《ESP8266通信指南》15-MQTT连接、订阅MQTT主题并打印消息（基于Lua|适合新手|非常简单）

往期

《ESP8266通信指南》14-连接WIFI（基于Lua）-CSDN博客

《ESP8266通信指南》13-Lua 简单入门（打印数据）-CSDN博客

《ESP8266通信指南》12-Lua 固件烧录-CSDN博客

《ESP8266通信指南》11-Lua开发环境配置-CSDN博客

《ESP8266通信指南》10-MQTT通信（Arduino开发）-CSDN博客

《ESP8266通信指南》9-TCP通信（Arudino开发）-CSDN博客

《ESP8266通信指南》8-连接WIFI（Arduino开发）（非常简单）-CSDN博客

《ESP8266通信指南》7-Arduino 开发8266的环境配置与示例代码烧录-CSDN博客

《ESP8266通信指南》6-创建TCP服务器（AT指令）-CSDN博客

《ESP8266通信指南》5-TCP通信透传模式(AT指令)-CSDN博客

《ESP8266通信指南》4-以Client进行TCP通信（AT指令）-CSDN博客

《ESP8266通信指南》3-常用AT指令详解-8266连WIFI-CSDN博客

《ESP8266通信指南》2-ESP8266 AT测试-CSDN博客

《ESP8266通信指南》1-ESP8266 简介-CSDN博客

1. 小节目标

实现 MQTT 的连接，订阅主题，接收来自 MQTT 的消息，并在串口打印出来。

2. 完整代码

station_cfg = {}
station_cfg.ssid = "xlu_2.4"
station_cfg.pwd  = "111222333+"
station_cfg.auto = false
station_cfg.save = false
x_id=666
mqtt_cfg = {}
mqtt_cfg.host      = "broker.emqx.io"
mqtt_cfg.port      = 1883
mqtt_cfg.clientid  = "alro_xxx".. x_id
mqtt_cfg.keepalive = 120
mqtt_cfg.username  = "AlvaRocha"
mqtt_cfg.password  = "aio_KO<safety edit>sXwbgtWCboCal"
-- 
x_topic="/topic/ctiot/".. x_id
m=nil
wifi.setmode(wifi.STATION)
wifi.sta.config(station_cfg)iot_test = mqtt.Client(mqtt_cfg.clientid, mqtt_cfg.keepalive, mqtt_cfg.username, mqtt_cfg.password)
iot_test:on("offline", function(client)print("client offline")
end)
iot_test:on("message", function(client, topic, data)if data ~= nil thenprint(data)end
end)function get_broker(mqtt_client)mqtt_client:connect(mqtt_cfg.host, mqtt_cfg.port, false,function(client)client:subscribe(x_topic.."/c", 0, function(client)print("subscribe success "..x_topic.."/c")end)m:publish(x_topic.."/m", "success", 0, 0, function(client)print("init success")end)end,function(client, reason)print('connection failed', reason)end)m=mqtt_client
endfunction startup()if file.open("init.lua") == nil thenprint("init.lua deleted or renamed")elseprint("Running")file.close("init.lua")get_broker(iot_test)end
endwifi_connect_event = function(T)print("Connection to AP(" .. T.SSID .. ") established!")print("Waiting for IP address...")if disconnect_ct ~= nil thendisconnect_ct = nilend
endwifi_got_ip_event = function(T)print("Wifi connection is ready! IP address is: " .. T.IP)print("Startup will resume momentarily, you have 3 seconds to abort.")print("Waiting...")tmr.create():alarm(3000, tmr.ALARM_SINGLE, startup)
endwifi.eventmon.register(wifi.eventmon.STA_CONNECTED, wifi_connect_event)
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, wifi_got_ip_event)
wifi.sta.connect()

各位读者需要自己将 ID 更改为自己的特殊信息，或者将整个主题更改为包含自己特征的主题，因为我们使用的是公共的 MQTT 服务器，为了避免接收到别人的消息，影响我们的测试，迫不得已这样做，在后来，我们会介绍如何自己部署一个 MQTT 服务器，到时候就不需要考虑这些主题的问题了，到时候就需要考虑设备的唯一表示 ID 主题。

3. 现象

3.1. 连接上 MQTT 服务

  1. 首先连接 WIFI
  2. 连接上 MQTT 服务器
  3. 订阅主题，并将订阅的主题打印出来

  • 这个就是 ESP8266 订阅的主题
/topic/ctiot/666/c

3.2. 接收到 MQTT 消息

我们使用之前介绍过的 MQTTX 客户端，往我们订阅的主题发送消息，我的主题是：

/topic/ctiot/666/c

使用 MQTTX 软件往上述的主题发送消息，ESP8266 就可以接收到消息了，如下

关于 MQTTX 如何使用，可参考这篇博客：《ESP8266通信指南》10-MQTT通信（Arduino开发）-CSDN博客

4. 代码详解

4.1. 初始化 Wi-Fi 连接参数

station_cfg = {}
station_cfg.ssid = "xlu_2.4"
station_cfg.pwd  = "111222333+"
station_cfg.auto = false
station_cfg.save = false

在这段代码中，我们初始化了 Wi-Fi 连接参数 station_cfg，包括 SSID、密码、自动连接和保存连接信息的设置。

  • station_cfg.ssid: Wi-Fi 的 SSID，即网络名称。
  • station_cfg.pwd: Wi-Fi 的密码。
  • station_cfg.auto: 是否自动连接 Wi-Fi。
  • station_cfg.save: 是否保存 Wi-Fi 连接信息。

4.2. 设置 MQTT 连接参数

x_id=666
mqtt_cfg = {}
mqtt_cfg.host      = "broker.emqx.io"
mqtt_cfg.port      = 1883
mqtt_cfg.clientid  = "alro_xxx".. x_id
mqtt_cfg.keepalive = 120
mqtt_cfg.username  = "AlvaRocha"
mqtt_cfg.password  = "aio_KO<safety edit>sXwbgtWCboCal"

这部分代码定义了 MQTT 连接的参数，包括代理主机、端口、客户端 ID、保持连接时间、用户名和密码。

  • x_id: 用于客户端 ID 的标识符。
  • mqtt_cfg.host: MQTT 代理的主机地址。
  • mqtt_cfg.port: MQTT 代理的端口。
  • mqtt_cfg.clientid: MQTT 客户端 ID，结合了固定的前缀和 x_id。
  • mqtt_cfg.keepalive: 客户端与服务器之间的心跳保持时间（以秒为单位）。
  • mqtt_cfg.username 和 mqtt_cfg.password: MQTT 代理的用户名和密码。

4.3. 定义 MQTT 主题

x_topic="/topic/ctiot/".. x_id

这一行代码定义了 MQTT 主题，其中包含了一个固定的前缀 "/topic/ctiot/" 和之前定义的 x_id。这个主题将用于发布和订阅消息。

4.4. 初始化 Wi-Fi 连接

m=nil
wifi.setmode(wifi.STATION)
wifi.sta.config(station_cfg)

在这里，我们将 Wi-Fi 模式设置为 STATION（即客户端模式），然后配置 Wi-Fi 参数为之前定义的 station_cfg。

初始化 MQTT 客户端

iot_test = mqtt.Client(mqtt_cfg.clientid, mqtt_cfg.keepalive, mqtt_cfg.username, mqtt_cfg.password)

这行代码创建了一个 MQTT 客户端实例，使用了之前定义的 MQTT 连接参数。

4.5. 定义 MQTT 客户端事件处理函数

iot_test:on("offline", function(client)print("client offline")
end)
iot_test:on("message", function(client, topic, data)if data ~= nil thenprint(data)end
end)

这里定义了两个事件处理函数，分别处理客户端离线和收到消息的情况。当客户端离线时，打印提示信息；当收到消息时，打印消息内容。

4.6. 定义连接到 MQTT 代理的函数

function get_broker(mqtt_client)mqtt_client:connect(mqtt_cfg.host, mqtt_cfg.port, false,function(client)client:subscribe(x_topic.."/c", 0, function(client)print("subscribe success "..x_topic.."/c")end)m:publish(x_topic.."/m", "success", 0, 0, function(client)print("init success")end)end,function(client, reason)print('connection failed', reason)end)m=mqtt_client
end

这个函数用于连接到 MQTT 代理，并订阅一个主题以及发布一条消息。连接成功后，将打印订阅成功和发布成功的信息。

4.7. 启动函数

function startup()if file.open("init.lua") == nil thenprint("init.lua deleted or renamed")elseprint("Running")file.close("init.lua")get_broker(iot_test)end
end

这个函数用于启动 MQTT 客户端。首先检查是否存在 init.lua 文件，如果存在，则执行 get_broker 函数。

4.8. 定义 Wi-Fi 连接事件处理函数

wifi_connect_event = function(T)print("Connection to AP(" .. T.SSID .. ") established!")print("Waiting for IP address...")if disconnect_ct ~= nil thendisconnect_ct = nilend
endwifi_got_ip_event = function(T)print("Wifi connection is ready! IP address is: " .. T.IP)print("Startup will resume momentarily, you have 3 seconds to abort.")print("Waiting...")tmr.create():alarm(3000, tmr.ALARM_SINGLE, startup)
end

这里定义了两个 Wi-Fi 连接事件处理函数，分别处理连接到 AP 和获取 IP 地址的情况。当连接到 AP 时，打印连接成功的提示信息；当获取到 IP 地址时，打印 IP 地址，并在 3 秒后执行 startup 函数。

4.9. 注册 Wi-Fi 事件回调函数并连接 Wi-Fi

wifi.eventmon.register(wifi.eventmon.STA_CONNECTED, wifi_connect_event)
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, wifi_got_ip_event)
wifi.sta.connect()

最后，注册了 Wi-Fi 事件回调函数，并启动 Wi-Fi 连接。

4.10. 带有注释的完整代码

带有中文注释的代码在烧录的时候有时候会烧录不进去，原因是中文编码导致的问题，建议如下：

  1. 不烧录带有中文的代码
  2. 将注释更改为简单易懂的英文

在这里贴出中文注释代码的原因是为了方便各位同学学习和阅读代码

-- 初始化 Wi-Fi 连接参数
station_cfg = {}
station_cfg.ssid = "xlu_2.4"  -- Wi-Fi SSID
station_cfg.pwd  = "111222333+"  -- Wi-Fi 密码
station_cfg.auto = false  -- 不自动连接
station_cfg.save = false  -- 不保存连接信息-- 设置 MQTT 连接参数
x_id = 666
mqtt_cfg = {}
mqtt_cfg.host      = "broker.emqx.io"  -- MQTT 代理主机
mqtt_cfg.port      = 1883  -- MQTT 代理端口
mqtt_cfg.clientid  = "alro_xxx" .. x_id  -- MQTT 客户端 ID
mqtt_cfg.keepalive = 120  -- 保持连接时间
mqtt_cfg.username  = "AlvaRocha"  -- MQTT 用户名
mqtt_cfg.password  = "aio_KO<safety edit>sXwbgtWCboCal"  -- MQTT 密码-- 定义 MQTT 主题
x_topic = "/topic/ctiot/" .. x_id-- 初始化 Wi-Fi 连接
m = nil
wifi.setmode(wifi.STATION)
wifi.sta.config(station_cfg)-- 初始化 MQTT 客户端
iot_test = mqtt.Client(mqtt_cfg.clientid, mqtt_cfg.keepalive, mqtt_cfg.username, mqtt_cfg.password)-- 定义 MQTT 客户端事件处理函数
iot_test:on("offline", function(client)print("client offline")
end)iot_test:on("message", function(client, topic, data)if data ~= nil thenprint(data)end
end)-- 定义连接到 MQTT 代理的函数
function get_broker(mqtt_client)mqtt_client:connect(mqtt_cfg.host, mqtt_cfg.port, false,function(client)client:subscribe(x_topic .. "/c", 0, function(client)print("subscribe success " .. x_topic .. "/c")end)-- 发布一条消息m:publish(x_topic .. "/m", "success", 0, 0, function(client)print("init success")end)end,function(client, reason)print('connection failed', reason)end)m = mqtt_client
end-- 启动函数
function startup()if file.open("init.lua") == nil thenprint("init.lua deleted or renamed")elseprint("Running")file.close("init.lua")get_broker(iot_test)end
end-- 定义 Wi-Fi 连接事件处理函数
wifi_connect_event = function(T)print("Connection to AP(" .. T.SSID .. ") established!")print("Waiting for IP address...")if disconnect_ct ~= nil thendisconnect_ct = nilend
endwifi_got_ip_event = function(T)print("Wifi connection is ready! IP address is: " .. T.IP)print("Startup will resume momentarily, you have 3 seconds to abort.")print("Waiting...")tmr.create():alarm(3000, tmr.ALARM_SINGLE, startup)
end-- 注册 Wi-Fi 事件回调函数并连接 Wi-Fi
wifi.eventmon.register(wifi.eventmon.STA_CONNECTED, wifi_connect_event)
wifi.eventmon.register(wifi.eventmon.STA_GOT_IP, wifi_got_ip_event)
wifi.sta.connect()

5. 结语

在小节中学习了如何使用 ESP8266 连接 MQTT 服务器同时订阅一个主题，在接收到 MQTT 服务器上发送来的消息的时候，将数据打印出来，在下一小节中我们将学习，如何将串口接收到的消息发送到 MQTT 服务器。

柴头物联网出品

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/324453.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

JUC下CountDownLatch详解

JUC下CountDownLatch详解

详细介绍 CountDownLatch是Java并发包java.util.concurrent中提供的一个同步工具类&#xff0c;它允许一个或多个线程等待其他线程完成操作后再继续执行。这个工具类基于一个计数器&#xff0c;计数器的初始值可以由构造函数设定。线程调用countDown()方法会将计数器减1&#x…
阅读更多...
深入理解JavaScript事件循环Event Loop：宏任务与微任务的奇幻之旅

深入理解JavaScript事件循环Event Loop：宏任务与微任务的奇幻之旅

&#x1f525; 个人主页&#xff1a;空白诗 文章目录 &#x1f389; 引言&#x1f31f; 什么是事件循环&#xff1f;&#x1f4da; 「宏任务」 vs 「微任务」「宏任务」(Macrotask)「微任务」(Microtask)实际应用中的注意事项 &#x1f500; 执行流程概览&#x1f4dd; 代码示例…
阅读更多...
如何在JavaScript/Vue中获取当前时间并格式化输出（精确到时分秒）

如何在JavaScript/Vue中获取当前时间并格式化输出（精确到时分秒）

如何在JavaScript/Vue中获取当前时间并格式化输出&#xff08;精确到时分秒&#xff09; 不只是树&#xff0c;人也是一样&#xff0c;在不确定中生活的人&#xff0c;能比较经得起生活的考验&#xff0c;会锻炼出一颗独立自主的心。在不确定中&#xff0c;就能学会把很少的养分…
阅读更多...
在uniapp中如何安装axios并解决跨域问题

在uniapp中如何安装axios并解决跨域问题

目录 1、安装axios 2、导入 3、使用&#xff08;发请求&#xff09; 2.解决跨域问题 1.为什么要解决跨域问题&#xff1f; 2.前端如何解决跨域问题&#xff1f; 1、安装axios npm install axios 2、导入 在main.js中导入使用 import axios from axios; // 创建一个名…
阅读更多...
智慧互联，统信UOS V20桌面专业版（1070）解锁办公新模式丨年度更新

智慧互联，统信UOS V20桌面专业版（1070）解锁办公新模式丨年度更新

从小屏到大屏 突破&#xff0c;就在方寸之间 从人机到智脑 融合&#xff0c;旨在新质生产力 统信UOS一直致力于将先进科技与用户场景相结合&#xff0c;不断提升用户的工作效率和生产力。在最新发布的统信UOS V20桌面专业版&#xff08;1070&#xff09;版本中&#xff0c;我们…
阅读更多...
Rust 解决循环引用

Rust 解决循环引用

导航 循环引用一、现象二、解决 循环引用 循环引用出现的一个场景就是你指向我&#xff0c;我指向你&#xff0c;导致程序崩溃 解决方式可以通过弱指针&#xff0c;而Rust中的弱指针就是Weak 在Rc中&#xff0c;可以实现&#xff0c;对一个变量&#xff0c;持有多个不可变引…
阅读更多...
【一支射频电缆的诞生】GORE 戈尔

【一支射频电缆的诞生】GORE 戈尔

工具连接&#xff1a; https://microwave-cablebuilder.gore.com/ 控制参数&#xff1a; 连接器&#xff1a; 欣赏
阅读更多...
Android APP读写外置SD卡无权限 java.io.IOException: Permission denied

Android APP读写外置SD卡无权限 java.io.IOException: Permission denied

在物联网应用里&#xff0c;app需要对挂载SD卡读写文件&#xff0c;从 Android 4.4&#xff08;KitKat&#xff09;版本开始&#xff0c;Google 引入了一项名为 "Storage Access Framework" 的新功能&#xff0c;该功能限制了应用对外部存储的直接读写权限,要不然就是…
阅读更多...
【挑战30天首通《谷粒商城》】-【第一天】03、简介-分布式基础概念

【挑战30天首通《谷粒商城》】-【第一天】03、简介-分布式基础概念

文章目录 课程介绍 ( 本章了解即可&#xff0c;可以略过)1、微服务简而言之: 2、集群&分布式&节点2.1、定义2.2、示例 3、远程调用4、负载均衡常见的负裁均衡算法: 5、服务注册/发现&注册中心6、配置中心7、服务熔断&服务降级7.1、服务熔断7.2、服务降级 8、AP…
阅读更多...
Appium测试之获取appPackage和appActivity

Appium测试之获取appPackage和appActivity

appPackage和appActivity 进行appium自动化测试非常重要的两个参数&#xff0c;我们所测试的APP不同&#xff0c;这两个参数肯定也是不一样的。那如何快速的获取这APP的这两个参数呢&#xff1f;我这里介绍两个方法。 import org.openqa.selenium.remote.DesiredCapabilities;i…
阅读更多...
从零开始学AI绘画，万字Stable Diffusion终极教程（六）

从零开始学AI绘画，万字Stable Diffusion终极教程（六）

【第6期】知识补充 欢迎来到SD的终极教程&#xff0c;这是我们的第六节课&#xff0c;也是最后一节课 这套课程分为六节课&#xff0c;会系统性的介绍sd的全部功能&#xff0c;让你打下坚实牢靠的基础 1.SD入门 2.关键词 3.Lora模型 4.图生图 5.controlnet 6.知识补充 …
阅读更多...
利用生成式AI重新构想ITSM的未来

利用生成式AI重新构想ITSM的未来

对注入 AI 的生成式 ITSM 的需求&#xff0c;在 2023 年 Gartner AI 炒作周期中&#xff0c;生成式 AI 达到预期值达到顶峰后&#xff0c;三分之二的企业已经将生成式 AI 集成到其流程中。 你问为什么这种追求&#xff1f;在预定义算法的驱动下&#xff0c;IT 服务交付和管理中…
阅读更多...
PyCharm 集成 Git

PyCharm 集成 Git

目录 1、配置 Git 忽略文件 2、定位Git 3、使用pycharm本地提交 3.1、初始化本地库 3.2、添加到暂存区 3.3、提交到本地库 3.4、切换版本 4、分支操作 4.1、创建分支 4.2、切换分支 4.3、合并分支 5、解决冲突 1、配置 Git 忽略文件 作用&#xff1a;与项目的实际…
阅读更多...
【redis】Redis五种常用数据类型和内部编码,以及对String字符串类型的总结

【redis】Redis五种常用数据类型和内部编码,以及对String字符串类型的总结

˃͈꒵˂͈꒱ write in front ꒰˃͈꒵˂͈꒱ ʕ̯•͡˔•̯᷅ʔ大家好&#xff0c;我是xiaoxie.希望你看完之后,有不足之处请多多谅解&#xff0c;让我们一起共同进步૮₍❀ᴗ͈ . ᴗ͈ აxiaoxieʕ̯•͡˔•̯᷅ʔ—CSDN博客 本文由xiaoxieʕ̯•͡˔•̯᷅ʔ 原创 CSDN 如…
阅读更多...
51单片机入门：蜂鸣器

51单片机入门：蜂鸣器

蜂鸣器介绍 蜂鸣器是一种将电信号转换为声音信号的器件&#xff0c;常用来产生设备的按键音、报警音等提示信号。 蜂鸣器的种类 1、从结构上&#xff1a;压电式蜂鸣器和电磁式蜂鸣器。 压电式蜂鸣器&#xff1a;通过压电陶瓷的压电效应原理工作的。当加有交变电压时&#xf…
阅读更多...
正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-14-主频和时钟配置

正点原子[第二期]Linux之ARM（MX6U）裸机篇学习笔记-14-主频和时钟配置

前言&#xff1a; 本文是根据哔哩哔哩网站上“正点原子[第二期]Linux之ARM&#xff08;MX6U&#xff09;裸机篇”视频的学习笔记&#xff0c;在这里会记录下正点原子 I.MX6ULL 开发板的配套视频教程所作的实验和学习笔记内容。本文大量引用了正点原子教学视频和链接中的内容。…
阅读更多...
轮式机器人简介

轮式机器人简介

迄今为止,轮子一般是移动机器人学和人造交通车辆中最流行的运动机构。它可达到很高的效率, 如图所示, 而且用比较简单的机械就可实现它的制作。 另外,在轮式机器人设计中,平衡通常不是一个研究问题。 因为在所有时间里,轮式机器人一般都被设计成在任何时间里所有轮子均与地接…
阅读更多...
idea上如何新建git分支

idea上如何新建git分支

当前项目在dev分支&#xff0c;如果想在新分支上开发代码&#xff0c;如何新建一个分支呢&#xff1f;5秒搞定~ 1、工具类选择git&#xff0c;点击New Branch 或者右下角点击git分支&#xff0c;再点击New Branch 2、在弹出的Create New Branch弹窗中&#xff0c;输入你的新分支…
阅读更多...
VMware 不能拍摄快照

VMware 不能拍摄快照

问题&#xff1a; 拍摄快照后&#xff0c;会出现这个弹窗&#xff0c;然后虚拟机就直接自动退出了&#xff0c;还会弹出一个框&#xff1a; 解决方法&#xff1a; 我用的是 window11 和 VMware16.0.0 这是因为VM16与window11&#xff0c;二者之间版本不兼容问题&#xff0c;可…
阅读更多...
Python 全栈系列243 S2S flask_celery

Python 全栈系列243 S2S flask_celery

说明 按现有的几个架构部件&#xff0c;构建数据流。 S Redis Stream。这个可以作为缓冲队列和简单任务队列&#xff0c;速度非常快&#xff0c;至少是万条/秒的速度。 Q RabbitMQ。这个作为任务队列&#xff0c;消息也主要是元数据。读速比较慢&#xff0c;但有一些特性&a…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023