背景
还记得,我们在物联网设备数据流转之实时数据从哪里来、如何转发:Node.js, MQTT, EMQX的WebHook这篇文章中,当 EMQX
的 WebHook
收到来自设备的消息时,我们当时只是简单地进行了打印输出,在我们真正实现实时消息推送前,先完成这样一件事:
将
WebHook
中的消息通过Spring
事件发送出去,随后再定义事件监听者(本项目中有两个监听者:1.TDengine
存储;2.WebSocket
推送)完成消费。
-
TDengine
存储; -
WebSocket
推送;
下面我们先完成 TDengine
数据存储。让我们看看设备消息现在到哪里了。