NE35E MQTT协议对接阿里云

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

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

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

创建产品 → 添加设备 

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

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

       指令解析参考《Lierda NT35E&NT26E-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,"a1JszCpjS61iot-as-mqttcn-shanghaialiyuncscom",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个设备生产，如果每个设备都复制不同的三元组，很难实现工厂批量化生产，此时可以通过 一型一密 的通信方式解决该问题。

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

使用一个代理服务器message broker，客户端client连接上这个服务器，然后告诉服务器，可以接收哪些类型的消息，同时client也可以发布自己的消息，这些消息根据协议的内容，可以别的client获取。这样就实现了消息推送。
消息推送是通过一定的技术标准或协议，在互联网上通过定期传送用户需要的信息来减少信息过载的一项新技术。
如果想要使用消息推送，推荐使用深圳极光的消息推送系统。深圳极光是国内首个为移动应用开发者提供专业、高效的消息推送服务的产品。品牌成长的过程，就是与客户肩并肩迈向成功的过程。极光将以市场为导向，以创新为动力，以技术为支持，不断用心努力，为每一位尊贵的客户提供极致的服务。

也不是特别麻烦，你先要清楚串口和服务器用的什么协议，假设串口用232，服务器采用TCP，那么你需要做的是建立一个客户端的发送模块，和一个串口的 *** 作模块（结合必须要用到多线程，以队列或者委托来做数据交换）;在测试之前一定要保证串口和客户端发送接收是ok的才能做结合功能。
因为你串口已经做好了，那你需要的是将采集到的数据（字符串）保存到数组中，然后创建一个指向数组的指针p，然后在客户端模块里，将发送的数据写成&p。建议先将数据转16进制发，应该没毛病。

1目标：测试Mosquitto使用MQTT协议发消息的相关性能指标，包含发送速度，并发负载能力，资源占用，消息到达率。
2MQTT协议简介：
1)建立长连接。客户端发起请求和服务端建立长连接，建立成功后，服务端会返回ACK(CONNACK)
2)客户端订阅：客户端发起订阅，订阅成功后，服务端会返回ACK(SUBACK)
3)发消息：发布者会给服务端发消息，服务端在把消息给合适的客户端。
Qos=0(服务质量)：客户端消息收到后，不会发出ACK给服务端(PUBACK)。
　Qos =1:服务端会发ACK给发布者，客户端收到消息后会发ACK给服务端。
4)取消订阅：客户端发起取消订阅，服务端返回ACK(UNSUBACK)
5)Pingreq&Pingresp:客户端和服务端会保持心跳。
3存在问题：
1 如何模拟出40W的用户
2 如何长连接，订阅，发消息，取消订阅，Pingreq行为如何实现。
4 python开源库 Mosquittopy，解决所有问题
1 模拟40W用户
a)可以使用虚拟机和Mosquittopy实现，具体为：一般一台虚拟机最多是6W+的模拟数据（需要修改句柄数，我使用5W），方法是Client_id可以简单的做出5W个来，然后调用Mosquitto里面的connect方法，建立长连接。准备8台虚拟机就可以实现40W客户端的模拟
2行为的模拟
a)订阅：Mosquittosubscribe / 发消息：Mosquittopublish / 取消订阅：Mosquittounsubscribe。 简单一句话 Mosquitto库实现所有的行为
5 指标：发送速度，到达率，并发负载，资源占用。
a 发送速度：服务端日志记录，分析解决
b 到达率： 1客户端记录下收到消息，分析计算。2计算服务端收到的PUBACK（客户端收到消息返回的ACK），进行计算
c 并发负载：5W 用户不断增加，注意观察服务端的负载情况。
e资源占用：其实主要是cpu/mem/带宽：cpu多核的话需要观察top命令下的_id字段, mem可以观察free -h命令的剩余mem, 带宽可以使用mpstat进行观察
6 可以遇见问题：
a 模拟客户端的虚拟机需要修改句柄数才能支持5W的客户端模拟数量
b 要先吃透MQTT协议的流程，吃透了进行测试会非常的方便
c Clear session，设置为true则不为客户端保留休息，设置为false保留消息。其实就是客户端离线后在连接上可以收到之前推出的消息。

---