ESP8266对接巴法云平台实现小爱同学控制开关灯

原理：esp8266连接巴法云平台mqtt服务并订阅主题，通过小爱语音发出指令，相当于mqtt的消息推送，从而进行控制esp8266 。

1. 巴法云平台创建MQTT设备云主题

在控制台新建mqtt设备云主题，字母+数字自定义组合即可。
现在支持的设备有：灯泡、插座、风扇、传感器设备。设备类型由创建的主题名称后三位决定：
当主题名字后三位是001时为插座设备。
当主题名字后三位是002时为灯泡设备。
当主题名字后三位是003时为风扇设备。
当主题名字后三位是004时为传感器设备。
当主题名字后三位是005时为空调设备。

在这里插入图片描述

2. ESP8266 模块代码编写与烧录

详细教程请看太极创客官网：零基础入门学用 Arduino 教程 – 基础知识篇
在官方代码的基础上加入了自动配网，当wifi环境改变后，可以使用手机连接esp8266热点进行网络配置。

/*
* 智能语言控制控制，支持同时天猫、小爱、小度、google Assistent控制
* 也同时支持web控制、小程序控制、app控制，定时控制等
* QQ群：566565915
* 项目示例：通过发送on或off控制开关
* 官网：bemfa.com
*/#include <ESP8266WiFi.h>               //默认，加载WIFI头文件
#include <DNSServer.h>
#include <ESP8266WebServer.h>
#include <WiFiManager.h>
#include <Ticker.h> 
//#include <PubSubClient.h>
#include "PubSubClient.h"              //默认，加载MQTT库文件         WiFiClient espClient;  //wifi客户端模式
PubSubClient client(espClient);
Ticker ticker;  //定时器对象//********************需要修改的部分*******************//
#define ID_MQTT  "888888888888888888888888"     //用户私钥，控制台获取
const char*  topic = "light002";        //主题名字，与巴法云控制台的主题一致
const int B_led = D1;       //引脚值，此引脚用于连接继电器的信号端
//**************************************************//const char* mqtt_server = "bemfa.com"; //默认，MQTT服务器
const int mqtt_server_port = 9501;      //默认，MQTT服务器端口
int count;    // Ticker计数用的变量//灯光函数及引脚定义
void turnOnLed();
void turnOffLed();//计数
void tickerCount(){count++;
}// 连接MQTT服务器
void reconnect() {// Loop until we're reconnectedwhile (!client.connected()) {Serial.print("Attempting MQTT connection...");// Attempt to connectif (client.connect(ID_MQTT)) {Serial.println("connected");Serial.print("subscribe:");Serial.println(topic);//订阅主题，如果需要订阅多个主题，可发送多条订阅指令client.subscribe(topic2);client.subscribe(topic3);client.subscribe(topic);} else {Serial.print("failed, rc=");Serial.print(client.state());Serial.println(" try again in 5 seconds");// Wait 5 seconds before retryingdelay(5000);}}
}// 收到信息后的回调函数
void receiveCallback(char* topic, byte* payload, unsigned int length) {Serial.print("Topic:");Serial.println(topic);String msg = "";for (int i = 0; i < length; i++) {msg += (char)payload[i];}Serial.print("Msg:");Serial.println(msg);if (msg == "on") {//如果接收字符on，亮灯turnOnLed();//开灯函数} else if (msg == "off") {//如果接收字符off，关灯turnOffLed();//关灯函数}msg = "";  
}//开灯
void turnOnLed() {Serial.println("turn on light");digitalWrite(B_led, HIGH);
}//关灯
void turnOffLed() {Serial.println("turn off light");digitalWrite(B_led, LOW);
}// 发布信息
void pubMQTTmsg(){   // 建立发布主题//巴法云个性设置，推送消息时：主题名后加/set推送消息，表示向所有订阅这个主题的设备们推送消息，//假如推送者自己也订阅了这个主题，消息不会被推送给它自己，以防止自己推送的消息被自己接收。String topicString = "light002/set" ;char publishTopic[topicString.length() + 1];  //转换成字符数组strcpy(publishTopic, topicString.c_str());// 建立发布信息,当前D1引脚状态String messageString;if(digitalRead(B_led)){messageString = "on"; } else {messageString = "off"; }       char publishMsg[messageString.length() + 1];   //转换成字符数组strcpy(publishMsg, messageString.c_str());// 实现ESP8266向主题发布信息,并在串口监视器显示出来if(client.publish(publishTopic, publishMsg)){Serial.println("Publish Topic:");Serial.println(publishTopic);Serial.println("Publish message:");Serial.println(publishMsg);    } else {Serial.println("Message Publish Failed."); }
}//程序入口
void setup() {pinMode(B_led, OUTPUT); //设置引脚为输出模式digitalWrite(B_led, LOW);//默认引脚上电低电平Serial.begin(9600);     //设置波特率9600//********************自动配置网络************************  // 建立WiFiManager对象WiFiManager wifiManager;  // 自动连接WiFi。以下语句的参数是连接ESP8266时的WiFi名称wifiManager.autoConnect("AutoConnectAP");  // 如果您希望该WiFi添加密码，可以使用以下语句：// wifiManager.autoConnect("AutoConnectAP", "12345678"); // WiFi连接成功后将通过串口监视器输出连接成功信息 Serial.println(""); Serial.print("ESP8266 Connected to ");Serial.println(WiFi.SSID());              // WiFi名称Serial.print("IP address:\t");Serial.println(WiFi.localIP());           // IP//*******************************************************  client.setServer(mqtt_server, mqtt_server_port);//设置mqtt服务器client.setCallback(receiveCallback); //mqtt消息处理  ticker.attach(1, tickerCount); // Ticker定时对象}//循环执行 
void loop() {if (!client.connected()) {reconnect();}else{client.loop();    // 保持心跳if (count >= 10){ // 每隔10秒钟发布一次信息pubMQTTmsg();count = 0;}} 
}