熊掌五十块 发表于 2017-7-7 09:26:58

【转】基于麒麟座开发板2.0的MQTT实现例程

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文件夹.jpg (0 Bytes, 下载次数: 717)
下载附件
2016-12-9 13:16 上传




其中：
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, 下载次数: 4536)
2016-12-22 09:25 上传
点击文件名下载附件





本例中的代码流程如下图：

http://upfiles.heclouds.com/forum-app/2016/12/09/3f19043a08739483c697d2a79fb5e6af.jpg
QQ截图20161209155653.jpg (0 Bytes, 下载次数: 713)
下载附件
2016-12-9 16:37 上传





开发板资源分配如下：

http://upfiles.heclouds.com/forum-app/2016/12/09/21981ea3010dcd42ec10107853745881.jpg
QQ截图20161209170524.jpg (0 Bytes, 下载次数: 705)
下载附件
2016-12-9 17:06 上传





代码中需要修改的参数位置：
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
两个设备.jpg (0 Bytes, 下载次数: 785)
下载附件
2016-12-9 18:05 上传





打开设备电源，在调试串口目录下可以看到调试信息

http://upfiles.heclouds.com/forum-app/2016/12/09/1bb145da0d19060ee99aa12790e76f9c.jpg
WIFI初始化.jpg (0 Bytes, 下载次数: 708)
下载附件
2016-12-9 18:04 上传




http://upfiles.heclouds.com/forum-app/2016/12/09/14e33996b22409d65db2c665935feac7.jpg
设备注册.jpg (0 Bytes, 下载次数: 1139)
下载附件
2016-12-9 18:05 上传




http://upfiles.heclouds.com/forum-app/2016/12/09/f51db673e83faa4e0bf29eb224abfafd.jpg
设备连接.jpg (0 Bytes, 下载次数: 707)
下载附件
2016-12-9 18:05 上传




http://upfiles.heclouds.com/forum-app/2016/12/09/03c6ecc1cc1653c888339f872fdb2a83.jpg
订阅.jpg (0 Bytes, 下载次数: 788)
下载附件
2016-12-9 18:05 上传




http://upfiles.heclouds.com/forum-app/2016/12/09/7ad5c91ec2eb86c4e208aebfeb1e901f.jpg
上传数据.jpg (0 Bytes, 下载次数: 785)
下载附件
2016-12-9 18:05 上传





使用模拟设备与平台建立连接

http://upfiles.heclouds.com/forum-app/2016/12/09/d5e04b0be3889cbf908554b494441036.jpg
模拟设备连接.jpg (0 Bytes, 下载次数: 714)
下载附件
2016-12-9 18:13 上传





可以看到产品topic列表中已经有开发板所创建的 test_topic（订阅自动创建）



5.1 topic发布以及接收测试
在订阅框中输入key_press ，点击订阅（该topic为开发板按键发布消息的topic）

http://upfiles.heclouds.com/forum-app/2016/12/09/2aa790db81fb71ec4b5983d0fa989a7f.jpg
订阅key_press.jpg (0 Bytes, 下载次数: 711)
下载附件
2016-12-9 18:26 上传





按下开发板上的key2，见调试信息：

http://upfiles.heclouds.com/forum-app/2016/12/09/3b064b5265dba5151ae779f80cff3ed4.jpg
按键2触发消息发布.jpg (0 Bytes, 下载次数: 712)
下载附件
2016-12-9 18:27 上传





触发消息之后，在模拟器侧，就可以收到该topic的消息了

http://upfiles.heclouds.com/forum-app/2016/12/09/ae049449ccbf70cfbae6923e958d3556.jpg
模拟软件收到topic消息.jpg (0 Bytes, 下载次数: 789)
下载附件
2016-12-9 18:27 上传






使用模拟软件，向test_topic发送一则消息

http://upfiles.heclouds.com/forum-app/2016/12/09/00d654f6bbaf762f0200cc6533d53e7f.jpg
模拟软件发送topic.jpg (0 Bytes, 下载次数: 785)
下载附件
2016-12-9 18:31 上传





在开发板侧，可以从调试信息中看到，已经收到了该topic消息

http://upfiles.heclouds.com/forum-app/2016/12/09/c7e4d75f9ca89299c8f29cc7660f9fc8.jpg
开发板收到topic消息.jpg (0 Bytes, 下载次数: 885)
下载附件
2016-12-9 18:31 上传







至此，topic的订阅与发布测试已完成。




5.2命令下发与应答测试
在线发送命令给开发板

http://upfiles.heclouds.com/forum-app/2016/12/09/409b87873c6a121dacb2fc79027ab622.jpg
发送命令.jpg (0 Bytes, 下载次数: 706)
下载附件
2016-12-9 18:35 上传





在调试信息中可以看到以及接收了该命令并成功解析

http://upfiles.heclouds.com/forum-app/2016/12/09/d568e66c650513db77e4342305d51fa1.jpg
接收命令.jpg (0 Bytes, 下载次数: 962)
下载附件
2016-12-9 18:35 上传





此时LED7已经被点亮

http://upfiles.heclouds.com/forum-app/2016/12/09/c62889e64bafef907c118f337df97e7d.jpg
点灯.jpg (0 Bytes, 下载次数: 787)
下载附件
2016-12-9 18:38 上传





根据调试信息可以看出，该命令的uuid为   8c14d921-8d10-5ef3-ac40-ea0befa250c7
使用API可以获取该命令的执行状态

http://upfiles.heclouds.com/forum-app/2016/12/09/f7cbe028eedf038dc02c19cc6d8856ae.jpg
sent.jpg (0 Bytes, 下载次数: 789)
下载附件
2016-12-9 18:40 上传





当前状态为 已发送

按下开发板上的key3 ，进行命令回复，回复内容为 “cmd receive”

http://upfiles.heclouds.com/forum-app/2016/12/09/71caf3b38b56dc33910c0bc90ac638fb.jpg
命令应答.jpg (0 Bytes, 下载次数: 787)
下载附件
2016-12-9 18:45 上传





再次进行API调用，查看命令状态：

http://upfiles.heclouds.com/forum-app/2016/12/09/51b8cef7047d0c91b6e098fcded2ba76.jpg
命令应答检测.jpg (0 Bytes, 下载次数: 789)
下载附件
2016-12-9 18:46 上传





可见状态变为，应答已接收

通过API获取命令回复内容：

http://upfiles.heclouds.com/forum-app/2016/12/09/81415899d8b608864f04ce244edbf920.jpg
获取响应.jpg (0 Bytes, 下载次数: 2225)
下载附件
2016-12-9 18:47 上传





可以看出，命令的应答内容，已经可以通过API成功获取到。

至此，平台命令的下发以及命令响应功能已全部完成。
（完）

fire 发表于 2017-7-7 11:24:01

帮顶            

kail_arm 发表于 2017-12-13 16:26:50

楼主：
    我按照你的方法移植，有一个函数报了警告assignment in condition，我检查了一下，判断句里出现了赋值操作，不知道这句代码怎么理解
struct DataPointPktInfo *Mqtt_GetDataPointPktInfo(struct MqttBuffer *buf)
{
    struct MqttExtent *fix_head = buf->first_ext;
    struct MqttExtent *first_payload;
    struct DataPointPktInfo *info;

    if(!fix_head) {
      return NULL;
    }

    if(MQTT_PKT_PUBLISH != (((uint8_t)(fix_head->payload)) >> 4)){
      return NULL;
    }

    if(!(fix_head->next) || !(first_payload = fix_head->next->next) ||
       (MQTT_DPTYPE_TRIPLE != first_payload->payload)) {
      return NULL;
    }

    if(first_payload->len != 2 + sizeof(struct DataPointPktInfo)) {
      return NULL;
    }

    info = (struct DataPointPktInfo*)(first_payload->payload + 2);
    if(DATA_POINT_PKT_TAG != info->tag) {
      return NULL;
    }

    return info;
}
页: [1]
查看完整版本: 【转】基于麒麟座开发板2.0的MQTT实现例程