一、消息生产
设备终端接入OneNET平台不同的产品套件,上传设备消息至OneNET平台;
开通消息队列MQ服务,创建消息队列MQ实例,添加topic和sub;
选择不同的 数据源 配置规则引擎和消息目的地,自定义 SQL规则 对消息数据进行过滤,将消息转发到消息队列MQ。
1、配置规则引擎
用户可以通过规则引擎
将物联网套件中的消息转发至消息队列MQ中
(1)打开MQTT物联网套件,进入产品详情
页面,在下图所示的位置添加规则
(2)选择消息源为:设备数据点消息
(3)消息目的地选择“消息队列MQ”,如图:
2、生产设备消息
用户可以使用平台的模拟工具产生设备消息,找到下图所示的位置:
点击发送数据
二、客户端消费数据
在MQTT.fx客户端,可以查看到接收到的数据(从控制台发送的模拟数据)
也可以通过Linux平台运行MQTTS协议产品设备
来源源不断地产生模拟数据
MQTT.fx客户端一直在接收数据: