【002:ESP8266 移植 Mqtt 】

系统环境: ubuntu 16.04 64bit
SDK版本: esp_iot_sdk_v1.3.0
记录时间: 2016年10月13日
联系方式: yexiaopeng1992@126.com

背景:在Esp8266上实现Mqtt,使之可以和Mqtt服务器进行数据通讯,代替原本项目中使用的socket通讯。

一、Mqtt在esp8266上的移植

使用开源工程 esp_mqtt https://github.com/tuanpmt/esp_mqtt

1.下载esp_mqtt 代码

  #git clone https://github.com/tuanpmt/esp_mqtt.git

2.将esp_mqtt中关于Mqtt需要的代码添加到自己工程

相关代码:esp_mqtt/mqtt 和 esp_mqtt/modules 下除 Makefile的文件
我将其中的 .h 和 .c 文件分别添加到 项目的 esp_iot_sdk_v1.3.0/app/driver 和 esp_iot_sdk_v1.3.0/app/include/driver下

在将esp_mqtt/include 下的user_config.sample.h文件中的有关配置信息的宏定义复制粘贴到 /esp_iot_sdk_v1.3.0/app/include下
的user_config.h 文件中即可。

3.添加mqtt的顶层代码

将 esp_mqtt/user 下的user_main.c 中除user_init之外的代码复制粘贴到自己的文件中。

4.修改平台相关代码

esp_mqtt项目和网络上的其他一些项目关于Mqtt&esp8266基本是基于NONOS_SDK的,与我项目中使用的esp_iot_sdk不同,因此在esp_mqtt
的代码中会有部分函数是esp_iot_sdk没有的,需要修改为esp_iot_sdk中相同功能的函数。

如将 mqtt_tcpclient_delete() 函数中 espconn_abort 替换为 espconn_disconnect,两者的功能皆为断开TCP连接

再将新添加的 mqtt相关代码的 头文件路径做修改后就能正常编译了。

二、Mqtt服务器搭建(仅测试)

http://makerpro.cc/2016/02/use-esp8266-and-mqtt-to-transfer-iot-data/ 或者 
  http://regishsu.blogspot.tw/2016/02/study-esp8266-notemcu-mqtt-study02xx.html

参考其关于服务器的搭建和测试方式即可

三、修改esp8266关于Mqtt的配置

user_config.h中,原始配置

#define MQTT_HOST     "192.168.0.101" //or "mqtt.yourdomain.com"
#define MQTT_PORT 1883
#define MQTT_BUF_SIZE 1024
#define MQTT_KEEPALIVE 120 /*second*/ #define MQTT_CLIENT_ID "CLIENT_1234"
#define MQTT_USER "USER"
#define MQTT_PASS "PASS"
#define MQTT_CLEAN_SESSION 1
#define MQTT_KEEPALIVE 120 #define STA_SSID "SSID"
#define STA_PASS "PASS" #define MQTT_RECONNECT_TIMEOUT 5 /*second*/ #define DEFAULT_SECURITY 0
#define QUEUE_BUFFER_SIZE 2048 #define PROTOCOL_NAMEv31

其中主要修改 MQTT_HOST 为 Mqtt 服务器地址, STA_SSID 和STA_PASS 为 wifi的名称和密码即可,其他配置根据自己情况修改。

四、修改esp8266中与Mqtt服务器的数据接收和发送

就两个函数 
    MQTT_Publish():发送消息到Mqtt 服务器
    mqttDataCb():  接收到Mqtt消息的回调函数

说明:一开始esp8266和服务器可以正常连接,但按照 Mqtt服务器测试参考的链接(见上文)中的提供的方式,esp8266无法和服务器做数据通讯,回来将 esp_mqtt 中 /mqtt/topic/0  改为 和链接中一样为 hello/world 后可以数据通讯了(具体原因应该和Mqtt有关,此时未学习mqtt,故不知道原因)
例子
    MQTT_Publish(&mqttClient, "hello/world", "mhjjs7", 6, 0, 0);

上一篇:关于duilib中的list的扩展探索


下一篇:react native中一次错误排查 Error:Error: Duplicate resources