开发者社区> 问答> 正文

IOT学习——规则引擎之消息流转

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格式的消息。

展开
收起
ladyff 2017-03-10 14:43:16 3438 0
1 条回答
写回答
取消 提交回答
  • ReIOT学习——规则引擎之消息流转
    看所有的实例接收的json都是{}格式的,如果接收的是[{},{},{}]格式的json数组,select和where该怎么书写呢?
    例如:{"id":"1.1","name":"test1","status","1"},可以写出select id id ,name n ,status s from "/..." from status="1",
    但如果是[{"id":"1.1","name":"test1","status","1"},{"id":"1.2","name":"test1","status","0"}],该怎么写呢?
    2017-05-24 11:18:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
ST + AliOS > Smart IoT ! 立即下载
IOT赋能旅行场景的实践与展望 立即下载
阿里云IoT物联网市场暨合作伙伴计划发布 立即下载