#include //如果是ESP8266 用#include
#include "Ticker.h"
//李智勇編碼,采用AP方式做服務(wù)端,可以方便控制各種設(shè)備,網(wǎng)上此方面的代碼放出不多不完整,在此放出, 沒有采用網(wǎng)上流行的多個(gè)客戶端,那樣當(dāng)新的客戶端不夠用時(shí),處理邏輯太麻煩,一個(gè)客戶端發(fā)過來消息,服務(wù)端接收,發(fā)送確認(rèn)消息,等控制指令結(jié)束發(fā)送斷開指令給客戶端,當(dāng)服務(wù)端接到新的連接,主動斷開上個(gè)連接,這樣就不會阻塞網(wǎng)絡(luò)連接。
Ticker ticker_1; //控制一號繼電器,用計(jì)時(shí)器模擬多線程
Ticker ticker_2; //控制二號繼電器
#define PIN_R1 23 //輸出控制,
#define PIN_R2 22 //輸出控制,
// 初始化一個(gè)WiFi服務(wù)器,端口為****
#define SERVER_PORT ****
#define CLOSE_CONNECT "Off" //發(fā)送關(guān)閉指令給客戶端,讓客戶端主動斷開
int count_OPEN = 0;
int count_R1 = -1; //第一次進(jìn)入打開
WiFiServer server(SERVER_PORT); //端口號,范圍 0-65535
// WiFiAPPSW是AP模式下的WiFi密碼
const String WiFiAPPSW = "12345678"; //設(shè)置AP模式下模塊所發(fā)出的WIFI的密碼
const String AP_NameString = "lizhiyong_CONTROL";
void setupWiFi() {
WiFi.mode(WIFI_AP);
WiFi.softAP(AP_NameString, WiFiAPPSW);
//自定義IP地址信息
WiFi.softAPConfig(IPAddress(192, ***, ***, ***), IPAddress(192, ***, ***, 1), IPAddress(255, 255, 255, 0));
Serial.println(WiFi.softAPSSID());
Serial.print("IP address: ");
Serial.println(WiFi.softAPIP());
Serial.print("SSID: ");
Serial.println(WiFi.softAPSSID());
server.begin();
}
void setup() {
pinMode(PIN_R1, OUTPUT); *
pinMode(PIN_R2, OUTPUT); *
*
*
Serial.begin(115200);
Serial.println("Begin now!!!");
setupWiFi();
}
WiFiClient serverClient;
void loop() {
//檢測服務(wù)器端是否有活動的客戶端連接
if (server.hasClient()) {
if (serverClient) serverClient.stop();
serverClient = server.available();
// Serial.println("hasClient " + serverClient.remoteIP());
}
//檢查客戶端的數(shù)據(jù)
if (serverClient && serverClient.connected()) {
if (serverClient.available()) {
Serial.print("Connected to client remoteIP:");
Serial.println(serverClient.remoteIP());
char data[1024] = { 0 };
// ind用于追蹤data數(shù)組中已存儲的數(shù)據(jù)量
int ind = 0;
// 接收客戶端發(fā)送的所有數(shù)據(jù)
Serial.println("Connected to client !!! ");
while (serverClient.available()) {
data[ind] = serverClient.read(); //讀取client端發(fā)送的字符,含有換行符
ind++;
}
String str = String(data);
Serial.println(str + String(str.length()));
if (str.indexOf("open") >= 0) { // compareTo equals 接收有回車符等不可見字符容易出錯
Serial.println("relay2 open is recive");
ticker_2.attach(0.1, relay2, 0); //二號繼電器打開。參數(shù)1
serverClient.print("relay2 open OK! "); //在client端回復(fù)
} else if (str.indexOf("close") >= 0) {
Serial.println("relay2 close is recive");
ticker_2.attach(0.1, relay2, 1); //參數(shù)0關(guān)斷
serverClient.print("relay2 close OK! "); //在client端回復(fù)
} else if (str.indexOf("time") >= 0) { //relay1打開后延時(shí)關(guān)閉
int time = str.substring(4).toInt(); //substring(4)從第4個(gè)數(shù)開始一直都末尾
ticker_1.attach(0.1, relay1, time); //繼電器 打開,延時(shí)time 后關(guān)閉,第一次執(zhí)行沒有延時(shí),
Serial.println("relay1 close is recive " + str.substring(4));
serverClient.print("relay1 time OK! "); //在client端回復(fù)
} else if (str.indexOf("hand") >= 0) { //relay1手動開關(guān)
Serial.println("relay1 hand " + String(count_R1));
if (count_R1 == -1) {
ticker_1.attach(0.1, relay1, -1); //手動打開關(guān)閉
Serial.println("relay1 hand open " + String(count_R1));
serverClient.print("relay1 hand open OK! "); //在client端回復(fù)
count_R1 = 0;
} else {
ticker_1.attach(0.1, relay1, 0); //-1 關(guān)閉指令
Serial.println("relay1 hand close ");
serverClient.print("relay1 hand close OK! "); //在client端回復(fù)
count_R1 = -1;
}
} else {
serverClient.print("OK! Got your request. "); //在client端回復(fù)
Serial.println("OK! Got your request. ");
}
serverClient.print(CLOSE_CONNECT); //在客戶端關(guān)閉端回復(fù)
}
}
}
void relay1(int action) { //控制繼電器1,參數(shù)整數(shù)型,0表示關(guān),-1表示開,其他數(shù)值表示開的延時(shí)
Serial.println("relay1 active !!! " + String(action));
if (action == 0) {
digitalWrite(PIN_R1, !digitalRead(PIN_R1)); // turn the LED on (HIGH is the voltage level)
Serial.println("relay1 open PIN_R1 !!! ");
ticker_1.detach();
} else if (action == -1) {
digitalWrite(PIN_R1, !digitalRead(PIN_R1)); // turn the LED off by making the voltage LOW
Serial.println("relay1 close PIN_R1 !!! ");
ticker_1.detach();
} else {
if (count_OPEN == 0) { //第一次 延時(shí)開,打開繼電器
ticker_1.attach(action, relay1, action); //保證下次進(jìn)來,并且把時(shí)間延長,因?yàn)榈谝淮芜M(jìn)沒有延時(shí)
digitalWrite(PIN_R1, !digitalRead(PIN_R1));
Serial.println(String(action) + " relay1 open !!! ");
count_OPEN = 1;
} else { //第二次延時(shí)關(guān),關(guān)閉繼電器
digitalWrite(PIN_R1, !digitalRead(PIN_R1));
count_OPEN = 0;
ticker_1.detach();
Serial.println(String(action) + " relay1 close !!! ");
}
}
}
void relay2(int level) { //控制繼電器2,參數(shù)是高低電平,決定吸合
digitalWrite(PIN_R2, level); // turn the LED on (HIGH is the voltage level)
Serial.println("relay2 active !!! " + String(level));
ticker_2.detach(); //都是執(zhí)行一次,模擬多線程,用delay會阻塞服務(wù)器響應(yīng)
}
審核編輯 黃宇
-
繼電器
+關(guān)注
關(guān)注
132文章
5263瀏覽量
147622 -
TCP
+關(guān)注
關(guān)注
8文章
1324瀏覽量
78759 -
源碼
+關(guān)注
關(guān)注
8文章
626瀏覽量
28976 -
ESP32
+關(guān)注
關(guān)注
17文章
936瀏覽量
16669
發(fā)布評論請先 登錄
相關(guān)推薦
評論