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

news2025/1/11 18:32:38

往期

《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 then
    print(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
end


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

wifi_connect_event = function(T)
  print("Connection to AP(" .. T.SSID .. ") established!")
  print("Waiting for IP address...")
  if disconnect_ct ~= nil then
    disconnect_ct = nil
  end
end

wifi_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

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()

各位读者需要自己将 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 then
    print(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 then
    print("init.lua deleted or renamed")
  else
    print("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 then
    disconnect_ct = nil
  end
end

wifi_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 then
    print(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 then
    print("init.lua deleted or renamed")
  else
    print("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 then
    disconnect_ct = nil
  end
end

wifi_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.coloradmin.cn/o/1661383.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

XTuner笔记

XTuner笔记

为什么要微调&#xff1a; 1. 模型不具备一些私人定制的知识 2。模型回答问题的套路你不满意。 对应衍生出来两种概念 增量预训练微调&#xff1a; 使用场景&#xff1a;让基座模型学习到一些新知识&#xff0c;如某个垂类领域的常识训练数据&#xff1a;文章、书籍、代码等…
阅读更多...
关于JAVA-JSP电子政务网实现参考论文（论文 + 源码）

关于JAVA-JSP电子政务网实现参考论文（论文 + 源码）

【免费】关于JAVA-JSP电子政务网.zip资源-CSDN文库https://download.csdn.net/download/JW_559/89292355关于JAVA-JSP电子政务网 摘 要 当前阶段&#xff0c;伴随着社会信息技术的快速发展&#xff0c;使得电子政务能够成为我国政府职能部门进行办公管理的一个重要内容&#x…
阅读更多...
AnaTraf局域网流量分析：告别网络故障困扰

AnaTraf局域网流量分析：告别网络故障困扰

网络故障是困扰网络管理员的一大难题&#xff0c;它会导致网络性能下降、服务中断&#xff0c;甚至造成数据泄露等严重后果。传统的网络故障排查方法往往效率低下&#xff0c;耗时费力&#xff0c;难以快速定位问题根源。 AnaTraf网络流量分析仪的出现&#xff0c;为网络管理员…
阅读更多...
Java入门基础学习笔记13——数据类型

Java入门基础学习笔记13——数据类型

数据类型的分类&#xff1a; 基本数据类型 引用数据类型 基本数据类型&#xff1a;4大类8种类型&#xff1a; 定义整形用int&#xff0c;再大的数用long。 package cn.ensource.variable;public class VariableDemo2 {public static void main(String[] args) {//目标&#x…
阅读更多...
[NISACTF 2022]popchains

[NISACTF 2022]popchains

第一步&#xff1a;看到 include($value); 作为链尾&#xff0c;则要触发 append($value) -->>__invoke()&#xff0c;看到$function()。 __invoke()&#xff1a;对象以函数形式被调用时触发 第二步&#xff1a;$function() &#xff0c;则要触发 __get($key)&#xff0…
阅读更多...
LeetCode算法题：8.字符串转换整数 (atoi)

LeetCode算法题：8.字符串转换整数 (atoi)

请你来实现一个 myAtoi(string s) 函数&#xff0c;使其能将字符串转换成一个 32 位有符号整数&#xff08;类似 C/C 中的 atoi 函数&#xff09;。 函数 myAtoi(string s) 的算法如下&#xff1a; 读入字符串并丢弃无用的前导空格检查下一个字符&#xff08;假设还未到字符末…
阅读更多...
pydev debugger: process **** is connecting

pydev debugger: process **** is connecting

目录 解决方案一解决方案二 1、调试时出现pydev debugger: process **** is connecting 解决方案一 File->settings->build,execution,deployment->python debugger 下面的attach to subprocess automatically while debugging取消前面的勾选&#xff08;默认状态为勾…
阅读更多...
走进C++：C到C++的过渡

走进C++：C到C++的过渡

目录 什么是C呢&#xff1f; C的发展史 多了一些吃前来很香的“语法糖”。 语法糖一&#xff1a;命名空间 命名空间有个强大的功能 如何使用 语法糖二&#xff1a;缺省参数 语法糖三&#xff1a;函数重载 语法糖四&#xff1a;引用 引用传参 引用返回 引用和…
阅读更多...
记一次DNS故障导致用户无法充值的问题（下）

记一次DNS故障导致用户无法充值的问题（下）

上一篇说到DNS故障导致无法充值&#xff0c;后来我们通过拨测发现业务域名的解析目标地址被解析到了【127.0.0.1】IP。 1、联系阿里云厂商&#xff0c;通过沟通&#xff0c;阿里云反馈我们的域名被XX省通管单位封禁了&#xff0c;导致解析到了不正确的地址。 2、为了解决用户问…
阅读更多...
文章分享：《肿瘤DNA甲基化标志物检测及临床应用专家共识（2024版）》

文章分享：《肿瘤DNA甲基化标志物检测及临床应用专家共识（2024版）》

本文摘自于《肿瘤DNA甲基化标志物检测及临床应用专家共识&#xff08;2024版&#xff09;》 目录 1. DNA甲基化标志物概述 2 DNA甲基化标志物的临床检测 2.1 临床样本前处理注意事项 2.2 DNA甲基化标志物检测技术方法 2.2.1 DNA提取与纯化 2.2.2 DNA转化 2.2.3 DNA 甲基…
阅读更多...
MDK/keil高阶使用手册

MDK/keil高阶使用手册

1.开启watch和内存窗口的值实时更新 2.调试模式可以查看局部变量的值 只不过要让任意被观察变量退出<cannot evaluate>状态，都需要先在该变量被赋值的地方先打个断点，此后该变量的值就能实时更新了。 3.可以在watch窗口直接输入你要查看的变量的名称 4.可以在watch窗…
阅读更多...
解决mybatis的配置文件没代码提示的问题

解决mybatis的配置文件没代码提示的问题

1.将org.apache.ibatis.builder.xml包里的两个dtd文件复制出来&#xff0c;jar包里复制 2.复制dtd的url地址&#xff1a; http://mybatis.org/dtd/mybatis-3-mapper.dtd 一样的做法&#xff01; 3.关闭两个配置文件&#xff0c;重新打开&#xff0c;就可以有代码提示了&…
阅读更多...
子查询之二(不相关子查询与相关子查询)

子查询之二(不相关子查询与相关子查询)

1. 相关子查询 如果子查询的执行依赖于外部查询&#xff0c;通常情况下都是因为子查询中的表用到了外部的表&#xff0c;并进行的条件关联&#xff0c;因此每一次执行一次外部查询&#xff0c;子查询都会重新计算一次&#xff0c;这样的子查询称为关联子查询. 相关子查询按照…
阅读更多...
工作中遇见的问题总结

工作中遇见的问题总结

1. 当我执行下面代码的时候&#xff0c;下边的的代码还是会执行 if(name"aaa"){console.log("111");}
阅读更多...
合并两个有序链表（C语言）———链表经典算法题

合并两个有序链表（C语言）———链表经典算法题

题目描述​​​​​​21. 合并两个有序链表 - 力扣&#xff08;LeetCode&#xff09;&#xff1a; 答案展示: 迭代&#xff1a; /*** Definition for singly-linked list.* struct ListNode {* int val;* struct ListNode *next;* };*/ struct ListNode* mergeTwoLis…
阅读更多...
Go PDF文件操作

Go PDF文件操作

目录 介绍 安装 gofpdf API 代码示例 结果展示 介绍 gofpdf 是一个在 Go 语言中用于生成 PDF 文档的库。 安装 gofpdf 首先&#xff0c;你需要安装 gofpdf 库。你可以使用 go get 命令来安装它&#xff1a; go get github.com/jung-kurt/gofpdf API 功能 函数名参数解释示…
阅读更多...
高校教务选课管理系统开发方案

高校教务选课管理系统开发方案

一、项目背景与目标 &#xff08;一&#xff09;项目背景 随着高校教育规模的扩大&#xff0c;教务管理变得越来越复杂&#xff0c;传统的手工管理方式已经无法满足现代高校的需求。因此&#xff0c;开发一套高效、便捷的高校教务选课管理系统显得尤为重要。该系统将涵盖学生…
阅读更多...
C++对象的赋值

C++对象的赋值

同类的对象之间可以互相赋值&#xff0c;即一个对象的值可以赋值给另一个对象。对象之间的赋值通过“”进行。默认就是把一个对象所有非static数据成员的值依次赋值给另一个对象。 对象赋值的一般形式为&#xff1a; 对象名1 对象名2; 注意:对象名1和对象名2必须是属于同一个…
阅读更多...
苹果电脑内存清理神器CleanMyMac2024中文版下载

苹果电脑内存清理神器CleanMyMac2024中文版下载

很多朋友在使用mac电脑一段时间后&#xff0c;可能都会发现&#xff0c;自己的电脑不知道什么原因开始有些卡顿。其实这主要因为内存被占用过多&#xff0c;及时地清理不必要的内存占用&#xff0c;可以为mac减负&#xff0c;也能让电脑的运行变得更加流畅。那么问题来了&#…
阅读更多...
如何用 OceanBase做业务开发——【DBA从入门到实践】第六期

如何用 OceanBase做业务开发——【DBA从入门到实践】第六期

当应用一款新的数据库时&#xff0c;除了基础的安装部署步骤&#xff0c;掌握其应用开发方法才是实现数据库价值的关键。为此&#xff0c;我们特别安排了5月15日&#xff08;周三&#xff09;的《DBA 从入门到实践》第六期课程——本次课程将带大家了解OceanBase数据库的开发流…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023