欧美极品高清xxxxhd,国产日产欧美最新,无码AV国产东京热AV无码,国产精品人与动性XXX,国产传媒亚洲综合一区二区,四库影院永久国产精品,毛片免费免费高清视频,福利所导航夜趣136

標題: 阿里云MQTT數據云流轉,實現多個終端控制某一個設備 [打印本頁]
作者: leanco    時間: 2022-11-14 00:03
標題: 阿里云MQTT數據云流轉,實現多個終端控制某一個設備
一、在阿里云注冊登錄，并在控制臺建好項目
二、在arduinoIDE上傳代碼至arduino系列單片機或者ESP8266或ESP32
三、可以在本地按鍵操作硬件，也可以在阿里云端進行設備模擬查看最終效果。
附上代碼，僅供參考
  1. #include <ESP8266WiFi.h>
  2. #include <PubSubClient.h>//這個沒有回調函數
  3. #include <ArduinoJson.h>
  4. #include "DHT.h"
  5. WiFiClient espClient;
  6. PubSubClient  client(espClient);
  7. PubSubClient mqttClient(espClient);
  8. #define sensor_Pin   0
  9. #define DHTPIN 2
  10. #define DHTTYPE DHT11
  11. DHT dht(DHTPIN, DHTTYPE);
  12. float h;
  13. float t;
  14. long s;
  15. // 連接WIFI和密碼
  16. #define WIFI_SSID         "-------------"
  17. #define WIFI_PASSWD       "-----------"


  20. //設備的三元組信息
  21. #define PRODUCT_KEY "-----------"
  22. #define DEVICE_NAME "---------"
  23. #define DEVICE_SECRET "-----------"

  25. #define REGION_ID         "cn-shanghai"

  27. //不需要改
  28. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs diancom"
  29. #define MQTT_PORT         1883

  31. /////
  32. #define MQTT_USRNAME      DEVICE_NAME "&" PRODUCT_KEY
  33. #define CLIENT_ID     "h8v70q9rDqp.center|securemode=2,signmethod=hmacsha256,timestamp=1652631576537|"//這里使用技小新可以生成，注意密碼和密鑰一定要對否則連不上MQTT    "FESA234FBDS24|securemode=3,timestamp=789,signmethod=hmacsha1|"
  34. #define MQTT_PASSWD       "180866dbe114bb5cedd3a3dc1f27dccdadeaf0dbc51bd3873a26c88bef98cf08"



  38. #define ALINK_TOPIC_PROP_SET "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/service/property/set"
  39. #define ALINK_BODY_FORMAT         "{\"id\":\"ESP8266\",\"version\":\"1.0\",\"method\":\"thing.event.property.post\",\"params\":%s}"
  40. #define ALINK_TOPIC_PROP_POST     "/sys/" PRODUCT_KEY "/" DEVICE_NAME "/thing/event/property/post"


  43. ////a1JKlnw6EP0/postion1/user/update
  44. unsigned long lastMs = 0;



  48. float soil_data = 0;


  51. //連接wifi
  52. void wifiInit()
  53. {
  54.   WiFi.mode(WIFI_STA);
  55.   WiFi.begin(WIFI_SSID, WIFI_PASSWD);
  56.   while (WiFi.status() != WL_CONNECTED)
  57.   {
  58.     delay(1000);
  59.     Serial.println("WiFi not Connect");
  60.   }
  61.   client.setServer(MQTT_SERVER, MQTT_PORT);   //連接MQTT服務器
  62. }

  64. //mqtt連接
  65. void mqttCheckConnect()
  66. {
  67.   while (!client.connected())
  68.   {
  69.     client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD);
  70.   }

  72.   Serial.println("MQTT connect succeed!");
  73.   // client.subscribe(ALINK_TOPIC_PROP_POSTRSP);
  74.   mqttClient.subscribe(ALINK_TOPIC_PROP_SET);
  75.   Serial.println("subscribe done");
  76. }

  78. void mqttIntervalPost()
  79. {
  80.   soil_data = analogRead(sensor_Pin);   //模擬數據讀取（A0腳輸入的數據）385-1024
  81.   soil_data -= 385;         //0-639
  82.   soil_data /= 6.39;        //0.00-100.00，變為百分比
  83.   soil_data = 100 - soil_data;         //修改為百分比越大濕度越大
  84.   char param[32];
  85.   char jsonBuf[128];
  86.   read_data();


  89.   //這里\"**"\要選擇對應的標識符，否則數據上報不了。
  90.   sprintf(param, "{\"wendu\":%f}", t);
  91.   sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  92.   Serial.println(jsonBuf);
  93.   boolean e = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);

  95.   sprintf(param, "{\"CurrentHumidity\":%f}", h);
  96.   sprintf(jsonBuf, ALINK_BODY_FORMAT, param);
  97.   Serial.println(jsonBuf);
  98.   boolean f = client.publish(ALINK_TOPIC_PROP_POST, jsonBuf);


  101.   ///以下///上報給另一個設備///////////
  102.   

  104. }

  106. void callback(char *topic, byte *payload, unsigned int length)//mqtt回調函數
  107. {
  108.   Serial.print("Message arrived [");
  109.   Serial.print(topic);
  110.   Serial.print("] ");
  111.   payload[length] = '\0';
  112.   Serial.println((char *)payload);

  114.   if (strstr(topic, ALINK_TOPIC_PROP_SET))
  115.   {
  116.     StaticJsonBuffer<100> jsonBuffer;


  119.     JsonObject &root = jsonBuffer.parseObject(payload);
  120.     if (!root.success())
  121.     {
  122.       Serial.println("parseObject() failed");
  123.       return;
  124.     }
  125.   }
  126. }



  130. void setup()
  131. {
  132.   Serial.begin(115200);
  133.   wifiInit();
  134.   dht.begin();
  135. }

  137. void read_data()
  138. {
  139.   float read_h = dht.readHumidity();//濕度
  140.   float read_t = dht.readTemperature();//溫度
  141.   h = read_h;
  142.   t = read_t;
  143.   Serial.print("濕度：");
  144.   Serial.print(h);
  145.   Serial.println("%");
  146.   Serial.print("溫度：");
  147.   Serial.println(t);
  148. }

  150. void loop()
  151. {
  152.   s = millis();
  153.   delay(500);
  154.   read_data();
  155.   Serial.println(millis() - s);
  156.   if (millis() - lastMs >= 5000)
  157.   {
  158.     lastMs = millis();
  159.     mqttCheckConnect();
  160.     mqttIntervalPost();
  161.   }
  162.   client.loop();
  163.   delay(2000);
  164. }
復制代碼






歡迎光臨 (http://www.raoushi.com/bbs/) Powered by Discuz! X3.1