玩转OneNET物联网平台之MQTT服务③

2023-03-11 18:16| 来源: 网络整理| 查看: 265

文章目录 1.理论基础 2.远程控制LED，实现设备自注册 2.1 实验材料 2.2 实验步骤 2.2.1 创建 ESP8266智能灯系统产品（MQTT协议） 2.2.2 NodeMcu烧录代码 —— MQTT设备端 3.总结

1.理论基础

参考博主线上博文：

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

在前面的博文中，博主主要通过手动方式去创建设备。这种方式的缺点明显：

人为手动控制，对于开发者来说极度不友好；如果设备数量很多，岂不是要手动操作非常多次；

那么，如何实现设备自注册呢？所谓自注册就是设备连入网络后自动往OneNet云平台注册设备信息并获取设备Id。

为了区分唯一性，我们采用ESP-Mac地址的组合形式 2.远程控制LED，实现设备自注册 2.1 实验材料 ESP8266 NodeMcu OneNet Mqtt调试工具 OneNet平台 2.2 实验步骤 2.2.1 创建 ESP8266智能灯系统产品（MQTT协议）

玩转OneNET物联网平台之MQTT服务③ —— 远程控制LED（设备自注册）_玩转OneNet教程

注意点：

务必选择MQTT协议

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

玩转OneNET物联网平台之MQTT服务③ —— 远程控制LED（设备自注册）_玩转OneNet教程_02

注意点：

需要记录产品ID，其用来区分产品唯一标识符 Master-APIkey，网络请求鉴权信息，接口调用需要带入 2.2.2 NodeMcu烧录代码 —— MQTT设备端

为了明确区分代码功能，博哥命名工程名为P_OneNet_Exam04:

P_OneNet_Exam04.ino文件： /** * 功能：ESP8266 Mqtt客户端自注冊功能，订阅OneNet Mqtt工具发过来的控制Led消息 * 作者：单片机菜鸟 * 时间：2019-06-30 * 描述： * 1.初始化工作：初始化网络配置，Mqtt客户端自注冊，连接鉴权，订阅主题 * 2.订阅消息：获取发送过来的消息（json格式），解析消息，实现控制亮灭灯 */ #include #include #include #include #include #include #include "H_project.h" #define MAGIC_NUMBER 0xAA int state; WiFiClient espClient; //声明方法 void initSystem(); void initOneNetMqtt(); void callback(char* topic, byte* payload, unsigned int length); void saveConfig(); void loadConfig(); bool parseRegisterResponse(); /** * 初始化 */ 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); loadConfig(); //还没有注册 if(strcmp(config.deviceid,DEFAULT_ID) == 0){ int tryAgain = 0; while(!registerDeviceToOneNet()){ Serial.print("."); delay(500); tryAgain++; if(tryAgain == 5){ //尝试5次 tryAgain = 0; //重启系统 delayRestart(1); } } if(!parseRegisterResponse()){ //重启系统 delayRestart(1); while(1); } } } void initOneNetMqtt(){ mqttClient.setServer(mqttServer,mqttPort); mqttClient.setClient(espClient); mqttClient.setCallback(callback); initOneNet(PRODUCT_ID,API_KEY,config.deviceid); } 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); } } /* * 保存参数到EEPROM */ void saveConfig() { Serial.println("Save OneNet config!"); Serial.print("deviceId:"); Serial.println(config.deviceid); EEPROM.begin(150); uint8_t *p = (uint8_t*)(&config); for (int i = 0; i < sizeof(config); i++) { EEPROM.write(i, *(p + i)); } EEPROM.commit(); } /* * 从EEPROM加载参数 */ void loadConfig() { EEPROM.begin(150); uint8_t *p = (uint8_t*)(&config); for (int i = 0; i < sizeof(config); i++) { *(p + i) = EEPROM.read(i); } EEPROM.commit(); if (config.magic != MAGIC_NUMBER) { strcpy(config.deviceid, DEFAULT_ID); config.magic = MAGIC_NUMBER; saveConfig(); Serial.println("Restore config!"); } Serial.println("-----Read config-----"); Serial.print("deviceId:"); Serial.println(config.deviceid); Serial.println("-------------------"); } /** * 解析注册返回结果 */ bool parseRegisterResponse(){ Serial.println("start parseRegisterResponse"); StaticJsonBuffer jsonBuffer; // StaticJsonBuffer 在栈区分配内存它也可以被 DynamicJsonBuffer（内存在堆区分配）代替 // DynamicJsonBuffer jsonBuffer; JsonObject& root = jsonBuffer.parseObject(response); // Test if parsing succeeds. if (!root.success()) { Serial.println("parseObject() failed"); return false; } int errno = root["errno"]; if(errno !=0){ Serial.println("register failed!"); return false; }else{ Serial.println("register sucess!"); strcpy(config.deviceid, root["data"]["device_id"]); saveConfig(); return true; } } H_project.h 代码: #ifndef _MAIN_H__ #define _MAIN_H__ extern "C" { #include "user_interface.h" #include "smartconfig.h" } struct onenet_config { char deviceid[15]; uint8_t magic; }; /************** 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(); /*********************************************************/ /**************** OneNet Http相关操作 ***************************/ HTTPClient http; String response; const char* host = "api.heclouds.com"; bool registerDeviceToOneNet(); /****************************************************************/ #define ONENET_DISCONNECTED 1 //已经断开 #define ONENET_CONNECTED 2 //已经连接上 #define ONENET_RECONNECT 3 //重连成功 //常量 #define VER "MQTT_LED_V1.0" const char* ssid = "xxxxxxxx";//wifi账号 const char* password = "xxxxxxx";//wifi秘密 //OneNet相关 PubSubClient mqttClient; const char* mqttServer = "183.230.40.39";//mqtt服务器 const uint16_t mqttPort = 6002; #define PRODUCT_ID "253190" //此为博哥自己的产品id 请新建自己的 #define API_KEY "aat9ivuJls3gcAFWnLoxfbwW8bI=" #define DEFAULT_ID "123456" #define TOPIC "esp8266led" unsigned long lastWiFiCheckTick = 0; bool ledState = 0; onenet_config config; #endif

全部工程代码，博哥放在个人QQ群里或者代码下载地址。

玩转OneNET物联网平台之MQTT服务③ —— 远程控制LED（设备自注册）_玩转OneNet教程_03