- 1【机器学习】决策树特征选择准则 信息增益、信息增益率、基尼系数的计算及其python实现_机器学习增益率计算题
- 2Git 中强行拉取，覆盖本地修改_git强制将远程覆盖到本地
- 3图像处理ASIC设计方法 笔记18 轮廓跟踪算法的硬件加速方案
- 4【深入浅出Spring原理及实战】「Web请求读取系列」如何构建一个可重复读取的Request的流机制_javaweb 请求流重复读取
- 5面向中文大模型价值观的评估与对齐研究：给AI的100瓶毒药
- 6uni.app开发小程序如何获取当前经纬度、位置信息以及如何重新发起授权定位_uniapp获取当前经纬度
- 7VHDL仿真ModelSim使用简介_modelsim vhdl
- 8mvc控制器html返回json,asp.net-mvc – 如何从MVC控制器返回Json对象到视图
- 9Meta 新推出的实时语音翻译模型 Seamless_seamless expressive
- 10华纳云：ubuntu中fdisk找不到硬盘怎么解决？
【MQTT从入门到提高系列 | 01】从0到1快速搭建MQTT测试环境
赞
踩
这是机器未来的第24篇文章
原文首发地址：https://blog.csdn.net/RobotFutures/article/details/125532208
1. mosquitto概述
Eclipse mosquitto是一个开源(EPL/EDL许可的)消息代理，它实现了MQTT协议版本5.0、3.1.1和3.1。mosquito是轻量级的，适用于所有设备，从低功耗的单板计算机到完整的服务器。
MQTT协议提供了使用发布/订阅模型执行消息传递的轻量级方法。这使得它适用于物联网消息传递，如低功耗传感器或移动设备，如手机、嵌入式计算机或微控制器。
mosquito to项目还提供了一个用于实现MQTT客户机的C库，以及非常流行的mosquito to_pub和mosquito to_sub命令行MQTT客户机。
2. 下载MQTT部署软件
下载地址：传送门
3. 快速上手mosquitto
3.1 启动mqtt broker
启动命令行工具，切换到mosquitto安装目录，执行如下命令，启动broker
mosquitto.exe -v
- 1
默认开启的端口为1883。
命令详情如下：
mosquitto [-c config file] [ -d | --daemon ] [-p port number] [-v]
- 1
-c 指定配置文件路径，默认配置路径为安装目录下的mosquitto.conf
-d 启动时进入后台运行
-p 指定端口，默认为1883
-v 开启日志输出
注意事项：如果不指定配置文件，默认仅支持127.0.0.1的本地回环网卡连接，如果要连接局域网或外网客户端，那么一定要指定配置文件mosquitto.conf:
listener 1883
allow_anonymous true # 允许匿名访问
- 1
- 2
启动命令如下：
mosquitto.exe -c mosquitto.conf -v
- 1
因电脑配置问题，这里使用自定义端口测试
#mosquitto.exe -v -p 6969
1647942133: mosquitto version 2.0.14 starting
1647942133: Using default config.
1647942133: Starting in local only mode. Connections will only be possible from clients running on this machine.
1647942133: Create a configuration file which defines a listener to allow remote access.
1647942133: For more details see https://mosquitto.org/documentation/authentication-methods/
1647942133: Opening ipv4 listen socket on port 6969.
1647942133: Opening ipv6 listen socket on port 6969.
1647942133: mosquitto version 2.0.14 running
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
3.2 订阅主题
mosquitto_sub.exe -t sensors/temperature -q 1 -p 6969
- 1
-t 指定topic，这里为传感器温度值 sensors/temperature
-q 指定qos质量，这里为1
-p 指定端口，这里为6969
命令执行后，broker的日志描述如下：
1647942590: New connection from 127.0.0.1:1746 on port 6969.
1647942590: New client connected from 127.0.0.1:1746 as auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 (p2, c1, k60).
1647942590: No will message specified.
1647942590: Sending CONNACK to auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 (0, 0)
1647942591: Received SUBSCRIBE from auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0
1647942591: sensors/temperature (QoS 1)
1647942591: auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 1 sensors/temperature
1647942591: Sending SUBACK to auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 - 连接成功后，broker分配的会话ID
CONNACK：对Connect命令的响应
SUBSCRIBE ：客户端发起的订阅请求
SUBACK ：broker对客户端auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0的SUBSCRIBE命令的反馈
3.3 发布主题
mosquitto_pub.exe -t sensors/temperature -m 32 -q 1 -p 6969
- 1
-t 指定topic，这里为传感器温度值 sensors/temperature
-q 指定qos质量，这里为1
-p 指定端口，这里为6969
-m指定消息，这里消息为32
命令执行后：
- broker的日志输出如下
1647942676: New connection from 127.0.0.1:1914 on port 6969.
1647942676: New client connected from 127.0.0.1:1914 as auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D (p2, c1, k60).
1647942676: No will message specified.
1647942676: Sending CONNACK to auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D (0, 0)
1647942676: Received PUBLISH from auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D (d0, q1, r0, m1, 'sensors/temperature', ... (2 bytes))
1647942676: Sending PUBLISH to auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 (d0, q1, r0, m1, 'sensors/temperature', ... (2 bytes))
1647942676: Sending PUBACK to auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D (m1, rc0)
1647942676: Received PUBACK from auto-651BD76A-09A1-67FD-1DF9-AF36BEADB2D0 (Mid: 1, RC:0)
1647942676: Received DISCONNECT from auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D
1647942676: Client auto-BADB5BE4-8FF4-C9F8-DD05-955CEC58CA3D disconnected.
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9
- 10
- 订阅的客户端日志输出如下：
PS E:\Tools\mosquitto> mosquitto_sub.exe -t sensors/temperature -q 1 -p 6969
32
- 1
- 2
可以看到，订阅客户端已经收到了发布者发布的消息：温度值32
3.4 简单的订阅/发布工作流
4. 测试过程中遇到的问题
4.1 记录mosquitto端口访问失败调试记录
- 以命令
mosquitto -v启动MQTT broker的端口开放情况如下：
PS X:> netstat -an |findstr "1883"
TCP 127.0.0.1:1883 0.0.0.0:0 LISTENING
TCP [::1]:1883 [::]:0 LISTENING
- 1
- 2
- 3
- 以命令
mosquitto -c .\mosquitto.conf -v启动MQTT broker的端口开放情况如下：
PS C:\Users\25267> netstat -an |findstr "1883"
TCP 0.0.0.0:1883 0.0.0.0:0 LISTENING
TCP 192.168.149.108:1883 192.168.149.162:59826 ESTABLISHED
TCP [::]:1883 [::]:0 LISTENING
- 1
- 2
- 3
- 4
可以看到未加载配置文件时，默认仅支持回环网卡。
《MQTT从入门到提高系列》快速导航：
- 【MQTT从入门到提高系列 | 01】从0到1快速搭建MQTT测试环境
- 【MQTT从入门到提高系列 | 02】MQTT3.1.1TLS加密传输
- 【MQTT从入门到提高系列 | 03】一文掌握MQTT3.1.1协议框架
- 【MQTT从入门到提高系列 | 04】MQTT应用协议之CONNECT
- 【MQTT从入门到提高系列 | 05】MQTT3.1.1之PUBLISH发布工作流
- 【MQTT从入门到提高系列 | 06】MQTT3.1.1之SUBSCRIBE订阅工作流
- 【MQTT从入门到提高系列 | 07】MQTT3.1.1之链路保活及断开
- 【MQTT从入门到提高系列 | 08】MQTT3.1.1主题Topic详解
- 【MQTT从入门到提高系列 | 09】WireShark抓包分析MQTT报文
写在末尾：
- 博客简介：专注AIoT领域，追逐未来时代的脉搏，记录路途中的技术成长！
- 专栏简介：从0到1掌握分布式消息中间件MQTT的使用。
- 面向人群：具备嵌入式开发基础的初级以上程序员
- 专栏计划：接下来会逐步发布跨入人工智能的系列博文，敬请期待
- Python零基础快速入门系列
- 快速入门Python数据科学系列
- 人工智能开发环境搭建系列
- 机器学习系列
- 物体检测快速入门系列
- 自动驾驶模拟器AirSim入门系列
- 自动驾驶物体检测系列
- …
