阿里IoT云产品流转打通IoT消息和小程序方案

方案使用阿里云物联网平台，基本无需服务端开发的轻量级的方案。大概流程如下：

阿里云物联网方案

消息队列RocketMQ

当设备基于Topic进行通信时，可以在数据流转中，编写SQL对Topic中的数据进行处理，并配置转发规则将处理后的数据转发到消息队列RocketMQ，还可以通过添加错误操作将正常操作中因实例或配置问题流转失败的数据再次流转。

举例说明如下：

处理数据：

创建数据流转规则时，需编写SQL来解析和处理设备上报的JSON数据

SELECTdeviceName()asdeviceName, items.CurrentHumidity.valueasHumidity, items.CurrentTemperature.valueasTemperatureFROM"/sysa15NNfl****/N5KUR***/thing/event/property/post"WHEREitems.CurrentTemperature.value>38

数据转发：

错误操作：

消息转发至云产品失败后，会进行重试。若重试失败，将根据错误操作数据转发的设置转发错误消息。

微消息队列MQTT版

可以支持消息队列RocketMQ和消息队列MQTT的消息互通，从而实现设备端和云端的双向打通。微消息队列MQTT在数据传输层支持TCP长连接、SSL加密、WebSocket等。技术栈如下所示：

通过配置规则和传统服务端消息中间件消息队列RocketMQ来实现云和端的数据双向互通

创建数据流入规则，举例说明如下：

至此，方案中最主要的部分已经实现了。