【LwIP学习营】【第四周】利用RT-Thread的MQTT连接阿里云

发布于 2018-06-14 09:24:07 浏览：4816 订阅该版

* 本帖最后由 碧水渊 于 2018-6-14 09:26 编辑 *

RT-Thread版本：3.0.3
编译软件:MDK
硬件平台：STM32F407IGT6

阿里云平台地址：linkdevelop.aliyun.com

连接阿里云和连接onenet有些区别，不是修改几个参数就可以直接连上的，还需要修改部分代码。刚开始的时候心里没底，觉得很难，但是坚持做完了，发现，大部分工作rt-thread已经做了，我们只需要应用即可。下面是我的连接过程，截图为主。
一、需要找到阿里云的地址和一个阿里云账号
在这一步晃悠了两天，找的不是地方，最后还是用@虞昊迪提供的网址才算是成功的进入了阿里云的控制台。并注册一个阿里云账号。进入控制台后如果已经创建了项目，会直接显示出来，如下图
![1.png](/uploads/201806/14/085202nzpjrsdntpxmr8py.png)
如果没有创建项目，请参照下图所示的开发文档部分内容自行操作。
这份开发文档的链接地址：[https://linkdevelop.aliyun.com/developGuide#kgd6wp.html](https://linkdevelop.aliyun.com/developGuide#kgd6wp.html)
![2.png](/uploads/201806/14/085529kzwxx11g1x4gs1xu.png)
二、在rt-thread上编辑代码，进行测试
有了上次连接onenet的经验，我希望在onenet代码的基础上修改，达到连接阿里云的目的。
首先需要连上阿里云，然后才能上传数据。
阿里云也支持mqtt方式连接，连接的时候主要是参数的设定。查看开发文档下图所示部分。设定topic，mq_client.uri、mq_client.condata.clientID、mq_client.condata.username、mq_client.condata.password、mq_client.condata.keepAliveInterval、mq_client.messageHandlers[0].topicFilter参数的值。修改的时候可以参照连接onenet时候用的mqtt初始化函数onenet_mqtt_init的结构。
![3.png](/uploads/201806/14/090124bktf46uxcff555zt.png)
我们选用的是Alink格式，我们上报的数据需要符合Alink格式才能被阿里云平台识别。参照开发文档中对设备上行数据的要求，组织需要发送的数据，对数据格式的组织，我是通过直接调用cJSON函数实现的。这的修改，我参考了onenet_get_digit_data函数。改动比较大，但是最初的这个函数提供了应用cJSON的函数的启发。
组织好了数据格式，需要上传数据，这步参考了onenet_publish。
最终连接到阿里云的效果图如下
![4.png](/uploads/201806/14/092121j5yszt5ggkyto8jc.png)![5.png](/uploads/201806/14/092124lqm4j03jjjbpjw4j.png)
[hr][hr][hr][hr]
![FastAdmin]()
[align=center]这是一个分割线
![FastAdmin]()
[hr][hr][hr][hr]
以上是我的连接过程，但是做完以后才发现rt-thread官方例程里面有一个mqtt_test.c，里面有现成的实现mqtt连接的例子，结构更清爽。总结：对基本原理不熟悉，走了很多弯路。