【转】基于麒麟座开发板2.0的MQTT实现例程
本帖最后由 894540228 于 2017-7-12 14:07 编辑本文转载自OneNET论坛，原贴地址https://open.iot.10086.cn/bbs/thread-1266-1-1.html
OneNET现已全面适配标准MQTT协议，相信这一功能的增加回大大便于开发者进行设备的接入。
OneNET提供了MQTT 的 C语言版本的SDK供大家使用，接下来我们将利用该SDK，将MQTT协议移植到麒麟座开发板上，希望这边文章能对希望使用MQTT接入OneNET的开发者提供一定帮助。
（本例中使用的SDK、调试工具、以及说明文档，均可以在线文档中的MQTT专区下载到）
1 下载SDK
首先进入我们的MQTT说明专区，找到C语言SDK下载链接，下载SDK。
http://upfiles.heclouds.com/forum-app/2016/12/09/bff1f1f2b3dc4e36cbf828094edc6183.jpg
其中：
mqtt/config.h mqtt/mqtt.hmqtt/mqtt_buffer.hsrc/mqtt.c src/mqtt_buffer.c为MQTT相关的.c 以及.h文件
sample/c/sample.c是使用示例文件
2 代码的移植
将上述.c 以及 .h 文件复制到 开发板的工程中 Protocol/mqtt目录下，在工程中添加mqtt.c以及mqtt_buffer.c文件（记得修改Include Path 路径）
由于SDK是在linux环境下编译以及测试的，移植到STM32环境下带来了平台的差异性。
主要记得修改如下地方：
1、修改MQTT相关的.h文件的include路径，使之与工程环境相匹配
2、屏蔽掉原来的assert函数，和inline关键字
3、修改分配的缓冲区的大小
主要是MqttSample_Init()函数中的Mqtt_InitContext() 函数，SDK中分配了 1<<20大小的字节，由于STM32资源有限，这里需要改小一点，本例中为1000字节
4、修改接口的初始化、收、发函数。
原SDK是在linux系统中利用网口来实现通信，而开发板中使用串口连接通信模块的形式实现通信，相关的函数都需要作相应的修改，详见代码文件
3 代码示例
源代码如下：
https://open.iot.10086.cn/bbs/static/image/filetype/rar.gif OneNET_Demo_v0_8266_mqtt.rar (5.35 MB, 下载次数: 5027)
本例中的代码流程如下图：
http://upfiles.heclouds.com/forum-app/2016/12/09/3f19043a08739483c697d2a79fb5e6af.jpg
开发板资源分配如下：
http://upfiles.heclouds.com/forum-app/2016/12/09/21981ea3010dcd42ec10107853745881.jpg
代码中需要修改的参数位置：
main.c
line 40：
[*]#define PROD_ID "70901" //修改为自己的产品ID
[*]#define SN "201608160002" //修改为自己的设备唯一序列号
[*]#define REG_CODE "6TM7OkhNsTjATvFx"//修改为自己的产品注册码
复制代码
line 789
[*]char *topics[] = {"test_topic", "test_topic2"}; //订阅的topic
复制代码
esp8266.h
line1 :
[*]#define SSID "PHICOMM_2590BC" //修改为自己的WIFI热点名
[*]#define PASSWD "1234567890" //修改为自己的WIFI密码
复制代码
4 SDK 使用示例
MQTT连接
[*]struct MqttSampleContext ctx;
[*]
[*]MqttSample_Connect(ctx, PROD_ID, SN, ctx->devid, keep_alive, clean_session);
[*]bytes = Mqtt_SendPkt(ctx->mqttctx, ctx->mqttbuf, 0);
[*]MqttBuffer_Reset(ctx->mqttbuf);
复制代码
MQTT订阅
[*]struct MqttSampleContext ctx;
[*]
[*]MqttSample_Subscribe(ctx, topics, 1); //可一次订阅多个，本例只用只订阅一个topic
[*]bytes = Mqtt_SendPkt(ctx->mqttctx, ctx->mqttbuf, 0);
[*]MqttBuffer_Reset(ctx->mqttbuf);
复制代码
MQTT发布消息
[*]struct MqttSampleContext ctx;
[*]
[*]MqttSample_Publish(ctx, temp, humi);
[*]bytes = Mqtt_SendPkt(ctx->mqttctx, ctx->mqttbuf, 0);
[*]MqttBuffer_Reset(ctx->mqttbuf);
复制代码
MQTT回复命令
[*]struct MqttSampleContext ctx;
[*]
[*]MqttSample_RespCmd(ctx, "cmd received");
[*]bytes = Mqtt_SendPkt(ctx->mqttctx, ctx->mqttbuf, 0);
[*]MqttBuffer_Reset(ctx->mqttbuf);
复制代码
MQTT上传数据
[*]struct MqttSampleContext ctx;
[*]
[*]MqttSample_Savedata(ctx, temp, humi);
[*]bytes = Mqtt_SendPkt(ctx->mqttctx, ctx->mqttbuf, 0);
[*]MqttBuffer_Reset(ctx->mqttbuf);
[*]
复制代码
接收数据解析
[*]err = Mqtt_RecvPkt(ctx->mqttctx);
[*]USART2_Clear();
复制代码
5 代码接入测试
使用MQTT simulate device 来模拟同产品目录下的另外一个设备
http://upfiles.heclouds.com/forum-app/2016/12/09/2ab2b9543ac76c7eb25a76d43fd98fe5.jpg
打开设备电源，在调试串口目录下可以看到调试信息
http://upfiles.heclouds.com/forum-app/2016/12/09/1bb145da0d19060ee99aa12790e76f9c.jpg
http://upfiles.heclouds.com/forum-app/2016/12/09/14e33996b22409d65db2c665935feac7.jpg
http://upfiles.heclouds.com/forum-app/2016/12/09/f51db673e83faa4e0bf29eb224abfafd.jpg
http://upfiles.heclouds.com/forum-app/2016/12/09/03c6ecc1cc1653c888339f872fdb2a83.jpg
http://upfiles.heclouds.com/forum-app/2016/12/09/7ad5c91ec2eb86c4e208aebfeb1e901f.jpg
使用模拟设备与平台建立连接
http://upfiles.heclouds.com/forum-app/2016/12/09/d5e04b0be3889cbf908554b494441036.jpg
可以看到产品topic列表中已经有开发板所创建的 test_topic（订阅自动创建）
5.1 topic发布以及接收测试
在订阅框中输入key_press ，点击订阅（该topic为开发板按键发布消息的topic）
http://upfiles.heclouds.com/forum-app/2016/12/09/2aa790db81fb71ec4b5983d0fa989a7f.jpg
按下开发板上的key2，见调试信息：
http://upfiles.heclouds.com/forum-app/2016/12/09/3b064b5265dba5151ae779f80cff3ed4.jpg
触发消息之后，在模拟器侧，就可以收到该topic的消息了
http://upfiles.heclouds.com/forum-app/2016/12/09/ae049449ccbf70cfbae6923e958d3556.jpg
使用模拟软件，向test_topic发送一则消息
http://upfiles.heclouds.com/forum-app/2016/12/09/00d654f6bbaf762f0200cc6533d53e7f.jpg
在开发板侧，可以从调试信息中看到，已经收到了该topic消息
http://upfiles.heclouds.com/forum-app/2016/12/09/c7e4d75f9ca89299c8f29cc7660f9fc8.jpg
至此，topic的订阅与发布测试已完成。
5.2命令下发与应答测试
在线发送命令给开发板
http://upfiles.heclouds.com/forum-app/2016/12/09/409b87873c6a121dacb2fc79027ab622.jpg
在调试信息中可以看到以及接收了该命令并成功解析
http://upfiles.heclouds.com/forum-app/2016/12/09/d568e66c650513db77e4342305d51fa1.jpg
此时LED7已经被点亮
http://upfiles.heclouds.com/forum-app/2016/12/09/c62889e64bafef907c118f337df97e7d.jpg
根据调试信息可以看出，该命令的uuid为 8c14d921-8d10-5ef3-ac40-ea0befa250c7
使用API可以获取该命令的执行状态
http://upfiles.heclouds.com/forum-app/2016/12/09/f7cbe028eedf038dc02c19cc6d8856ae.jpg
当前状态为 已发送
按下开发板上的key3 ，进行命令回复，回复内容为 “cmd receive”
http://upfiles.heclouds.com/forum-app/2016/12/09/71caf3b38b56dc33910c0bc90ac638fb.jpg
再次进行API调用，查看命令状态：
http://upfiles.heclouds.com/forum-app/2016/12/09/51b8cef7047d0c91b6e098fcded2ba76.jpg
可见状态变为，应答已接收
通过API获取命令回复内容：
http://upfiles.heclouds.com/forum-app/2016/12/09/81415899d8b608864f04ce244edbf920.jpg
可以看出，命令的应答内容，已经可以通过API成功获取到。
至此，平台命令的下发以及命令响应功能已全部完成。
（完）
页:
[1]