IOT学习——规则引擎之消息流转
本文主要模拟的是消息通过规则引擎转发到消息队列,经过服务器端订阅再发布,实现消息在两个设备之间的流转。
[attachment=122261]
1
、首先创建产品和设备,创建规则引擎,将消息转发到消息服务。
[attachment=122262]
[attachment=122263]
关于服务器端的订阅,本文不做详细介绍,可以参考文章:
https://bbs.aliyun.com/read/309106.html?amp;displayMode=1&page=1&toread=1#tpc
2
、设备端接入
设备一:
[attachment=122264]
[attachment=122265]
3
、服务端接入,订阅消息,将消息转发到topic
[attachment=122266]
4
、运行函数,设备一发送消息,消息经过服务端转发出去,设备二收到消息
[attachment=122267]
这就是消息经过规则引擎转发到消息队列,服务器端再转发到另外一个设备的过程。
这里设备的接入都是MQTT
接入的,也可以用CCP
接入,同时对于设备二如果是CCP
接入的话,服务器端还可以采用RRPC
的方式直接将消息转发给设备。这种方式可以参考文章:
https://bbs.aliyun.com/read.php?tid=309164&displayMode=1&page=1&toread=1%23tpc
注意:经过规则引擎转发的消息必须是json格式的消息。