阿里云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       "-----------"
    
18. 
    
19. 
    
20. //设备的三元组信息
    
21. #define PRODUCT_KEY "-----------"
    
22. #define DEVICE_NAME "---------"
    
23. #define DEVICE_SECRET "-----------"
    
24. 
    
25. #define REGION_ID         "cn-shanghai"
    
26. 
    
27. //不需要改
    
28. #define MQTT_SERVER       PRODUCT_KEY ".iot-as-mqtt." REGION_ID ".aliyuncs diancom"
    
29. #define MQTT_PORT         1883
    
30. 
    
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"
    
35. 
    
36. 
    
37. 
    
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"
    
41. 
    
42. 
    
43. ////a1JKlnw6EP0/postion1/user/update
    
44. unsigned long lastMs = 0;
    
45. 
    
46. 
    
47. 
    
48. float soil_data = 0;
    
49. 
    
50. 
    
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. }
    
63. 
    
64. //mqtt连接
    
65. void mqttCheckConnect()
    
66. {
    
67.   while (!client.connected())
    
68.   {
    
69.     client.connect(CLIENT_ID, MQTT_USRNAME, MQTT_PASSWD);
    
70.   }
    
71. 
    
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. }
    
77. 
    
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();
    
87. 
    
88. 
    
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);
    
94. 
    
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);
    
99. 
    
100. 
     
101.   ///以下///上报给另一个设备///////////
     
102.   
     
103. 
     
104. }
     
105. 
     
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);
     
113. 
     
114.   if (strstr(topic, ALINK_TOPIC_PROP_SET))
     
115.   {
     
116.     StaticJsonBuffer<100> jsonBuffer;
     
117. 
     
118. 
     
119.     JsonObject &root = jsonBuffer.parseObject(payload);
     
120.     if (!root.success())
     
121.     {
     
122.       Serial.println("parseObject() failed");
     
123.       return;
     
124.     }
     
125.   }
     
126. }
     
127. 
     
128. 
     
129. 
     
130. void setup()
     
131. {
     
132.   Serial.begin(115200);
     
133.   wifiInit();
     
134.   dht.begin();
     
135. }
     
136. 
     
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. }
     
149. 
     
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. }
     

复制代码