1-8 ESP8266订阅MQTT主题

在上一节课程里，我们学习了如何使用ESP8266发布MQTT消息，在这节课里，我们将学习如何使用ESP8266来订阅MQTT消息。

本节课的学习将需要您掌握ESP8266的基本操作，假如您对ESP8266的基本操作不太了解，您可以先完成《零基础入门学用物联网》系列教程的第一部分“基础知识篇”。

假如您已经完成以上教程，那么接下来您就可以继续这节课的学习了。

ESP8266的Arduino开发环境里有多个MQTT库，我们将使用最为流行的PubSubClient库来作为本教程的主要介绍对象，我们将通过一系列课程教您如何使用ESP8266通过PubSubClient库来实现MQTT物联网应用。关于PubSubClient库,以下是其基本信息：

作者名：Nick O’Leary
官网地址：https://pubsubclient.knolleary.net/
GitHub：https://github.com/knolleary/pubsubclient/
百度网盘下载： https://pan.baidu.com/s/12MHGbdfiOdwOGip5RMSSEQ 提取码: sizy

在本节课里，我们将使用ESP8266实现以下订阅MQTT消息的操作：

– 订阅单个主题
– 订阅多个主题
– 使用单级通配符订阅主题
– 使用多级通配符订阅主题

订阅单个主题

通过以下示例程序，我们将可以让ESP8266通过公用MQTT服务器 然也物联 订阅MQTT消息。

/**********************************************************************
项目名称/Project          : 零基础入门学用物联网
程序名称/Program name     : subscribe_ranye_url
团队/Team                : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)
作者/Author              : CYNO朔
日期/Date（YYYYMMDD）     : 20200708
程序目的/Purpose          : 
本程序旨在演示如何使用PubSubClient库使用ESP8266向MQTT服务器订阅信息。
-----------------------------------------------------------------------
本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。
该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：
http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/
***********************************************************************/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)
const char* ssid = "taichimaker";
const char* password = "12345678";
const char* mqttServer = "test.ranye-iot.net";
// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案
// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);     // 设置板上LED引脚为输出模式
  digitalWrite(LED_BUILTIN, HIGH);  // 启动后关闭板上LED
  Serial.begin(9600);               // 启动串口通讯
  
  //设置ESP8266工作模式为无线终端模式
  WiFi.mode(WIFI_STA);
  
  // 连接WiFi
  connectWifi();
  
  // 设置MQTT服务器和端口号
  mqttClient.setServer(mqttServer, 1883);
  // 设置MQTT订阅回调函数
  mqttClient.setCallback(receiveCallback);

  // 连接MQTT服务器
  connectMQTTserver();
}

void loop() {
  if (mqttClient.connected()) { // 如果开发板成功连接服务器
    mqttClient.loop();          // 处理信息以及心跳
  } else {                      // 如果开发板未能成功连接服务器
    connectMQTTserver();        // 则尝试连接服务器
  }
}

// 连接MQTT服务器并订阅信息
void connectMQTTserver(){
  // 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）
  String clientId = "esp8266-" + WiFi.macAddress();

  // 连接MQTT服务器
  if (mqttClient.connect(clientId.c_str())) { 
    Serial.println("MQTT Server Connected.");
    Serial.println("Server Address:");
    Serial.println(mqttServer);
    Serial.println("ClientId: ");
    Serial.println(clientId);
    subscribeTopic(); // 订阅指定主题
  } else {
    Serial.print("MQTT Server Connect Failed. Client State:");
    Serial.println(mqttClient.state());
    delay(5000);
  }   
}

// 收到信息后的回调函数
void receiveCallback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message Received [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println("");
  Serial.print("Message Length(Bytes) ");
  Serial.println(length);

  if ((char)payload[0] == '1') {     // 如果收到的信息以“1”为开始
    digitalWrite(BUILTIN_LED, LOW);  // 则点亮LED。
    Serial.println("LED ON");
  } else {                           
    digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。
    Serial.println("LED OFF");
  }
}

// 订阅指定主题
void subscribeTopic(){

  // 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。
  // 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同
  String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress();
  char subTopic[topicString.length() + 1];  
  strcpy(subTopic, topicString.c_str());
  
  // 通过串口监视器输出是否成功订阅主题以及订阅的主题名称
  if(mqttClient.subscribe(subTopic)){
    Serial.println("Subscrib Topic:");
    Serial.println(subTopic);
  } else {
    Serial.print("Subscribe Fail...");
  }  
}

// ESP8266连接wifi
void connectWifi(){

  WiFi.begin(ssid, password);
 
  //等待WiFi连接,成功连接后输出成功信息
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi Connected!");  
  Serial.println(""); 
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

/**********************************************************************

项目名称/Project : 零基础入门学用物联网

程序名称/Program name : subscribe_ranye_url

团队/Team : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)

作者/Author : CYNO朔

日期/Date（YYYYMMDD） : 20200708

程序目的/Purpose :

本程序旨在演示如何使用PubSubClient库使用ESP8266向MQTT服务器订阅信息。

-----------------------------------------------------------------------

本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。

该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：

http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/

***********************************************************************/

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)

const char* ssid = "taichimaker";

const char* password = "12345678";

const char* mqttServer = "test.ranye-iot.net";

// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案

// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;

PubSubClient mqttClient(wifiClient);

void setup() {

pinMode(LED_BUILTIN, OUTPUT); // 设置板上LED引脚为输出模式

digitalWrite(LED_BUILTIN, HIGH); // 启动后关闭板上LED

Serial.begin(9600); // 启动串口通讯

//设置ESP8266工作模式为无线终端模式

WiFi.mode(WIFI_STA);

// 连接WiFi

connectWifi();

// 设置MQTT服务器和端口号

mqttClient.setServer(mqttServer, 1883);

// 设置MQTT订阅回调函数

mqttClient.setCallback(receiveCallback);

// 连接MQTT服务器

connectMQTTserver();

}

void loop() {

if (mqttClient.connected()) { // 如果开发板成功连接服务器

mqttClient.loop(); // 处理信息以及心跳

} else { // 如果开发板未能成功连接服务器

connectMQTTserver(); // 则尝试连接服务器

}

// 连接MQTT服务器并订阅信息

void connectMQTTserver(){

// 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）

String clientId = "esp8266-" + WiFi.macAddress();

// 连接MQTT服务器

if (mqttClient.connect(clientId.c_str())) {

Serial.println("MQTT Server Connected.");

Serial.println("Server Address:");

Serial.println(mqttServer);

Serial.println("ClientId: ");

Serial.println(clientId);

subscribeTopic(); // 订阅指定主题

} else {

Serial.print("MQTT Server Connect Failed. Client State:");

Serial.println(mqttClient.state());

delay(5000);

}

// 收到信息后的回调函数

void receiveCallback(char* topic, byte* payload, unsigned int length) {

Serial.print("Message Received [");

Serial.print(topic);

Serial.print("] ");

for (int i = 0; i < length; i++) {

Serial.print((char)payload[i]);

}

Serial.println("");

Serial.print("Message Length(Bytes) ");

Serial.println(length);

if ((char)payload[0] == '1') { // 如果收到的信息以“1”为开始

digitalWrite(BUILTIN_LED, LOW); // 则点亮LED。

Serial.println("LED ON");

} else {

digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。

Serial.println("LED OFF");

}

// 订阅指定主题

void subscribeTopic(){

// 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。

// 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同

String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress();

char subTopic[topicString.length() + 1];

strcpy(subTopic, topicString.c_str());

// 通过串口监视器输出是否成功订阅主题以及订阅的主题名称

if(mqttClient.subscribe(subTopic)){

Serial.println("Subscrib Topic:");

Serial.println(subTopic);

} else {

Serial.print("Subscribe Fail...");

}

// ESP8266连接wifi

void connectWifi(){

WiFi.begin(ssid, password);

//等待WiFi连接,成功连接后输出成功信息

while (WiFi.status() != WL_CONNECTED) {

delay(1000);

Serial.print(".");

}

Serial.println("");

Serial.println("WiFi Connected!");

Serial.println("");

}

订阅多个主题

通过以下示例程序，我们将可以让ESP8266通过公用MQTT服务器 然也物联 订阅多个主题。

/**********************************************************************
项目名称/Project          : 零基础入门学用物联网
程序名称/Program name     : subscribe_multitopic_ranye_url
团队/Team                : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)
作者/Author              : CYNO朔
日期/Date（YYYYMMDD）     : 20201125
程序目的/Purpose          : 
本程序旨在演示如何使用PubSubClient库使用ESP8266向MQTT服务器订阅多个主题
-----------------------------------------------------------------------
本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。
该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：
http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/
***********************************************************************/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)
const char* ssid = "taichimaker";
const char* password = "12345678";
const char* mqttServer = "test.ranye-iot.net";
// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案
// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);     // 设置板上LED引脚为输出模式
  digitalWrite(LED_BUILTIN, HIGH);  // 启动后关闭板上LED
  Serial.begin(9600);               // 启动串口通讯
  
  //设置ESP8266工作模式为无线终端模式
  WiFi.mode(WIFI_STA);
  
  // 连接WiFi
  connectWifi();
  
  // 设置MQTT服务器和端口号
  mqttClient.setServer(mqttServer, 1883);
  mqttClient.setCallback(receiveCallback);

  // 连接MQTT服务器
  connectMQTTserver();
}

void loop() {
  if (mqttClient.connected()) { // 如果开发板成功连接服务器
    mqttClient.loop();          // 处理信息以及心跳
  } else {                      // 如果开发板未能成功连接服务器
    connectMQTTserver();        // 则尝试连接服务器
  }
}

// 连接MQTT服务器并订阅信息
void connectMQTTserver(){
  // 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）
  String clientId = "esp8266-" + WiFi.macAddress();

  // 连接MQTT服务器
  if (mqttClient.connect(clientId.c_str())) { 
    Serial.println("MQTT Server Connected.");
    Serial.println("Server Address:");
    Serial.println(mqttServer);
    Serial.println("ClientId: ");
    Serial.println(clientId);
    subscribeTopic(); // 订阅指定主题
  } else {
    Serial.print("MQTT Server Connect Failed. Client State:");
    Serial.println(mqttClient.state());
    delay(5000);
  }   
}

// 收到信息后的回调函数
void receiveCallback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message Received [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println("");
  Serial.print("Message Length(Bytes) ");
  Serial.println(length);

  if ((char)payload[0] == '1') {     // 如果收到的信息以“1”为开始
    digitalWrite(BUILTIN_LED, LOW);  // 则点亮LED。
  } else {                           
    digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。
  }
}

// 订阅指定主题
void subscribeTopic(){

  // 建立订阅主题1。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。
  // 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同
  String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress();
  char subTopic[topicString.length() + 1];  
  strcpy(subTopic, topicString.c_str());
  
  // 建立订阅主题2
  String topicString2 = "Taichi-Maker-Sub2-" + WiFi.macAddress();
  char subTopic2[topicString2.length() + 1];  
  strcpy(subTopic2, topicString2.c_str());
  
  // 通过串口监视器输出是否成功订阅主题1以及订阅的主题1名称
  if(mqttClient.subscribe(subTopic)){
    Serial.println("Subscrib Topic:");
    Serial.println(subTopic);
  } else {
    Serial.print("Subscribe Fail...");
  }  

  // 通过串口监视器输出是否成功订阅主题2以及订阅的主题2名称
  if(mqttClient.subscribe(subTopic2)){
    Serial.println("Subscrib Topic:");
    Serial.println(subTopic2);
  } else {
    Serial.print("Subscribe Fail...");
  }    
}

// ESP8266连接wifi
void connectWifi(){

  WiFi.begin(ssid, password);
 
  //等待WiFi连接,成功连接后输出成功信息
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi Connected!");  
  Serial.println(""); 
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

126

127

128

129

130

131

132

133

134

135

136

137

/**********************************************************************

项目名称/Project : 零基础入门学用物联网

程序名称/Program name : subscribe_multitopic_ranye_url

团队/Team : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)

作者/Author : CYNO朔

日期/Date（YYYYMMDD） : 20201125

程序目的/Purpose :

本程序旨在演示如何使用PubSubClient库使用ESP8266向MQTT服务器订阅多个主题

-----------------------------------------------------------------------

本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。

该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：

http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/

***********************************************************************/

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)

const char* ssid = "taichimaker";

const char* password = "12345678";

const char* mqttServer = "test.ranye-iot.net";

// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案

// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;

PubSubClient mqttClient(wifiClient);

void setup() {

pinMode(LED_BUILTIN, OUTPUT); // 设置板上LED引脚为输出模式

digitalWrite(LED_BUILTIN, HIGH); // 启动后关闭板上LED

Serial.begin(9600); // 启动串口通讯

//设置ESP8266工作模式为无线终端模式

WiFi.mode(WIFI_STA);

// 连接WiFi

connectWifi();

// 设置MQTT服务器和端口号

mqttClient.setServer(mqttServer, 1883);

mqttClient.setCallback(receiveCallback);

// 连接MQTT服务器

connectMQTTserver();

}

void loop() {

if (mqttClient.connected()) { // 如果开发板成功连接服务器

mqttClient.loop(); // 处理信息以及心跳

} else { // 如果开发板未能成功连接服务器

connectMQTTserver(); // 则尝试连接服务器

}

// 连接MQTT服务器并订阅信息

void connectMQTTserver(){

// 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）

String clientId = "esp8266-" + WiFi.macAddress();

// 连接MQTT服务器

if (mqttClient.connect(clientId.c_str())) {

Serial.println("MQTT Server Connected.");

Serial.println("Server Address:");

Serial.println(mqttServer);

Serial.println("ClientId: ");

Serial.println(clientId);

subscribeTopic(); // 订阅指定主题

} else {

Serial.print("MQTT Server Connect Failed. Client State:");

Serial.println(mqttClient.state());

delay(5000);

}

// 收到信息后的回调函数

void receiveCallback(char* topic, byte* payload, unsigned int length) {

Serial.print("Message Received [");

Serial.print(topic);

Serial.print("] ");

for (int i = 0; i < length; i++) {

Serial.print((char)payload[i]);

}

Serial.println("");

Serial.print("Message Length(Bytes) ");

Serial.println(length);

if ((char)payload[0] == '1') { // 如果收到的信息以“1”为开始

digitalWrite(BUILTIN_LED, LOW); // 则点亮LED。

} else {

digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。

}

// 订阅指定主题

void subscribeTopic(){

// 建立订阅主题1。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。

// 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同

String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress();

char subTopic[topicString.length() + 1];

strcpy(subTopic, topicString.c_str());

// 建立订阅主题2

String topicString2 = "Taichi-Maker-Sub2-" + WiFi.macAddress();

char subTopic2[topicString2.length() + 1];

strcpy(subTopic2, topicString2.c_str());

// 通过串口监视器输出是否成功订阅主题1以及订阅的主题1名称

if(mqttClient.subscribe(subTopic)){

Serial.println("Subscrib Topic:");

Serial.println(subTopic);

} else {

Serial.print("Subscribe Fail...");

}

// 通过串口监视器输出是否成功订阅主题2以及订阅的主题2名称

if(mqttClient.subscribe(subTopic2)){

Serial.println("Subscrib Topic:");

Serial.println(subTopic2);

} else {

Serial.print("Subscribe Fail...");

}

// ESP8266连接wifi

void connectWifi(){

WiFi.begin(ssid, password);

//等待WiFi连接,成功连接后输出成功信息

while (WiFi.status() != WL_CONNECTED) {

delay(1000);

Serial.print(".");

}

Serial.println("");

Serial.println("WiFi Connected!");

Serial.println("");

}

使用单级通配符订阅主题

以下是使用单级通配符订阅主题的示例程序。假如您想要了解MQTT通配符的具体使用方法，请点击这里进入课程页面。

/**********************************************************************
项目名称/Project          : 零基础入门学用物联网
程序名称/Program name     : subscribe_single_level_wildcard_ranye
团队/Team                : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)
作者/Author              : CYNO朔
日期/Date（YYYYMMDD）     : 20200813
程序目的/Purpose          : 
本程序旨在演示ESP8266订阅信息时的单极通配符+应用。

-----------------------------------------------------------------------
本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。
该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：
http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/
***********************************************************************/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)
const char* ssid = "taichi-maker";
const char* password = "12345678";
const char* mqttServer = "test.ranye-iot.net";
// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案
// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);     // 设置板上LED引脚为输出模式
  digitalWrite(LED_BUILTIN, HIGH);  // 启动后关闭板上LED
  Serial.begin(9600);               // 启动串口通讯
  
  //设置ESP8266工作模式为无线终端模式
  WiFi.mode(WIFI_STA);
  
  // 连接WiFi
  connectWifi();
  
  // 设置MQTT服务器和端口号
  mqttClient.setServer(mqttServer, 1883);
  mqttClient.setCallback(receiveCallback);

  // 连接MQTT服务器
  connectMQTTserver();
}

void loop() {
  if (mqttClient.connected()) { // 如果开发板成功连接服务器
    mqttClient.loop();          // 处理信息以及心跳
  } else {                      // 如果开发板未能成功连接服务器
    connectMQTTserver();        // 则尝试连接服务器
  }
}

// 连接MQTT服务器并订阅信息
void connectMQTTserver(){
  // 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）
  String clientId = "esp8266-" + WiFi.macAddress();

  // 连接MQTT服务器
  if (mqttClient.connect(clientId.c_str())) { 
    Serial.println("MQTT Server Connected.");
    Serial.println("Server Address:");
    Serial.println(mqttServer);
    Serial.println("ClientId: ");
    Serial.println(clientId);
    subscribeTopic(); // 订阅指定主题
  } else {
    Serial.print("MQTT Server Connect Failed. Client State:");
    Serial.println(mqttClient.state());
    delay(5000);
  }   
}

// 收到信息后的回调函数
void receiveCallback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message Received [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println("");
  Serial.print("Message Length(Bytes) ");
  Serial.println(length);

  if ((char)payload[0] == '1') {     // 如果收到的信息以“1”为开始
    digitalWrite(BUILTIN_LED, LOW);  // 则点亮LED。
  } else {                           
    digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。
  }
}

// 订阅指定主题
void subscribeTopic(){

  // 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。
  // 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同
  String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress()+"/+/data";
  char subTopic[topicString.length() + 1];  
  strcpy(subTopic, topicString.c_str());
  
  // 通过串口监视器输出是否成功订阅主题以及订阅的主题名称
  if(mqttClient.subscribe(subTopic)){
    Serial.println("Subscrib Topic:");
    Serial.println(subTopic);
  } else {
    Serial.print("Subscribe Fail...");
  }  
}

// ESP8266连接wifi
void connectWifi(){

  WiFi.begin(ssid, password);
 
  //等待WiFi连接,成功连接后输出成功信息
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi Connected!");  
  Serial.println(""); 
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

125

/**********************************************************************

项目名称/Project : 零基础入门学用物联网

程序名称/Program name : subscribe_single_level_wildcard_ranye

团队/Team : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)

作者/Author : CYNO朔

日期/Date（YYYYMMDD） : 20200813

程序目的/Purpose :

本程序旨在演示ESP8266订阅信息时的单极通配符+应用。

-----------------------------------------------------------------------

本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。

该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：

http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/

***********************************************************************/

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)

const char* ssid = "taichi-maker";

const char* password = "12345678";

const char* mqttServer = "test.ranye-iot.net";

// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案

// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;

PubSubClient mqttClient(wifiClient);

void setup() {

pinMode(LED_BUILTIN, OUTPUT); // 设置板上LED引脚为输出模式

digitalWrite(LED_BUILTIN, HIGH); // 启动后关闭板上LED

Serial.begin(9600); // 启动串口通讯

//设置ESP8266工作模式为无线终端模式

WiFi.mode(WIFI_STA);

// 连接WiFi

connectWifi();

// 设置MQTT服务器和端口号

mqttClient.setServer(mqttServer, 1883);

mqttClient.setCallback(receiveCallback);

// 连接MQTT服务器

connectMQTTserver();

}

void loop() {

if (mqttClient.connected()) { // 如果开发板成功连接服务器

mqttClient.loop(); // 处理信息以及心跳

} else { // 如果开发板未能成功连接服务器

connectMQTTserver(); // 则尝试连接服务器

}

// 连接MQTT服务器并订阅信息

void connectMQTTserver(){

// 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）

String clientId = "esp8266-" + WiFi.macAddress();

// 连接MQTT服务器

if (mqttClient.connect(clientId.c_str())) {

Serial.println("MQTT Server Connected.");

Serial.println("Server Address:");

Serial.println(mqttServer);

Serial.println("ClientId: ");

Serial.println(clientId);

subscribeTopic(); // 订阅指定主题

} else {

Serial.print("MQTT Server Connect Failed. Client State:");

Serial.println(mqttClient.state());

delay(5000);

}

// 收到信息后的回调函数

void receiveCallback(char* topic, byte* payload, unsigned int length) {

Serial.print("Message Received [");

Serial.print(topic);

Serial.print("] ");

for (int i = 0; i < length; i++) {

Serial.print((char)payload[i]);

}

Serial.println("");

Serial.print("Message Length(Bytes) ");

Serial.println(length);

if ((char)payload[0] == '1') { // 如果收到的信息以“1”为开始

digitalWrite(BUILTIN_LED, LOW); // 则点亮LED。

} else {

digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。

}

// 订阅指定主题

void subscribeTopic(){

// 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。

// 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同

String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress()+"/+/data";

char subTopic[topicString.length() + 1];

strcpy(subTopic, topicString.c_str());

// 通过串口监视器输出是否成功订阅主题以及订阅的主题名称

if(mqttClient.subscribe(subTopic)){

Serial.println("Subscrib Topic:");

Serial.println(subTopic);

} else {

Serial.print("Subscribe Fail...");

}

// ESP8266连接wifi

void connectWifi(){

WiFi.begin(ssid, password);

//等待WiFi连接,成功连接后输出成功信息

while (WiFi.status() != WL_CONNECTED) {

delay(1000);

Serial.print(".");

}

Serial.println("");

Serial.println("WiFi Connected!");

Serial.println("");

}

使用多级通配符订阅主题

以下是使用多级通配符订阅主题的示例程序。假如您想要了解MQTT通配符的具体使用方法，请点击这里进入课程页面。

/**********************************************************************
项目名称/Project          : 零基础入门学用物联网
程序名称/Program name     : subscribe_multi_level_wildcard_ranye
团队/Team                : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)
作者/Author              : CYNO朔
日期/Date（YYYYMMDD）     : 20200813
程序目的/Purpose          : 
本程序旨在演示ESP8266订阅信息时的多极通配符#应用。
-----------------------------------------------------------------------
本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。
该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：
http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/
***********************************************************************/
#include <ESP8266WiFi.h>
#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)
const char* ssid = "taichi-maker";
const char* password = "12345678";
const char* mqttServer = "test.ranye-iot.net";
// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案
// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;
PubSubClient mqttClient(wifiClient);

void setup() {
  pinMode(LED_BUILTIN, OUTPUT);     // 设置板上LED引脚为输出模式
  digitalWrite(LED_BUILTIN, HIGH);  // 启动后关闭板上LED
  Serial.begin(9600);               // 启动串口通讯
  
  //设置ESP8266工作模式为无线终端模式
  WiFi.mode(WIFI_STA);
  
  // 连接WiFi
  connectWifi();
  
  // 设置MQTT服务器和端口号
  mqttClient.setServer(mqttServer, 1883);
  mqttClient.setCallback(receiveCallback);

  // 连接MQTT服务器
  connectMQTTserver();
}

void loop() {
  if (mqttClient.connected()) { // 如果开发板成功连接服务器
    mqttClient.loop();          // 处理信息以及心跳
  } else {                      // 如果开发板未能成功连接服务器
    connectMQTTserver();        // 则尝试连接服务器
  }
}

// 连接MQTT服务器并订阅信息
void connectMQTTserver(){
  // 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）
  String clientId = "esp8266-" + WiFi.macAddress();

  // 连接MQTT服务器
  if (mqttClient.connect(clientId.c_str())) { 
    Serial.println("MQTT Server Connected.");
    Serial.println("Server Address:");
    Serial.println(mqttServer);
    Serial.println("ClientId: ");
    Serial.println(clientId);
    subscribeTopic(); // 订阅指定主题
  } else {
    Serial.print("MQTT Server Connect Failed. Client State:");
    Serial.println(mqttClient.state());
    delay(5000);
  }   
}

// 收到信息后的回调函数
void receiveCallback(char* topic, byte* payload, unsigned int length) {
  Serial.print("Message Received [");
  Serial.print(topic);
  Serial.print("] ");
  for (int i = 0; i < length; i++) {
    Serial.print((char)payload[i]);
  }
  Serial.println("");
  Serial.print("Message Length(Bytes) ");
  Serial.println(length);

  if ((char)payload[0] == '1') {     // 如果收到的信息以“1”为开始
    digitalWrite(BUILTIN_LED, LOW);  // 则点亮LED。
  } else {                           
    digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。
  }
}

// 订阅指定主题
void subscribeTopic(){

  // 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。
  // 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同
  String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress()+"/sensor/#";
  char subTopic[topicString.length() + 1];  
  strcpy(subTopic, topicString.c_str());
  
  // 通过串口监视器输出是否成功订阅主题以及订阅的主题名称
  if(mqttClient.subscribe(subTopic)){
    Serial.println("Subscrib Topic:");
    Serial.println(subTopic);
  } else {
    Serial.print("Subscribe Fail...");
  }  
}

// ESP8266连接wifi
void connectWifi(){

  WiFi.begin(ssid, password);
 
  //等待WiFi连接,成功连接后输出成功信息
  while (WiFi.status() != WL_CONNECTED) {
    delay(1000);
    Serial.print(".");
  }
  Serial.println("");
  Serial.println("WiFi Connected!");  
  Serial.println(""); 
}

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121

122

123

124

/**********************************************************************

项目名称/Project : 零基础入门学用物联网

程序名称/Program name : subscribe_multi_level_wildcard_ranye

团队/Team : 太极创客团队 / Taichi-Maker (www.taichi-maker.com)

作者/Author : CYNO朔

日期/Date（YYYYMMDD） : 20200813

程序目的/Purpose :

本程序旨在演示ESP8266订阅信息时的多极通配符#应用。

-----------------------------------------------------------------------

本示例程序为太极创客团队制作的《零基础入门学用物联网》中示例程序。

该教程为对物联网开发感兴趣的朋友所设计和制作。如需了解更多该教程的信息，请参考以下网页：

http://www.taichi-maker.com/homepage/esp8266-nodemcu-iot/iot-c/esp8266-nodemcu-web-client/http-request/

***********************************************************************/

#include <ESP8266WiFi.h>

#include <PubSubClient.h>

// 设置wifi接入信息(请根据您的WiFi信息进行修改)

const char* ssid = "taichi-maker";

const char* password = "12345678";

const char* mqttServer = "test.ranye-iot.net";

// 如以上MQTT服务器无法正常连接，请前往以下页面寻找解决方案

// http://www.taichi-maker.com/public-mqtt-broker/

WiFiClient wifiClient;

PubSubClient mqttClient(wifiClient);

void setup() {

pinMode(LED_BUILTIN, OUTPUT); // 设置板上LED引脚为输出模式

digitalWrite(LED_BUILTIN, HIGH); // 启动后关闭板上LED

Serial.begin(9600); // 启动串口通讯

//设置ESP8266工作模式为无线终端模式

WiFi.mode(WIFI_STA);

// 连接WiFi

connectWifi();

// 设置MQTT服务器和端口号

mqttClient.setServer(mqttServer, 1883);

mqttClient.setCallback(receiveCallback);

// 连接MQTT服务器

connectMQTTserver();

}

void loop() {

if (mqttClient.connected()) { // 如果开发板成功连接服务器

mqttClient.loop(); // 处理信息以及心跳

} else { // 如果开发板未能成功连接服务器

connectMQTTserver(); // 则尝试连接服务器

}

// 连接MQTT服务器并订阅信息

void connectMQTTserver(){

// 根据ESP8266的MAC地址生成客户端ID（避免与其它ESP8266的客户端ID重名）

String clientId = "esp8266-" + WiFi.macAddress();

// 连接MQTT服务器

if (mqttClient.connect(clientId.c_str())) {

Serial.println("MQTT Server Connected.");

Serial.println("Server Address:");

Serial.println(mqttServer);

Serial.println("ClientId: ");

Serial.println(clientId);

subscribeTopic(); // 订阅指定主题

} else {

Serial.print("MQTT Server Connect Failed. Client State:");

Serial.println(mqttClient.state());

delay(5000);

}

// 收到信息后的回调函数

void receiveCallback(char* topic, byte* payload, unsigned int length) {

Serial.print("Message Received [");

Serial.print(topic);

Serial.print("] ");

for (int i = 0; i < length; i++) {

Serial.print((char)payload[i]);

}

Serial.println("");

Serial.print("Message Length(Bytes) ");

Serial.println(length);

if ((char)payload[0] == '1') { // 如果收到的信息以“1”为开始

digitalWrite(BUILTIN_LED, LOW); // 则点亮LED。

} else {

digitalWrite(BUILTIN_LED, HIGH); // 否则熄灭LED。

}

// 订阅指定主题

void subscribeTopic(){

// 建立订阅主题。主题名称以Taichi-Maker-Sub为前缀，后面添加设备的MAC地址。

// 这么做是为确保不同设备使用同一个MQTT服务器测试消息订阅时，所订阅的主题名称不同

String topicString = "Taichi-Maker-Sub-" + WiFi.macAddress()+"/sensor/#";

char subTopic[topicString.length() + 1];

strcpy(subTopic, topicString.c_str());

// 通过串口监视器输出是否成功订阅主题以及订阅的主题名称

if(mqttClient.subscribe(subTopic)){

Serial.println("Subscrib Topic:");

Serial.println(subTopic);

} else {

Serial.print("Subscribe Fail...");

}

// ESP8266连接wifi

void connectWifi(){

WiFi.begin(ssid, password);

//等待WiFi连接,成功连接后输出成功信息

while (WiFi.status() != WL_CONNECTED) {

delay(1000);

Serial.print(".");

}

Serial.println("");

Serial.println("WiFi Connected!");

Serial.println("");

}