阿里云mqtt同步（阿里云mqtt数据保存到数据库）

今天给各位分享阿里云mqtt同步的知识，其中也会对阿里云mqtt数据保存到数据库进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

微信号：cloud7591
如需了解更多，欢迎添加客服微信咨询。
复制微信号

本文目录一览：

• 1、NE35E MQTT协议对接阿里云
• 2、玩转 ESP32 + Arduino (十六) 通过mqtt协议连接阿里云
• 3、阿里云物联网平台搭建（5）基础平台服务的调用

NE35E MQTT协议对接阿里云

MQTT通信协议的基本介绍参考文章 NT35 MQTT通信 ，本篇给出阿里云的基本操作，NT35E通过订阅阿里云的主题发布信息与阿里云平台相互通信。

登录阿里云 → 工作台 → 物联网平台 → 进入控制台→ 公共实例

阿里云默认通信协议为MQTT，不需要特殊选择，用户按照如下步骤创建自己的产品：

创建产品 → 添加设备 

在"查看"标签中，包含了MQTT连接的基本三元组信息，也就是后面设备要填充的基本参数

      用户每定义一类产品都会自动生成对应的Topic列表，当然我们也可以"自定义Topic"便于自己测试。

       指令解析参考《Lierda NT35ENT26E-CN AT命令手册》，这里给出使用到的AT指令对应参数说明以便于理解。

AT+LMQTTCFG=cloud,tcpconnectID[,cloud _ type,data_type ]

tcpconnectID 。MQTT Socket 标识符。范围：0~4。

cloud_type整型。2 alibaba，其他参数指定其他平台

data_type整型。阿里云平台 1 json数据 

AT+LMQTTCFG="cloud",0,2,1   对应就是对接阿里云平台，发送json格式的数据

AT+LMQTTCFG=aliauth,tcpconnectID[,product_key,device_name,device_secret]

填充阿里云平台中设备的三元组信息

AT+LMQTTCFG="aliauth",0,"a1JszCpjS61","NT35E_06011","390358fc595040aa73221e8393aba86c"

这部分是模组进行TCP链路连接(需抓包确认)

AT+LMQTTOPEN=tcpconnectID,host_name,port

host_name对应阿里云 "设备信息"→"MQTT连接参数" 中的 "mqttHostUrl"

AT+LMQTTOPEN=0,"a1JszCpjS61.iot-as-mqtt.cn-shanghai.aliyuncs.com",1883

模组作为客户端，通过MQTT协议连接到服务器(需抓包确认)

AT+LMQTTCONN=tcpconnectID[,clientID[,username[,password]]]

clientID字符串型。客户端标识符。用户可以随便定义。 username,password 不需要填写

AT+LMQTTCONN=0,"NT35E"

AT+LMQTTSUBUNSUB=tcpconnectID,subflag,msgID,topic1[,qos1[,topic2[,qos2]d…]]

subflag整型。消息类型 0 订阅 1 取消订阅

msgID整型。数据包消息标识符。范围：0~65535。

topic带双引号的字符串型。客户端订阅或者退订的主题。长度范围：0~256 字节。

qos整型。客户端发送订阅消息(SUBSCRIBE)的 QoS 等级，此时为必选参数。2 正好一次，该主题下的消息确保接收端仅接收到一次

AT+LMQTTSUBUNSUB=0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",2

这里注意topic对应参数的替换，里面的deviceName需要替换。

订阅主题之后，服务器下发的数据模组就可以正常接收了。模组下发位置

       发布消息在对应的设备目录下，如果有设备"订阅"对应的消息，平台"发布"相应的数据设备就可以接收到了。

AT+LMQTTPUB=tcpconnectID,msgID,qos,retain,topic,msglen,msg

msgID整型。 0~65535。任意定义，但qos=0 时，该参数值只能为0。

qos整型。 0 最多一次 1 至少一次 2  正好一次

retain整型 。服务器是否保存该消息。0 不保存  1 保存

topic带双引号的字符串型。 客户端发布消息的主题。长度范围：0~256 字节

msglen整型 。指定的消息数据长度。范围：0~1460。

msg字符串型。 需要发布的消息数据。

AT+LMQTTPUB=0,0,0,1,"/a1JszCpjS61/ NT35E_06011 /user/COMMUTEST",10,"1122334455"

       注意刚刚自己创建的主题属性是" 发布和订阅 "，所以模组发送该主题的信息，阿里云也是可以收到的

注意这里模组发送数据的时候，也推送了自己发送的数据，因为刚刚订阅了这个主题，所以模组订阅(收)到了对应的数据

       前面我们通过NT35E与平台进行信息交互，那么为什么是这样填写对应的参数呢，每个参数对应的说明在阿里云上是什么样的呢，用户可以查看阿里云的帮助文档进行确认。

       上面我们使用三元组的方式( 一机一密 )实现NT35E与阿里云平台通信，但实际生产过程中该方式不好实现，比如工厂有1000个设备生产，如果每个设备都复制不同的三元组，很难实现工厂批量化生产，此时可以通过 一型一密 的通信方式解决该问题。

一型一密模组端实现方式后续更新。

玩转 ESP32 + Arduino (十六) 通过mqtt协议连接阿里云

需要用到的库:

引入"PubSubClient.h"后

打开"PubSubClient.h"

修改如下内容:

关于MQTT协议, 请参考文章:

请参考我之前整理的文档:

【腾讯文档】MQTT连接阿里云示例(1)

如果使用了AliyunMqttArduino, 就不需要关系协议的报文和加密方式了

首先创建一个mqtt客户端

返回值: 连接结果

返回: 状态码

mqttClient.publish(主题, 内容)

首先, 创建产品:

其次, 为产品添加设备

第三, 查看设备关键信息:

创建完后,我们发现系统已经自动创建了一些功能定义

找到产品的功能页面, 点击"编辑草稿"

最后发布新的物模型

非常简单的修改, 只修改了要发送json里的param

注意同步修改param和json的内存占用大小

阿里云物联网平台搭建（5）基础平台服务的调用

之前一直想要使用mqtt协议模拟tcp协议的实时返回监控参数的功能，经过几个月的摸索和试验，终于将同步服务的开发摸透，仅仅看飞燕平台的技术文档是看不懂的，核心文档链接如下：

1、什么是rrpc，同步服务如何使用rrpc实现实时返回的效果

;aly_as=odhFNfAc

阿里将同步服务使用rrpc

2、服务的数据格式

;aly_as=KNMEpUOP

看完文档还有不懂的同学们，我给你准备了总结：

1.RRPC有专用的topic，服务端的实现，在物的模型服务中有invoke的请求方式和返回结果。

设备端根据文档1中的订阅topic与上报topic。上报的数据格式根据文档2上报。

例子：

1.按照物的服务调用方法请求

2.设备端订阅到服务的下发，将msgid从topic上面截取下来此处为1214836938775870464

3.将msgid填充到上报topic结尾，数据格式注意param改为data，加上code，其余数据对照功能定义中的物模型

4.在调试窗口中找到服务调用菜单

显示上报成功，注意服务的解析与属性事件不一样，通过通用打印只能打印出result ok，要进一步解析data出来再打印。

阿里云mqtt同步的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于阿里云mqtt数据保存到数据库、阿里云mqtt同步的信息别忘了在本站进行查找喔。