一、前言
最近在网上看到了某家智能插座的结构，大概是下面图片的样子，感觉也不是很复杂，于是自己也想做一个。 由于不会画PCB，只能找模块草草地设计一个，原理图如下： OK，可以开始在某宝上选择对应的模块了。
二、准备环境
（一）、硬件环境： 1. WIFI继电器模块（含wifi模块） 2. AC转DC模块（220V转5V） 3. 普通插座
（二） 软件环境： 1. arduino IDE 2. 必要的库： (1) arduino json库：https://www.ardu-badge.com/ArduinoJson/6.10.1 (2) arduino mqtt库：https://github.com/knolleary/pubsubclient
三、实施步骤
第一步： 把插座拆开，准确来说下面这个是插头转换器 如果选的这种，拆开可能是最难的一步了，虽然背部有螺丝孔，楼主拿到的不是十字，也不是一字，孔径很长，最后用的工具切开插座盖板，比较丑就不上图了。。
第二步： 接线
按照上面的原理图接好线后，样子大概如下： 这是体育老师教的焊接
第三步： 烧录代码
代码比较简单，先连接wifi、mqtt服务器，订阅指定的消息后轮循判断wifi，服务器连接是否断开并重连（封装在库里），按照json格式解析接收到消息，向GPIO0 发送对应的高/低电平信号控制插座通/断电，具体代码如下：
#include
#include
#include "EspMQTTClient.h"
#define Pin 0
/*******************STA模式**********************/
//设置STA网络参数，静态IP（按照自己的网段填写）
IPAddress staticIP(192, 168, 43, 199); //本地静态IP
IPAddress gateway(192, 168, 43, 1); //本地网关
IPAddress subnet(255, 255, 255, 0); //本地子网掩码
//设置STA连接热点
const char *ssid = "meizu"; //填写自己的WiFi名
const char *password = "ljd1234567"; //填写自己的WiFi密码
/*****************MQTT服务器*******************/
const char *MQTTBroker = "j8home.cn"; //可以更换为其他开源的MQTT服务器
const int brokerPort = 1883;
const char *MQTTUsername = "admin"; //不限制，可以是任意用户名
const char *MQTTPassword = "admin"; //不限制，可以是任意密码
const char *ClientName = "TestClient"; //不限制，可以是任意客户端名
const char *subTopic = "v1/devices/me/relay1";
WiFiClient Client;
bool first_set = false;
EspMQTTClient client(
ssid, //wifi ssid
password, //wifi passwd
MQTTBroker, // MQTT Broker server ip
MQTTUsername, // Can be omitted if not needed
MQTTPassword, // Can be omitted if not needed
ClientName, // Client name that uniquely identify your device
brokerPort // The MQTT port, default to 1883.
);
int status = WL_IDLE_STATUS; //保存wifi状态
char recv_data[1024]; //存入服务器下发的数据
void connect_wifi(); //wifi初始化
void analy_recv_data(char *msg, int len); //解析服务器数据
void setup() {
Serial.begin(115200); //波特率为9600
pinMode(Pin, OUTPUT); //初始化控制引脚
connect_wifi(); // 连接WiFi
first_set = true;
client.enableDebuggingMessages(); // Enable debugging messages sent to serial output
}
void loop() {
status = WiFi.status(); //获取wifi状态
if ( status != WL_CONNECTED) {
connect_wifi();
}
client.loop();
}
/****************************
MQTT订阅函数
****************************/
void onConnectionEstablished()
{
//订阅消息
client.subscribe(subTopic, [](const String & payload) {
char cArr[payload.length() + 1];
payload.toCharArray(cArr, payload.length() + 1);
analy_recv_data(cArr);
});
//发布消息
client.executeDelayed(5 * 1000, []() {
client.publish("mytopic/test", "This is a message sent 5 seconds later");
});
}
/****************************
WIFI软串口通信初始化函数
****************************/
void connect_wifi()
{
WiFi.begin(ssid, password);
if(!first_set)
WiFi.config(staticIP, gateway, subnet);
Serial.print("Is connecting routing,please wait");
while (WiFi.status() != WL_CONNECTED) //等待连接路由
{
delay(500);
Serial.print(". ");
}
Serial.println("");
Serial.println("WiFi connected!");
Serial.print("IP address: ");
Serial.println(WiFi.localIP());
}
/*****************************
分析tcp数据
****************************/
void analy_recv_data(char *msg) {
StaticJsonDocument<200> doc;
DeserializationError error = deserializeJson(doc, msg);
// 判断是否解析成功
if (error) {
Serial.print(F("deserializeJson() failed: "));
Serial.println(error.c_str());
return;
}
//开始获得每个对象
char id = doc["id"];
char status = doc["status"];
char data[2];
data[0] = id;
data[1] = status;
for (int data_i = 0; data_i < 2; data_i++) {
Serial.write(data[data_i]); //向串口发送读取的每个字节
}
if (id == 1) {
if (status == 1) {
digitalWrite(Pin, HIGH);//开
delay(200);
} else if (status == 0) {
digitalWrite(Pin, LOW);//开
delay(200);
}
}
}
下一篇：https://blog.csdn.net/qq_34472145/article/details/94572774