云产品流转 - 实现小车和微信小程序之间的通信（M2M通信）_阿里云云产品流转sql调试

@[toc]

功能需求：

小程序客户端（设备1）需要向小车（设备2）发送指令，控制小车的速度和方向等。所以，也就是说两个设备之间需要通信。

尝试方法：使用自定义 Topic

设备1：订阅了一个自定义的 Topic1

设备2：订阅了一个自定义的 Topic2

如果，设备1 想给设备2发送消息，则用 Topic2 来发布（也就是用设备2 的 Topic 来发布），由于设备2 已经订阅了 Topic2，所以设备2 就可以接收到设备1 发布过来的消息了。但是，阿里云平台做了限制，设备只能用自身的 Topic 来发布消息，不能用其他设备的Topic。所以自定义 Topic 这个方法行不通。

可行方法：云产品流转

云产品流转：编写 SQL 语句对 Topic 中的数据进行处理，并通过配置转发规则将处理过的数据转发到其他设备的 Topic。作用：实现不同设备之间的通信等等（具体看官网文档：网关与子设备 - 阿里云物联网平台 - 阿里云）。

接下来的工作就是：

① 在同一产品下创建两个设备：小车和微信小程序

② 创建云产品流转规则

③ 调试

[一] 创建设备

（1）创建产品（产品名称自定义）

创建产品时，需要选择节点类型。物联网平台目前支持三种节点类型：

• 直连设备：直连物联网平台，但不能挂载子设备的设备。

• 网关子设备：作为网关的子设备，由网关代理连接物联网平台。

• 网关设备：可以挂载子设备的直连设备。网关可以管理子设备，维持与子设备的拓扑关系，并将该拓扑关系同步到云端。

（2）创建完之后，就可以看到你的产品了，每个产品都有唯一的一个 ProductKey。点击【管理设备】，去创建设备

（3）创建设备（设备名称自定义），我这里创建的小车设备名为：Car_Robot，微信小程序设备名为：WX_Client

创建好设备之后，设备处于 “未激活” 的状态。只要连接一次设备之后，就可以激活了。

用 MQTT.fx 连接设备：

再去云端查看设备状态：显示【在线】，此时已经激活了。

（4）获取设备的 “三元组” 信息，以及 MQTT 连接参数

设备接入 - 认证方案

一机一密：即预先为每个设备烧录其唯一的设备证书。当设备与物联网平台建立连接时，物联网平台对其携带的设备证书信息进行认证。认证通过，物联网平台激活设备，设备与物联网平台间才可传输数据。

连接设备时，我们采用的是【一机一密】方式，所以需要获取设备的 “三元组” 信息，以及 MQTT 连接参数，这些参数在后面连接设备时都需要用到。

（5）给产品添加属性功能。产品的属性一般是指产品的运行状态，例如我的产品是一辆小车，小车的运行状态有速度，方向等，所以我的产品就设置了“速度”，“方向”等属性。

以上，就创建好两个设备了，可以先用 MQTT.fx 连接激活一下，也可以后面调式时再来激活。

[二] 配置云产品流转规则

了解一下云产品流转中，数据流转过程：

① 对于自定义 Topic，数据流转过程数据格式不变

② 对于物模型通信 Topic

可以看出，对于物模型通信 Topic，在数据流转过程中，payload 的数据格式被改变了，因此，如果要获取某个字段的值，如 temperature，则需要按物模型-解析结果的 payload 数据格式来获取：items.temperature.value。

开始配置云产品流转规则：

（1）现在阿里云提供了功能更加强大的【云产品流转新版】，如果想用回【旧版】，可以点击【返回旧版】

（2）创建规则，规则名称自定义，数据格式选择 "JSON"

（3）编写 SQL 语句。注意：这里的字段，需要和你给产品添加属性功能时的标识符字段保持一致。例如，我的小车有一个属性是 “速度”，我给产品添加 “速度” 这个属性功能时起的标识符字段是 Speed，所以这里就需要填写 items.Speed.value

（4）编写数据操作规则：将微信小程序的 Topic 数据发布到小车的 Topic

（5）返回上一页，启动规则：

[三] 调试

在【监控运维】-【设备模拟器】中打开两个设备的模拟器（开两个网页来分别打开两个设备）

微信小程序 WX_Client 发送指令：

小车 Car_Robot 收到指令：

其实，中间是云服务器来帮我们转发的。

微信小程序通过物模型 Topic：/sys/gl9fb/WX_Client/thing/event/property/post（前提是这个 Topic 具备“发布”的权限）来发送指令给云端，云端收到后，根据配置的云产品流转规则，将来自 Topic：/sys/gl9fb/WX_Client/thing/event/property/post 的数据消息进行处理，然后将处理后的数据发送给小车的Topic：/sys/gl9fb/Car_Robot/thing/service/property/set（前提是这个 Topic 具备“订阅”的权限），这样，小车就可以收到微信小程序发送的指令了。