这是关于MQTT的第三篇文章，也是最后一篇关于MQTT的介绍和如何在ESP8266使用的文章，不过本篇文章只是简单的一个串口收发MQTT消息的小Demo，后面如果我们在实际的小项目中用到关于MQTT相关的内容，将不再做介绍，大家如果还没有看过前两篇文章的可以戳下面卡片看一下。
文章都是利用业余时间所写，如果有错误可以指出我及时改正。
废话不多说，我们这里直接开始，这里我简单写了一个控制LED灯的小Demo方便大家更好的观看效果，为了好区分，我这里一共有3个主题，每个主题对应不同的操作：
- /imliubo/mqtt/recv -> ESP8266订阅的主题，主要接收电脑端，或者手机端的消息
- /imliubo/mqtt/send -> 电脑端或手机端订阅的主题，接收ESP8266发送的消息
- /imliubo/mqtt/blueLED -> 控制LED的主题，发”on“-> 开，发”off “-> 灭
其中ESP8266发送消息是接收到手机或者电脑端消息后才发送，每条消息都有一个序列号，控制LED灯亮灭是必须用”/imliubo/mqtt/blueLED“这个主题，在其他主题下发送”on“或”off“没有用，我们先看一下主要代码：
1 void mqttConnectedCb(uint32_t *args) 2 { 3 MQTT_Client* client = (MQTT_Client*)args; 4 INFO("MQTT: Connected "); 5 MQTT_Subscribe(client, "/imliubo/mqtt/recv", 0);//订阅主题 6 MQTT_Subscribe(client, "/imliubo/mqtt/blueLED", 0);//订阅主题 7 8 MQTT_Publish(client, "/imliubo/mqtt/send", "This message is ESP8266 send!", sizeof("This message is ESP8266 send!"), 0, 0); 9 //推送消息 10 } 11 12 void mqttDataCb(uint32_t *args, const char* topic, uint32_t topic_len, const char *data, uint32_t data_len) 13 { 14 char *topicBuf = (char*)os_zalloc(topic_len+1), 15 *dataBuf = (char*)os_zalloc(data_len+1); 16 17 MQTT_Client* client = (MQTT_Client*)args; 18 19 os_memcpy(topicBuf, topic, topic_len); 20 topicBuf[topic_len] = 0; 21 22 os_memcpy(dataBuf, data, data_len); 23 dataBuf[data_len] = 0; 24 25 INFO("Receive topic: %s, data: %s ", topicBuf, dataBuf); 26 27 if(!strcmp(topicBuf,"/imliubo/mqtt/blueLED")){//判断主题是否是控制LED灯的主题 28 if(!strcmp(dataBuf,"on")){//判断开关命令 29 GPIO_OUTPUT_SET(GPIO_ID_PIN(14),1);//亮 30 }else if(!strcmp(dataBuf,"off")){ 31 GPIO_OUTPUT_SET(GPIO_ID_PIN(14),0);//灭 32 } 33 } 34 35 os_sprintf(send_data,"This message is ESP8266 send! >%d<",send_count); 36 MQTT_Publish(client, "/imliubo/mqtt/send",send_data , sizeof(send_data), 0, 0);//推送消息，send_count每次自增1 37 send_count ++; 38 39 os_free(topicBuf); 40 os_free(dataBuf); 41 }
这是主要代码，其实没多少东西，相信大家一看就懂，大家编译代码之前记得要先修改一下app->include->mqtt_config.h文件，如下：
1 #define CFG_HOLDER 0x00FF55A5 //一个标志位，如果下面的配置有更改可以将此标志位加1或者减1再编译下载 2 3 #define MQTT_HOST "192.168.0.106" //MQTT消息服务器IP地址，我这里是在局域网内本机测试的，不懂的可以看前一篇文章 4 #define MQTT_PORT 1883 //默认端口号 5 #define MQTT_CLIENT_ID "imliubo-esp8266" // ID，随意设置一个，也可不填 6 #define MQTT_USER "admin" //用户名，如果服务器开启了用户名密码鉴权登录，请修改 7 #define MQTT_PASS "admin" //密码，我这里是随便设置的，因为没有开启密码登录 8 #define STA_SSID "CMCC-Master" // your AP/router SSID to config your device networking 9 #define STA_PASS "zxcvbnmlk" // your AP/router password
这就是我们需要修改的地方，其他的我们可以先不用管，下面视频是实际测试视频，由于我现在主要开发平台也迁移到了Linux上，顺便也给大家演示一下如果在Ubuntu下编译和上传程序：
呃呃呃，录好的视频太大就传到了B站，但是审核两天多了一直还在等待审核，有点让人头大。。。。。。
后面审核通过了会修改本篇文章，各位看官先不要着急，不过前两个视频还是可以看的，前面文章没有看过的，可以先看一下~
另外本节代码已经更新在了我的仓库，大家可以下载先自己测试一下，其实我是在视频中演示了如何测试，但是现在迟迟审核不通过，再等等吧~
欢迎大家去我的仓库点个star，有问题可以提交issues，我看到后会第一时间回复。
视频已经审核通过，各位看官可以戳上面卡片观看了~本篇文章对应的是P3哟~
mua!(*╯3╰) mua!(*╯3╰)
QQ交流群：592587184