代码拉取完成,页面将自动刷新
物联网无线通信的大作业硬件
#include <ESP8266WiFi.h>
#include <PubSubClient.h>
#include <SimpleDHT.h>
#include <Servo.h>
Servo myservo; //创建一个舵机控制对象
int pos = 0; // 该变量用与存储舵机角度位置
int pinDHT11 = 5;
int pinDELAY = 4;
int pinLED = 2;
int pinBEEP = 15;
int pinSTEERING = 16;
SimpleDHT11 dht11(pinDHT11);
// Update these with values suitable for your network.
//只需要修改wifi名称和密码
const char* ssid = "61";
const char* password = "6161612333";
const char* mqtt_server = "k0fed7ae.cn.emqx.cloud";//服务器地址
const char *mqtt_username = "WX_esp8266";
const char *mqtt_password = "123456";
WiFiClient espClient;
PubSubClient client(espClient);
long lastMsg = 0;
char msg[50];
int value = 0;
int led_status = 0;
int delay_status = 0;
void setup_wifi() {
delay(10);
// We start by connecting to a WiFi network
Serial.println();
Serial.print("Connecting to ");
Serial.println(ssid);
WiFi.begin(ssid, password);
while (WiFi.status() != WL_CONNECTED) {
delay(500);
Serial.print(".");
}
randomSeed(micros());
Serial.println("");
Serial.println("WiFi connected");
Serial.println("IP address: ");
Serial.println(WiFi.localIP());
}
void callback(char* topic, byte* payload, unsigned int length) {
Serial.print("Message arrived [");
Serial.print(topic);
Serial.print("] ");
Serial.print((char)payload[0]);
for (int i = 0; i < length; i++) {
Serial.print((char)payload[i]);
}
Serial.println();
// Switch on the LED if an 1 was received as first character
if ((char)payload[0] == '1') {
digitalWrite(pinLED, LOW);
}
if ((char)payload[0] == '2'){
digitalWrite(pinLED, HIGH);
}
if ((char)payload[0] == '3') {
digitalWrite(pinDELAY, HIGH);
}
if ((char)payload[0] == '4'){
digitalWrite(pinDELAY, LOW);
}
}
void reconnect() {
// Loop until we're reconnected
while (!client.connected()) {
Serial.print("Attempting MQTT connection...");
// Create a random client ID
String clientId = "ESP8266Client-";
clientId += String(random(0xffff), HEX);
// Attempt to connect
if (client.connect(clientId.c_str(), mqtt_username, mqtt_password)) {
Serial.println("connected");
// Once connected, publish an announcement...
client.publish("outTopic", "hello world");
// ... and resubscribe
client.subscribe("inTopic");
} else {
Serial.print("failed, rc=");
Serial.print(client.state());
Serial.println(" try again in 5 seconds");
// Wait 5 seconds before retrying
delay(5000);
}
}
}
void beepStart (){
digitalWrite(pinBEEP, LOW);
}
void beepStop (){
digitalWrite(pinBEEP, HIGH);
}
void shunshizhen(){
myservo.write(0); // 指定舵机转向的角度
delay(15); // 等待15ms让舵机到达指定位置
};
void nishizhen(){
myservo.write(180); // 指定舵机转向的角度
delay(15); // 等待15ms让舵机到达指定位置
};
void setup() {
pinMode(pinLED, OUTPUT); // Initialize the BUILTIN_LED pin as an output
pinMode(pinDELAY, OUTPUT);
pinMode(pinBEEP, OUTPUT);
myservo.attach(16); // 该舵机由arduino第16脚控制
Serial.begin(115200);
setup_wifi();
client.setServer(mqtt_server, 12589);//服务器端口号
client.setCallback(callback);
reconnect();
while(!client.subscribe("wx_android",0))
{Serial.println("订阅失败;尝试重新订阅!");
client.subscribe("wx_android",0);
delay(300);
}
Serial.println("订阅成功~~~");
shunshizhen();
}
void loop() {
// 默认关闭蜂鸣器
beepStop();
//delay(1000);
if (!client.connected()) {
reconnect();
}
client.loop();
long now = millis();
if (now - lastMsg > 2000) {
lastMsg = now;
Serial.begin(115200);
while(!client.subscribe("wx_android",0))
{Serial.println("订阅失败;尝试重新订阅!");
client.subscribe("wx_android",0);
delay(300);
}
Serial.println("订阅成功~~~");
byte temperature = 0;
byte humidity = 0;
int err = SimpleDHTErrSuccess;
if ((err = dht11.read(&temperature, &humidity, NULL)) != SimpleDHTErrSuccess) {
Serial.print("Read DHT11 failed, err="); Serial.println(err);delay(1000);
return;
}
Serial.print((int)temperature);
Serial.print(" *C, ");
Serial.print((int)humidity);
Serial.println(" H");
if(temperature > 30){
nishizhen();
beepStart();
delay(1000);
beepStop();
}else{
shunshizhen();
delay(1000);
}
if(digitalRead(pinLED) == HIGH){
led_status = 0;
}else{
led_status = 1;
}
if(digitalRead(pinDELAY) == HIGH){
delay_status = 1;
}else{
delay_status = 0;
}
Serial.print("LED, ");
Serial.println((int)led_status);
Serial.print("DELAY,");
Serial.println((int)delay_status);
snprintf (msg, 50, "%ld", (int)temperature);
Serial.print("Publish message: ");
Serial.println(msg);
client.publish("wx_tem_sensor", msg); //发布信息
snprintf (msg, 50, "%ld", (int)humidity);
Serial.print("Publish message: ");
Serial.println(msg);
client.publish("wx_hum_sensor", msg); //发布信息
snprintf (msg, 50, "%ld", (int)led_status);
Serial.print("Publish message: ");
Serial.println(msg);
client.publish("wx_led_sensor", msg); //发布信息
snprintf (msg, 50, "%ld", (int)delay_status);
Serial.print("Publish message: ");
Serial.println(msg);
client.publish("wx_delay_sensor", msg); //发布信息
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。
登录 后才可以发表评论