阿里云IOT

1. http://download.dfrobot.top/FireBeetle/package_DFRobot_index.json

1. #include <WiFi.h>
2. #include <PubSubClient.h>
3. #include <ArduinoJson.h>
4. #include "DFRobot_Aliyun.h"
5. #define MOTION_SENSOR_PIN  D3 //人体红外传感器接入D3引脚
6. #define LED_PIN D9 //LED_PIN灯接入D9引脚
7. #define BUZZER_PIN D6 //蜂鸣器接入D6引脚
8. bool sensorSign = false;//判断人体红外传感器标记的
9. uint16_t sensorState = 0;//人体红外传感器状态变量1为有人 0为无人
10. /*配置WIFI名和密码*/
11. const char * WIFI_SSID     = "zjf";//输入自己家的wifi及密码
12. const char * WIFI_PASSWORD = "123456789.";
13. /*配置设备证书信息*/
14. String ProductKey = "a16seZxWRxD";
15. String ClientId = "12345";//这个不用管
16. String DeviceName = "flash";
17. String DeviceSecret = "5ae31a7b63ec3c3a5660c8d39f160918";
18. /*配置域名和端口号*/
19. String ALIYUN_SERVER = "iot-as-mqtt.cn-shanghai.aliyuncs.com";
20. uint16_t PORT = 1883;
21. /*需要操作的产品标识符*/
22. String Identifier = "123456";
23. /*需要上报的TOPIC*/
24. const char * pubTopic = "/sys/a16seZxWRxD/flash/thing/event/property/post";//******post
25. DFRobot_Aliyun myAliyun;
26. WiFiClient espClient;
27. PubSubClient client(espClient);
28. void connectWiFi(){
29.   Serial.print("Connecting to ");
30.   Serial.println(WIFI_SSID);
31.   WiFi.begin(WIFI_SSID,WIFI_PASSWORD);
32.   while(WiFi.status() != WL_CONNECTED){
33.     delay(500);
34.     Serial.print(".");
35.   }
36.   Serial.println();
37.   Serial.println("WiFi connected");
38.   Serial.print("IP Adderss: ");
39.   Serial.println(WiFi.localIP());
40. }
41. void callback(char * topic, byte * payload, unsigned int len){
42.   Serial.print("Recevice [");
43.   Serial.print(topic);
44.   Serial.print("] ");
45.   for (int i = 0; i < len; i++){
46.     Serial.print((char)payload[i]);
47.   }
48.   Serial.println();
49. }
50. void ConnectAliyun(){
51.   while(!client.connected()){
52.     Serial.print("Attempting MQTT connection...");
53.     /*根据自动计算的用户名和密码连接到Alinyun的设备，不需要更改*/
54.     if(client.connect(myAliyun.client_id,myAliyun.username,myAliyun.password)){
55.       Serial.println("connected");
56.     }else{
57.       Serial.print("faiLED_PIN, rc=");
58.       Serial.print(client.state());
59.       Serial.println(" try again in 5 seconds");
60.       delay(5000);
61.     }
62.   }
63. }
64. void setup(){
65.   Serial.begin(115200);
66.   pinMode(MOTION_SENSOR_PIN,INPUT);//设置人体红外传感器为输入模式
67.   pinMode(LED_PIN,OUTPUT);//设置LED灯为输出模式
68.   pinMode(BUZZER_PIN,OUTPUT);//设置蜂鸣器为输出模式
69.   /*连接WIFI*/
70.   connectWiFi();
71.   
72.   /*初始化Alinyun的配置，可自动计算用户名和密码*/
73.   myAliyun.init(ALIYUN_SERVER,ProductKey,ClientId,DeviceName,DeviceSecret);
74.   
75.   client.setServer(myAliyun.mqtt_server,PORT);
76.   
77.   /*设置回调函数，当收到订阅信息时会执行回调函数*/
78.   client.setCallback(callback);
79.   
80.   /*连接到Aliyun*/
81.   ConnectAliyun();
82. }
83. void loop(){
84.   if(!client.connected()){
85.     ConnectAliyun();
86.   }
87.   sensorState =digitalRead(MOTION_SENSOR_PIN);//把人体红外传感器接收到的值赋值给sensorState
88.   if((sensorState==1)&&(sensorSign==false)){
89.     /*上报防盗警告*/
90.     client.publish(pubTopic,("{"id":"+ClientId+","params":{""+Identifier+"":1},"method":"thing.event.property.post"}").c_str());
91.     digitalWrite(LED_PIN,HIGH);//LED_PIN灯打开
92.     digitalWrite(BUZZER_PIN,HIGH);//蜂鸣器打开
93.     delay(3000);//延长3秒
94.     sensorSign = true;//把传感器标记变为true 防止重复发送信息
95.   }
96.   else if((sensorState==0)&&(sensorSign==true)){
97.     digitalWrite(LED_PIN,LOW);//LED_PIN灯关闭
98.     digitalWrite(BUZZER_PIN,LOW);//蜂鸣器关闭
99.     sensorSign = false;//把传感器标记变为false
100.   }
101.    
102.   client.loop();
103. }