在这节课里,我们一起来学习如何使用ESP8266来实现MQTT遗嘱应用。我们将向您介绍两段示例程序。以下是这两段实例的简要介绍:
示例1:MQTT遗嘱基本应用
示例2:利用MQTT遗嘱实现设备在线状态发布
在开始本节课以前请确保您的电脑已经成功安装了MQTTfx软件。另外我们还将使用PubSubClient库。您可以通过以下链接获取此库。
官网地址:https://pubsubclient.knolleary.net/
GitHub:https://github.com/knolleary/pubsubclient/
百度网盘下载: https://pan.baidu.com/s/12MHGbdfiOdwOGip5RMSSEQ 提取码: sizy
当您将PubSubClient库安装后,我们就可以使用该库进行开发了。
示例1:MQTT遗嘱基本应用
本示例程序将实现ESP8266的最基本MQTT遗嘱应用。程序使用connect函数对遗嘱消息实现设置
本程序旨在演示如何设置客户端遗嘱机制。客户端在连接服务器时,设置遗嘱的主题和信息。
MQTT服务器会定时检查客户端是否仍然与服务器连接。为了实现这一检查,服务器将会根据以下
内容进行检查.
-
客户端连接时会提供心跳时间间隔(Keep Alive)。
-
如果在心跳时间间隔时长内,客户端向服务器发布了消息,则
服务器会认为客户端与服务器保持连接无误。
-
如果在心跳时间间隔时长内,客户端没有向服务端发布消息,
客户端会向服务端发送pingreq信息。此信息由PubSubClient库自动发送。
-
我们可以通过setKeepAlive函数控制心跳时间间隔时长,或者可以通过PubSubClient.h
的#define MQTT_KEEPALIVE 15来设置心跳时间间隔时长。
-
在心跳时间间隔的1.5倍时长内,如果服务端没有收到客户端信息也没有pingreq。
那么服务端将会执行客户端遗嘱机制。
默认情况下,设备的心跳时间间隔时长为15秒。这是在PubSubClient.h中通过以下语句定义的:
#define MQTT_KEEPALIVE 15
若要修改keep-alive时间,可修改以上头文件,或者使用setKeepAlive函数实现。
对于PubSubClient,遗嘱QoS允许使用0,1。
示例2:利用MQTT遗嘱实现设备在线状态发布
本实例将实现本教程2-6 MQTT遗嘱这节课中的“MQTT遗嘱使用建议”示例。通过以下程序,ESP8266客户端可以利用遗嘱机制来实时的将当前在线与否状态通过服务端进行发布。也就是说,其它客户端只要订阅ESP8266客户端的遗嘱主题就可以马上了解该客户端是否在线。
本程序旨在演示如何设置客户端遗嘱机制。客户端在连接服务器时,设置遗嘱的主题和信息。
本客户端所发布的遗嘱消息为保留消息。其它客户端可通过订阅本客户端的遗嘱主题获取本
客户端是否在线的状态信息
#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); // 遗嘱设置const char* willMsg = "CLIENT-OFFLINE"; // 遗嘱消息内容const int willQoS = 0; // 遗嘱QoSconst bool willRetain = true; // 遗嘱保留 void setup() { Serial.begin(9600);// 启动串口通讯 //设置ESP8266工作模式为无线终端模式 WiFi.mode(WIFI_STA); // 连接WiFi connectWifi(); // 设置MQTT服务器和端口号 mqttClient.setServer(mqttServer, 1883); mqttClient.setKeepAlive(10); // 设置心跳间隔时间 // 连接MQTT服务器 connectMQTTserver();} void loop() { // 如果开发板未能成功连接服务器,则尝试连接服务器 if (!mqttClient.connected()) { connectMQTTserver(); } // 处理信息以及心跳 mqttClient.loop();} // 连接MQTT服务器并订阅信息void connectMQTTserver(){ // 根据ESP8266的MAC地址生成客户端ID(避免与其它ESP8266的客户端ID重名) String clientId = "esp8266-" + WiFi.macAddress(); // 建立遗嘱主题。主题名称以Taichi-Maker-为前缀,后面添加设备的MAC地址,最后 // 以“-Will”结尾,这是为确保不同ESP8266客户端的遗嘱主题名称各不相同。 String willString = "Taichi-Maker-" + WiFi.macAddress() + "-Will"; char willTopic[willString.来源:暮誠雪
声明:本站部分文章及图片转载于互联网,内容版权归原作者所有,如本站任何资料有侵权请您尽早请联系jinwei@zod.com.cn进行处理,非常感谢!