1. 首页
  2. 文章中心
  3. 其他

ESP8266订阅MQTT主题

65 阅读 0 评论
我是靠谱客的博主 包容导师，最近开发中收集的这篇文章主要介绍ESP8266订阅MQTT主题，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

在上一节课程里，我们学习了如何使用ESP8266发布MQTT消息，在这节课里，我们将学习如何使用ESP8266来订阅MQTT消息。我们将使用ESP8266实现以下订阅MQTT消息的操作：

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

我们将针对以上列表中的每一项内容提供一个示例程序。这些示例程序均配有视频讲解以帮助您更好的了解我们是如何实现每一项MQTT操作的。您可以点击本文首部的视频链接，打开讲解视频。

订阅单个主题

下面展示一些 内联代码片。

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

#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("");

}

订阅多个主题
/**********************************************************************

项目名称/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("");

}

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

#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("");

}

订阅多个主题
/**********************************************************************

项目名称/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("");

}

使用单级通配符订阅主题

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

#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("");

}

使用多级通配符订阅主题
/**********************************************************************

项目名称/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("");

}

最后

以上就是包容导师为你收集整理的ESP8266订阅MQTT主题的全部内容，希望文章能够帮你解决ESP8266订阅MQTT主题所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。

本图文内容来源于网友提供，作为学习参考使用，或来自网络收集整理，版权属于原作者所有。
点赞(43)

相关文章

心跳包：告诉别人，我还活着
心跳包：告诉别人，我还活着
Rtthread学习笔记（二十）RT-Thread使用Esp8266，连接远端服务器IP端口发送数据Rtthread学习笔记（二十）RT-Thread使用Esp8266，连接远端服务器IP端口发送数据
Rtthread学习笔记（二十）RT-Thread使用Esp8266，连接远端服务器IP端口发送数据Rtthread学习笔记（二十）RT-Thread使用Esp8266，连接远端服务器IP端口发送数据
java 心跳包 报文格式_tcp/心跳包
java 心跳包 报文格式_tcp/心跳包
心跳报文 - Linux C++网络编程（二十八）
心跳报文 - Linux C++网络编程（二十八）
ESP8266订阅MQTT主题
ESP8266订阅MQTT主题
ESP8266与阿里云传数据
ESP8266与阿里云传数据
MQTT.fx连接阿里云平台测试1、阿里云平台的操作流程2、MQTT.fx连接测试
MQTT.fx连接阿里云平台测试1、阿里云平台的操作流程2、MQTT.fx连接测试
Mqttfx 链接onenet
Mqttfx 链接onenet

评论列表共有 0 条评论

立即
投稿
返回
顶部