参考文档：https://yq.aliyun.com/articles/740235?spm=a2c4e.11155472.0.0.241b1a23fnRgEJ

第一版

  1. #include <ESP8266WiFi.h>
  2. /* 依赖 PubSubClient 2.4.0 */
  3. #include <PubSubClient.h>
  4. /* 依赖 ArduinoJson 5.13.4 */
  5. #include <ArduinoJson.h>
  7. #define SENSOR_PIN    13
  9. /* 连接您的WIFI SSID和密码 */
  10. #define WIFI_SSID         "3espace"
  11. #define WIFI_PASSWD       "kekoukele1100"
  13. /* 设备的三元组信息*/
  14. #define PRODUCT_KEY       "a1Cz4QmyJrC"
  15. #define DEVICE_NAME       "esp8266-led1"
  16. #define DEVICE_SECRET     "XhLZRM9adPmPts1QATVdsPmC29bUOh0M"
  17. #define REGION_ID         "cn-shanghai"
  19. /* 线上环境域名和端口号，不需要改 */
  20. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs.com"
  21. #define MQTT_PORT         1883
  22. #define MQTT_USRNAME      DEVICE_NAME "&" PRODUCT_KEY
  24. #define CLIENT_ID         "esp8266|securemode=3,timestamp=1234567890,signmethod=hmacsha1|"
  26. #define MQTT_PASSWD       "参考上面password教程，算法工具生成"
  28. #define ALINK_BODY_FORMAT         "{\"id\":\"123\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"
  29. #define ALINK_TOPIC_PROP_POST     "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"
  31. unsigned long lastMs = 0;
  32. WiFiClient espClient;
  33. PubSubClient  client(espClient);
  36. void callback(char *topic, byte *payload, unsigned int length)
  37. {
  38.     Serial.print("Message arrived [");
  39.     Serial.print(topic);
  40.     Serial.print("] ");
  41.     payload[length] = '\0';
  42.     Serial.println((char *)payload);
  44. }
  47. void wifiInit()
  48. {
  49.     WiFi.mode(WIFI_STA);
  50.     WiFi.begin(WIFI_SSID, WIFI_PASSWD);
  51.     while (WiFi.status() != WL_CONNECTED)
  52.     {
  53.         delay(1000);
  54.         Serial.println("WiFi not Connect");
  55.     }
  57.     Serial.println("Connected to AP");
  58.     Serial.println("IP address: ");
  59.     Serial.println(WiFi.localIP()); 
  60.     Serial.print("espClient [");
  61.     client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */
  62.     client.setCallback(callback);
  63. }
  66. void mqttCheckConnect()
  67. {
  68.     while (!client.connected())
  69.     {
  70.         Serial.println("Connecting to MQTT Server ...");
  71.         if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))
  73.         {
  75.             Serial.println("MQTT Connected!");
  77.         }
  78.         else
  79.         {
  80.             Serial.print("MQTT Connect err:");
  81.             Serial.println(client.state());
  82.             delay(5000);
  83.         }
  84.     }
  85. }
  88. void mqttIntervalPost()
  89. {
  90.     char param[32];
  91.     char jsonBuf[128];
  93.     sprintf(param, "{\"idle\":%d}", digitalRead(13));
  94.     sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  95.     Serial.println(jsonBuf);
  96.     boolean d = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);
  97.     Serial.print("publish:0 失败;1成功");
  98.     Serial.println(d);
  99. }
  102. void setup() 
  103. {
  105.     pinMode(SENSOR_PIN,  INPUT);
  106.     /* initialize serial for debugging */
  107.     Serial.begin(115200);
  108.     Serial.println("Demo Start");
  110.     wifiInit();
  111. }
  114. // the loop function runs over and over again forever
  115. void loop()
  116. {
  117.     if (millis() - lastMs >= 5000)
  118.     {
  119.         lastMs = millis();
  120.         mqttCheckConnect(); 
  122.         /* 上报 */
  123.         mqttIntervalPost();
  124.     }
  126.     client.loop();
  127.     if (digitalRead(SENSOR_PIN) == HIGH){
  128.     Serial.println("Motion detected!");
  129.     delay(2000);
  130.       }
  131.     else {
  132.     Serial.println("Motion absent!");
  133.     delay(2000);
  134.   }
  136. }

第二版完整代码：

  1. #include <ESP8266WiFi.h>
  2. /* 依赖 PubSubClient 2.4.0 */
  3. #include <PubSubClient.h>
  4. /* 依赖 ArduinoJson 5.13.4 */
  5. #include <ArduinoJson.h>
  7. #define SENSOR_PIN    13
  9. /* 连接您的WIFI SSID和密码 */
  10. #define WIFI_SSID         "3espace"
  11. #define WIFI_PASSWD       "kekoukele1100"
  13. /* 设备的三元组信息*/
  14. #define PRODUCT_KEY       "a1Cz4QmyJrC"
  15. #define DEVICE_NAME       "esp8266-led1"
  16. #define DEVICE_SECRET     "XhLZRM9adPmPts1QATVdsPmC29bUOh0M"
  17. #define REGION_ID         "cn-shanghai"
  19. /* 线上环境域名和端口号，不需要改 */
  20. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs.com"
  21. #define MQTT_PORT         1883
  22. #define MQTT_USRNAME      DEVICE_NAME "&" PRODUCT_KEY
  24. #define CLIENT_ID         "esp8266|securemode=3,signmethod=hmacsha1,timestamp=1539421321846|"
  26. #define MQTT_PASSWD       "5547bf3ae082851a958e65635ddba86327b4c2d6"
  28. #define ALINK_BODY_FORMAT         "{\"id\":\"123\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"
  29. #define ALINK_TOPIC_PROP_POST     "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"
  31. int led13Status=0;
  33. unsigned long lastMs = 0;
  34. WiFiClient espClient;
  35. PubSubClient  client(espClient);
  38. void callback(char *topic, byte *payload, unsigned int length)
  39. {
  40.     Serial.print("Message arrived [");
  41.     Serial.print(topic);
  42.     Serial.println("] ");
  43.     payload[length] = '\0';
  44.     Serial.println((char *)payload);
  45.     led13Status = 1-led13Status;
  46.     Serial.print("led13Status");
  47.     Serial.println(led13Status);
  48.     digitalWrite(13,led13Status);
  49.     delay(200);
  50. }
  53. void wifiInit()
  54. {
  55.     WiFi.mode(WIFI_STA);
  56.     WiFi.begin(WIFI_SSID, WIFI_PASSWD);
  57.     while (WiFi.status() != WL_CONNECTED)
  58.     {
  59.         delay(1000);
  60.         Serial.println("WiFi not Connect");
  61.     }
  63.     Serial.println("Connected to AP");
  64.     Serial.println("IP address: ");
  65.     Serial.println(WiFi.localIP()); 
  66.     Serial.print("espClient [");
  67.     client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */
  68.     client.setCallback(callback);
  69. }
  72. void mqttCheckConnect()
  73. {
  74.     while (!client.connected())
  75.     {
  76.         Serial.println("Connecting to MQTT Server ...");
  77.         if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))
  79.         {
  81.             Serial.println("MQTT Connected!");
  83.         }
  84.         else
  85.         {
  86.             Serial.print("MQTT Connect err:");
  87.             Serial.println(client.state());
  88.             delay(5000);
  89.         }
  90.     }
  91. }
  94. void mqttIntervalPost()
  95. {
  96.     char param[32];
  97.     char jsonBuf[128];
  99.     sprintf(param, "{\"LEDSwitch\":%d}", digitalRead(13));
  100.     sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  101.     Serial.println(jsonBuf);
  102.     boolean d = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);
  103.     Serial.print("publish:0 失败;1成功");
  104.     Serial.println(d);
  105. }
  108. void setup() 
  109. {
  110.     led13Status = digitalRead(13);
  111.     pinMode(SENSOR_PIN,  OUTPUT);
  112.     /* initialize serial for debugging */
  113.     Serial.begin(115200);
  114.     Serial.println("Demo Start");
  116.     wifiInit();
  117. }
  120. // the loop function runs over and over again forever
  121. void loop()
  122. {
  124.     if (millis() - lastMs >= 5000)
  125.     {
  126.         lastMs = millis();
  127.         mqttCheckConnect(); 
  129.         /* 上报 */
  130.         mqttIntervalPost();
  131.     }
  133.     client.loop();
  134.     digitalWrite(SENSOR_PIN,led13Status);
  135.     if (digitalRead(SENSOR_PIN) == HIGH){
  136.     Serial.println("Motion detected!");
  137.     delay(2000);
  138.       }
  139.     else {
  140.     Serial.println("Motion absent!");
  141.     delay(2000);
  142.   }
  144. }

坑

1、按照文章描述，开始不知道如何生成密码，arduino中不知道有没有sha1密码生成函数，最后借助工具，按照格式生成了免密。
2、pubsubclient.h库要按照文章的要求去修改几处信息。

难点

在arduino中不知道如何处理字符串。

第三版 更改Arduino版本为5.x

  1. #include <ESP8266WiFi.h>
  2. /* 依赖 PubSubClient 2.4.0 */
  3. #include <PubSubClient.h>
  4. /* 依赖 ArduinoJson 5.13.4 */
  5. #include <ArduinoJson.h>
  7. #define SENSOR_PIN    13
  9. /* 连接您的WIFI SSID和密码 */
  10. #define WIFI_SSID         "3espace"
  11. #define WIFI_PASSWD       "kekoukele1100"
  13. /* 设备的三元组信息*/
  14. #define PRODUCT_KEY       "a1Cz4QmyJrC"
  15. #define DEVICE_NAME       "esp8266-led1"
  16. #define DEVICE_SECRET     "XhLZRM9adPmPts1QATVdsPmC29bUOh0M"
  17. #define REGION_ID         "cn-shanghai"
  19. /* 线上环境域名和端口号，不需要改 */
  20. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs.com"
  21. #define MQTT_PORT         1883
  22. #define MQTT_USRNAME      DEVICE_NAME "&" PRODUCT_KEY
  24. #define CLIENT_ID         "esp8266|securemode=3,signmethod=hmacsha1,timestamp=1539421321846|"
  26. #define MQTT_PASSWD       "5547bf3ae082851a958e65635ddba86327b4c2d6"
  28. #define ALINK_BODY_FORMAT         "{\"id\":\"123\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"
  29. #define ALINK_TOPIC_PROP_POST     "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"
  31. int led13Status=0;
  33. unsigned long lastMs = 0;
  34. WiFiClient espClient;
  35. PubSubClient  client(espClient);
  38. void callback(char *topic, byte *payload, unsigned int length)
  39. {
  40.     Serial.print("Message arrived [");
  41.     Serial.print(topic);
  42.     Serial.println("] ");
  43.     payload[length] = '\0';
  44.     Serial.println((char *)payload);
  45.      StaticJsonBuffer<400> jsonBuffer;
  46.      JsonObject &root = jsonBuffer.parseObject(payload);
  47.         if (!root.success())
  48.         {   
  49.             Serial.println("parseObject() failed");
  50.         } 
  51.         else
  52.         {
  53.             Serial.println("parseObject() success");
  55.             //redLedState0  = json解析后的"S_D0"的值
  56.             char redLedState0 = root["params"]["LEDSwitch"];
  58.             Serial.print(redLedState0);
  59.             Serial.println(" set  sucess");
  60.             Serial.println();
  62.         }
  71.     led13Status = 1-led13Status;
  72.     Serial.print("led13Status");
  73.     Serial.println(led13Status);
  74.     digitalWrite(13,led13Status);
  75.     delay(200);
  76. }
  79. void wifiInit()
  80. {
  81.     WiFi.mode(WIFI_STA);
  82.     WiFi.begin(WIFI_SSID, WIFI_PASSWD);
  83.     while (WiFi.status() != WL_CONNECTED)
  84.     {
  85.         delay(1000);
  86.         Serial.println("WiFi not Connect");
  87.     }
  89.     Serial.println("Connected to AP");
  90.     Serial.println("IP address: ");
  91.     Serial.println(WiFi.localIP()); 
  92.     Serial.print("espClient [");
  93.     client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */
  94.     client.setCallback(callback);
  95. }
  98. void mqttCheckConnect()
  99. {
  100.     while (!client.connected())
  101.     {
  102.         Serial.println("Connecting to MQTT Server ...");
  103.         if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))
  105.         {
  107.             Serial.println("MQTT Connected!");
  109.         }
  110.         else
  111.         {
  112.             Serial.print("MQTT Connect err:");
  113.             Serial.println(client.state());
  114.             delay(5000);
  115.         }
  116.     }
  117. }
  120. void mqttIntervalPost()
  121. {
  122.     char param[32];
  123.     char jsonBuf[128];
  125.     sprintf(param, "{\"LEDSwitch\":%d}", digitalRead(13));
  126.     sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  127.     Serial.println(jsonBuf);
  128.     boolean d = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);
  129.     Serial.print("publish:0 失败;1成功");
  130.     Serial.println(d);
  131. }
  134. void setup() 
  135. {
  136.     led13Status = digitalRead(13);
  137.     pinMode(SENSOR_PIN,  OUTPUT);
  138.     /* initialize serial for debugging */
  139.     Serial.begin(115200);
  140.     Serial.println("Demo Start");
  142.     wifiInit();
  143. }
  146. // the loop function runs over and over again forever
  147. void loop()
  148. {
  150.     if (millis() - lastMs >= 5000)
  151.     {
  152.         lastMs = millis();
  153.         mqttCheckConnect(); 
  155.         /* 上报 */
  156.         mqttIntervalPost();
  157.     }
  159.     client.loop();
  160.     digitalWrite(SENSOR_PIN,led13Status);
  161.     if (digitalRead(SENSOR_PIN) == HIGH){
  162.     Serial.println("Motion detected!");
  163.     delay(2000);
  164.       }
  165.     else {
  166.     Serial.println("Motion absent!");
  167.     delay(2000);
  168.   }
  170. }

为了解析buffer数据,应用了Arduino5.x版本

终极版本，换回Arduino6.x版本

  1. #include <ESP8266WiFi.h>
  2. /* 依赖 PubSubClient 2.4.0 */
  3. #include <PubSubClient.h>
  4. /* 依赖 ArduinoJson 5.13.4 */
  5. #include <ArduinoJson.h>
  7. #define SENSOR_PIN    13
  9. /* 连接您的WIFI SSID和密码 */
  10. #define WIFI_SSID         "3espace"
  11. #define WIFI_PASSWD       "kekoukele1100"
  13. /* 设备的三元组信息*/
  14. #define PRODUCT_KEY       "a1Cz4QmyJrC"
  15. #define DEVICE_NAME       "esp8266-led1"
  16. #define DEVICE_SECRET     "XhLZRM9adPmPts1QATVdsPmC29bUOh0M"
  17. #define REGION_ID         "cn-shanghai"
  19. /* 线上环境域名和端口号，不需要改 */
  20. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs.com"
  21. #define MQTT_PORT         1883
  22. #define MQTT_USRNAME      DEVICE_NAME "&" PRODUCT_KEY
  24. #define CLIENT_ID         "esp8266|securemode=3,signmethod=hmacsha1,timestamp=1539421321846|"
  26. #define MQTT_PASSWD       "5547bf3ae082851a958e65635ddba86327b4c2d6"
  28. #define ALINK_BODY_FORMAT         "{\"id\":\"123\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"
  29. #define ALINK_TOPIC_PROP_POST     "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"
  31. //初始化次态
  32. int led13Status=0;
  34. //初始化现态
  35. int last0 = 0;
  37. unsigned long lastMs = 0;
  38. WiFiClient espClient;
  39. PubSubClient  client(espClient);
  42. void callback(char *topic, byte *payload, unsigned int length)
  43. {
  44.     Serial.print("Message arrived [");
  45.     Serial.print(topic);
  46.     Serial.println("] ");
  47.     payload[length] = '\0';
  48.     Serial.println((char *)payload);
  49.      StaticJsonDocument<200> doc;
  50.      deserializeJson(doc, (char *)payload);
  51.      const char* data_method = doc["method"];
  52.      Serial.print("data_method:");
  53.      Serial.println(data_method);
  54.      int data_ledstatus = doc["params"]["LEDSwitch"];
  55.      Serial.print("data_ledstatus:");
  56.      Serial.println(data_ledstatus);
  58.     led13Status = data_ledstatus;
  59.     Serial.print("led13Status");
  60.     Serial.println(led13Status);
  61.     digitalWrite(13,led13Status);
  62.     delay(200);
  63. }
  66. void wifiInit()
  67. {
  68.     WiFi.mode(WIFI_STA);
  69.     WiFi.begin(WIFI_SSID, WIFI_PASSWD);
  70.     while (WiFi.status() != WL_CONNECTED)
  71.     {
  72.         delay(1000);
  73.         Serial.println("WiFi not Connect");
  74.     }
  76.     Serial.println("Connected to AP");
  77.     Serial.println("IP address: ");
  78.     Serial.println(WiFi.localIP()); 
  79.     Serial.print("espClient [");
  80.     client.setServer(MQTT_SERVER, MQTT_PORT);   /* 连接WiFi之后，连接MQTT服务器 */
  81.     client.setCallback(callback);
  82. }
  85. void mqttCheckConnect()
  86. {
  87.     while (!client.connected())
  88.     {
  89.         Serial.println("Connecting to MQTT Server ...");
  90.         if (client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD))
  92.         {
  94.             Serial.println("MQTT Connected!");
  96.         }
  97.         else
  98.         {
  99.             Serial.print("MQTT Connect err:");
  100.             Serial.println(client.state());
  101.             delay(5000);
  102.         }
  103.     }
  104. }
  107. void mqttIntervalPost()
  108. {
  109.     char param[32];
  110.     char jsonBuf[128];
  112.     sprintf(param, "{\"LEDSwitch\":%d}", digitalRead(13));
  113.     sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  114.     Serial.println(jsonBuf);
  115.     boolean d = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);
  116.     Serial.print("publish:0 失败;1成功");
  117.     Serial.println(d);
  118. }
  121. void setup() 
  122. {
  123.     led13Status = digitalRead(13);
  124.     pinMode(SENSOR_PIN,  OUTPUT);
  125.     /* initialize serial for debugging */
  126.     Serial.begin(115200);
  127.     Serial.println("Demo Start");
  129.     wifiInit();
  130. }
  133. // the loop function runs over and over again forever
  134. void loop()
  135. {
  137.     if (millis() - lastMs >= 5000)
  138.     {
  139.         lastMs = millis();
  140.         mqttCheckConnect(); 
  142.         /* 上报 */
  143.         mqttIntervalPost();
  144.     }
  146.     if (last0 != led13Status)
  147.       {
  148.           last0 = led13Status;
  150.           mqttIntervalPost(); 
  151.           Serial.println();
  152.       }
  154.       client.loop();
  155. }