3421| 0
|
[官方案例教程] 智能家居----温湿度灯控 |
前两次都是写的单个产品的用例。是方便对阿里云套件的简单认识及使用,熟悉了单个产品的使用后,我就有点不满足了。所以我尝试加上两个产品,并且会相互关联。于是我就想到用温湿度传感器和LED灯,想要实现的功能就是当温度或湿度达到某一个值时,开起LED灯,适用环境就类似种植大棚蔬菜一样(这个比喻好像不太恰当,,大家明白就好啦) 需要材料:阿里云入门套件 x1 智能手机 x1 接下来就开始咯。 1.创建产品和设备 因为阿里云与实物进行相互联系的是设备三元组,当我们挂载多个产品的时候,难道是增加多个设备吗?这样不就乱套了,而且按理这样做,多个产品挂在在ESP32上是不能同时工作的。设备是挂载在产品之下的,一个设备所属与一个产品,我们程序当中只需要一个设备三元组,所以,我们只需一个设备,同样就只需一个产品。那怎样实现同时挂在温度传感器和led呢,我们可以为产品添加多个功能。 首先向之前的步骤一样,创建产品,选填为:温湿度灯控。然后进行功能定义,添加功能,因为温湿度是两个变量,LED灯是一个。所以这里添加了三个功能。 温度监控,选填标识符为TEM,数据类型为整型,范围在-40--50; 湿度监控,选填标识符为HUM,数据类型也为整型,范围在0--100; LED开关,选填标识符为LEDSwitch,数据类型为布尔型,0--表示关灯,1--表示开灯。 接下来就是添加设备,为温湿度产品创建一个设备,选填为:ESP32-2019-5 现在产品和设备都创建成功后,就可以编辑移动设备了,不懂的可参照前两篇,而且也可以选用钉钉机器人,当温湿度大于或小于某一个值时,通过钉钉机器人通知。 2.程序的编写 多个产品的功能挂载在同一个ESP32设备上,程序就不仅仅是简单修改WiFi及WiFi密码,设备三元组,产品标识符和Post,Set,这些数据了。 增加引脚定义,将温湿度传感器接入D2口,LED灯接入D3口。 将产品标识符填写完整。 WiFi连接函数和回调函数是不用改动的。然后要增加对挂载的产品进行判断 然后增加这部分程序 增加对接入的产品输入输出模式,温度传感器是输入模式,LED灯是输出模式 最后加上在LOOP加上你想要的功能,这里我是当温度大于31时,开启LED灯。 [mw_shl_code=applescript,true]#include <WiFi.h> #include <PubSubClient.h> #include <ArduinoJson.h> #include "DFRobot_Aliyun.h" #include "DFRobot_DHT11.h" #define DHT11_PIN D2 #define SOCKET_PINled D3 /*配置WIFI名和密码*/ const char * WIFI_SSID = "Honor 8"; const char * WIFI_PASSWORD = "11223344"; /*配置设备证书信息*/ String ProductKey = "a1L5N6eNyK1"; String ClientId = "12345"; String DeviceName = "ESP32-2019-5"; String DeviceSecret = "xAJrHPeOBJzdLcdWv1sdR9uHqqycVWpr"; /*配置域名和端口号*/ String ALIYUN_SERVER = "iot-as-mqtt.cn-shanghai.aliyuncs.com"; uint16_t PORT = 1883; /*需要操作的产品标识符(温度和湿度两个标识符)*/ String TempIdentifier = "TEM"; String HumiIdentifier = "HUM"; String ledIdentifier = "LEDSwitch"; /*需要上报和订阅的两个TOPIC*/ const char * subTopic = "/sys/a1L5N6eNyK1/${deviceName}/thing/service/property/set";//****set const char * pubTopic = "/sys/a1L5N6eNyK1/${deviceName}/thing/event/property/post";//******post DFRobot_Aliyun myAliyun; WiFiClient espClient; PubSubClient client(espClient); DFRobot_DHT11 DHT; static void openSocketled(){ digitalWrite(SOCKET_PINled, HIGH);//led控制 } static void closeSocketled(){ digitalWrite(SOCKET_PINled, LOW); } void connectWiFi(){ Serial.print("Connecting to "); Serial.println(WIFI_SSID); WiFi.begin(WIFI_SSID,WIFI_PASSWORD); while(WiFi.status() != WL_CONNECTED){ delay(500); Serial.print("."); } Serial.println(); Serial.println("WiFi connected"); Serial.print("IP Adderss: "); Serial.println(WiFi.localIP()); } void callback(char * topic, byte * payload, unsigned int len){ Serial.print("Recevice ["); Serial.print(topic); Serial.print("] "); for (int i = 0; i < len; i++){ Serial.print((char)payload); } Serial.println(); StaticJsonBuffer<300> jsonBuffer; JsonObject& root = jsonBuffer.parseObject((const char *)payload); if(!root.success()){ Serial.println("parseObject() failed"); return; } uint8_t SocketStatus1,ledStatus ;//定义局部变量 const char* ledtval = root["params"][ledIdentifier];//判断Identifier是否存在,不存在返回NULL if( ledtval != NULL ) { // Serial.println("------------"); ledStatus = root["params"][ledIdentifier]; Serial.print("ledStatus="); Serial.print(ledStatus); if(ledStatus == 1){ /*打开灯*/ openSocketled(); }else{ /*关掉灯*/ closeSocketled(); } } String tempMsegled = "{\"id\":"+ClientId+",\"params\":{\""+ledIdentifier+"\":"+(String)ledStatus+"},\"method\":\"thing.event.property.post\"}"; char ledsendMseg[tempMsegled.length()]; strcpy(ledsendMseg,tempMsegled.c_str()); client.publish(pubTopic,ledsendMseg); } void ConnectAliyun(){ while(!client.connected()){ Serial.print("Attempting MQTT connection..."); /*根据自动计算的用户名和密码连接到Alinyun的设备,不需要更改*/ if(client.connect(myAliyun.client_id,myAliyun.username,myAliyun.password)){ Serial.println("connected"); client.subscribe(subTopic); }else{ Serial.print("failed, rc="); Serial.print(client.state()); Serial.println(" try again in 5 seconds"); delay(5000); } } } void setup(){ Serial.begin(115200); pinMode(SOCKET_PINled,OUTPUT); pinMode(DHT11_PIN,INPUT); closeSocketled(); /*连接WIFI*/ connectWiFi(); /*初始化Alinyun的配置,可自动计算用户名和密码*/ myAliyun.init(ALIYUN_SERVER,ProductKey,ClientId,DeviceName,DeviceSecret); client.setServer(myAliyun.mqtt_server,PORT); /*设置回调函数,当收到订阅信息时会执行回调函数*/ client.setCallback(callback); /*连接到Aliyun*/ ConnectAliyun(); } uint8_t tempTime = 0; void loop(){ if(!client.connected()){ ConnectAliyun(); } /*一分钟上报两次温湿度信息*/ if(tempTime > 60){ tempTime = 0; DHT.read(DHT11_PIN); Serial.print("DHT.temperature="); Serial.println(DHT.temperature); Serial.print("DHT.humidity="); Serial.println(DHT.humidity); client.publish(pubTopic,("{\"id\":"+ClientId+",\"params\":{\""+TempIdentifier+"\":"+DHT.temperature+",\""+HumiIdentifier+"\":"+DHT.humidity+"},\"method\":\"thing.event.property.post\"}").c_str()); }else{ tempTime++; delay(500); } if(DHT.temperature > 31){ openSocketled(); }else closeSocketled(); client.loop(); }[/mw_shl_code] |
© 2013-2024 Comsenz Inc. Powered by Discuz! X3.4 Licensed