玩转OneNET物联网平台之MQTT服务②|玩转OneNET物联网平台之MQTT服务② —

文章图片
image 1.理论基础 ????参考博主线上博文：

玩转PubSubClient MQTT库
玩转OneNET物联网平台之简介
玩转OneNET物联网平台之MQTT服务①

2.远程控制LED 2.1 实验材料

ESP8266 NodeMcu
OneNet Mqtt调试工具
OneNet平台

2.2 实验步骤
2.2.1 创建 ESP8266智能灯系统产品（MQTT协议）

玩转OneNET物联网平台之MQTT服务②|玩转OneNET物联网平台之MQTT服务② —— 远程控制LED

文章图片
image 注意点：

务必选择MQTT协议

????创建完毕后，我们点击查看具体的产品信息：

文章图片
image 注意点：

需要记录产品ID，其用来区分产品唯一标识符
Master-APIkey，网络请求鉴权信息，接口调用需要带入

2.2.2 API调试创建 deviceA和deviceB两个设备 API接口定义：

参考官方文档创建设备

操作步骤：

通过API调试工具创建deviceA

文章图片
image http body：

{ "title": "mqtt_device_A", "desc": "mqtt_device_A", "tags": ["china", "mobile"], "location": { "lon": 109, "lat": 23.54 }, "auth_info": "mqtt_device_A", "other": { "version": "1.0.0", "manufacturer": "china mobile" } }

通过API调试工具创建deviceB

文章图片
image http body：

{ "title": "mqtt_device_B", "desc": "mqtt_device_B", "tags": ["china", "mobile"], "location": { "lon": 109, "lat": 23.54 }, "auth_info": "mqtt_device_B", "other": { "version": "1.0.0", "manufacturer": "china mobile" } }

查看设备列表

文章图片
image 2.2.2 NodeMcu烧录代码 —— deviceA ????为了明确区分代码功能，博哥命名工程名为P_OneNet_Exam01:

P_OneNet_Exam01.ino文件：

/** *功能：ESP8266 Mqtt客户端调试主题功能，订阅OneNet Mqtt工具发过来的控制Led消息 *作者：单片机菜鸟 *时间：2019-06-25 *描述： *1.OneNet平台端：提前在OneNet平台创建DeviceA，DeviceB两个设备点，DeviceA属于NodeMcu，DeviceB属于OneNet Mqtt调试工具 *2.初始化工作：初始化网络配置，Mqtt客户端配置，连接鉴权，订阅主题 *3.订阅消息：获取发送过来的消息（json格式），解析消息，实现控制亮灭灯 */#include #include #include #include "H_project.h"int state; WiFiClient espClient; //声明方法 void initSystem(); void initOneNetMqtt(); void callback(char* topic, byte* payload, unsigned int length); /** * 初始化 */ void setup() { initSystem(); initOneNetMqtt(); }void loop() { ESP.wdtFeed(); state = connectToOneNetMqtt(); if(state == ONENET_RECONNECT){ //重连成功需要重新注册 mqttClient.subscribe(TOPIC,1); mqttClient.loop(); }else if(state == ONENET_CONNECTED){ mqttClient.loop(); } delay(2000); }void initSystem(){ int cnt = 0; Serial.begin (115200); Serial.println("\r\n\r\nStart ESP8266 MQTT"); Serial.print("Firmware Version:"); Serial.println(VER); Serial.print("SDK Version:"); Serial.println(ESP.getSdkVersion()); wifi_station_set_auto_connect(0); //关闭自动连接 ESP.wdtEnable(5000); WiFi.disconnect(); delay(100); WiFi.begin(ssid, password); while (WiFi.status() != WL_CONNECTED) { delay(500); cnt++; Serial.print("."); if(cnt>=40){ cnt = 0; //重启系统 delayRestart(1); } } pinMode(LED_BUILTIN, OUTPUT); }void initOneNetMqtt(){ mqttClient.setServer(mqttServer,mqttPort); mqttClient.setClient(espClient); mqttClient.setCallback(callback); initOneNet(PRODUCT_ID,API_KEY,DEVICE_ID); }void callback(char* topic, byte* payload, unsigned int length) { Serial.print("Message arrived ["); Serial.print(topic); Serial.print("] "); for (int i = 0; i < length; i++) { Serial.print((char)payload[i]); } Serial.println(); if ((char)payload[0] == '1') { digitalWrite(LED_BUILTIN, LOW); } else { digitalWrite(LED_BUILTIN, HIGH); } }

H_project.h 代码:

#ifndef _MAIN_H__ #define _MAIN_H__extern "C" { #include "user_interface.h" #include "smartconfig.h" }/************** ESP8266相关操作 **************************/ void delayRestart(float t); void delayNs(uint8_t m); /*********************************************************//*************** OneNet MQTT相关操作 ****************************/ void initOneNet(uint8_t *productId,uint8_t *apiKey,uint8_t *deviceId); int connectToOneNetMqtt(); /*********************************************************/#define ONENET_DISCONNECTED 1 //已经断开 #define ONENET_CONNECTED 2//已经连接上 #define ONENET_RECONNECT 3//重连成功//常量 #define VER"MQTT_LED_V1.0" const char* ssid = "xxxx"; //wifi账号 const char* password = "xxxx"; //wifi秘密//OneNet相关 PubSubClient mqttClient; const char* mqttServer = "183.230.40.39"; //mqtt服务器 const uint16_t mqttPort = 6002; #define PRODUCT_ID"xxxx" //此为博哥自己的产品id 请新建自己的 #define API_KEY"xxxx" #define DEVICE_ID "xxxx" #define TOPIC"xxxx"unsigned long lastWiFiCheckTick = 0; bool ledState = 0; #endif

????全部工程代码，博哥放在个人QQ群里。