智能家居----温湿度灯控
前两次都是写的单个产品的用例。是方便对阿里云套件的简单认识及使用,熟悉了单个产品的使用后,我就有点不满足了。{:5_135:}所以我尝试加上两个产品,并且会相互关联。于是我就想到用温湿度传感器和LED灯,想要实现的功能就是当温度或湿度达到某一个值时,开起LED灯,适用环境就类似种植大棚蔬菜一样(这个比喻好像不太恰当,,大家明白就好啦{:5_132:})需要材料:阿里云入门套件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灯。#include <WiFi.h>
#include <PubSubClient.h>
#include <ArduinoJson.h>
#include "DFRobot_Aliyun.h"
#include "DFRobot_DHT11.h"
#define DHT11_PIND2
#define SOCKET_PINledD3
/*配置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"];//判断Identifier是否存在,不存在返回NULL
if( ledtval != NULL )
{
// Serial.println("------------");
ledStatus = root["params"];
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;
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();
}
页:
[1]