- 物联网
- 消息队列
- 后端
- 网络/通信
【免费下载链接】mosquitto
Eclipse Mosquitto - An open source MQTT broker
导读
本文以仓库内 doc/joss-paper/paper.md 这一篇发表于《Journal of Open Source Software》（JOSS）的论文为核心骨架，系统拆解 Eclipse Mosquitto 项目的三大组成部分——MQTT 服务器（broker）、mosquitto_pub/mosquitto_sub命令行工具，以及提供 C/C++ 接口的客户端库，并结合当前仓库源码与配置印证论文所述设计。读完本文，你将理解 Mosquitto 在物联网轻量消息传递场景中的定位、其发布/订阅模型下的核心能力与配置手段，并能直接上手运行 broker、发布与订阅消息，乃至深入客户端库 API 与编译选项。
论文定位：一篇面向开源社区的软件摘要
paper.md是一篇典型的 JOSS 软件论文（Software Summary），元数据头部标明其标题为"Mosquitto: server and client implementation of the MQTT protocol"，作者为 Roger A. Light（ORCID 0000-0001-9218-7797），发表于 2017 年 5 月 17 日，配套的 codemeta.json 记录了当时对应的版本为 v1.4.11，许可证为 EPL 2.0 / EDL 2.0。论文明确强调：Mosquitto 提供 MQTT 消息协议的标准兼容服务器与客户端实现，并声明项目为 Eclipse 基金会成员。
论文的核心主张可以概括为三点，本文后续章节将逐一展开：
- MQTT 采用发布/订阅模型，网络开销低，可在微控制器等低功耗远程物联网传感器设备上实现，因此 Mosquitto 面向所有需要轻量消息传递的场景，尤其是资源受限设备；
- 项目由三个部分组成：主
mosquitto服务器、与 MQTT 服务器通信的mosquitto_pub与mosquitto_sub客户端工具、以及一个带 C++ 封装的 C 语言 MQTT 客户端库； - Mosquitto 既服务于协议本身的研究（如 MQTT 与 CoAP 性能对比、MQTT 中的 OAuth 应用研究），也作为构建更大系统的积木支撑各类应用（智慧城市服务、环境监测、远程实验室控制），并在学术界之外被 openHAB、OwnTracks 等开源项目及商业产品所采用。
MQTT 协议与 Mosquitto 的设计动机
论文在 Summary 中给出的动机十分明确：MQTT 基于发布/订阅（publish/subscribe）模型，具备低网络开销，并且可以在微控制器这类低功耗设备上实现——这类设备常见于偏远位置的物联网传感器。Mosquitto 正是为此类需求设计：当需要轻量消息传递、且资源受限时，它就是标准兼容的落地方案。
从当前仓库的 README.md 可以看到项目能力的演进：Mosquitto 现在是MQTT 协议 v5.0、v3.1.1 与 v3.1 三个版本的开源服务器实现，并同时提供 C 与 C++ 客户端库，以及mosquitto_pub、mosquitto_sub两个发布/订阅工具。这与论文写作时（v1.4.11，以 MQTT v3.1.1 为主）相比已显著扩展——当前仓库 config.mk 中的VERSION=2.1.0即是佐证。也就是说，论文描述的“三部分构成”架构延续至今，协议支持范围则随版本迭代不断拓宽。
发布/订阅模型的核心价值在于解耦：发布者无需知道谁在订阅，订阅者无需知道消息来自哪里，broker 作为中枢负责主题（topic）匹配与消息路由。仓库中的实现可以印证这一点：
- broker 侧的主题匹配与消息处理分别位于 src/subs.c（订阅维护）、src/retain.c（保留消息）与 src/handle_publish.c（处理 PUBLISH 报文）；
- 客户端库侧的主题校验工具见 lib/util_topic.c，负责验证主题合法性及
+/#通配符匹配逻辑。
项目三大部分：服务器、命令行工具与客户端库
论文明确指出项目由三部分组成，这是理解 Mosquitto 的钥匙。下面结合仓库源码逐一剖析。
第一部分：mosquitto服务器（broker）
broker 是项目的核心，其全部实现位于 src/ 目录，主入口为 src/mosquitto.c。从源码结构看，broker 的关键子系统包括：
- 配置解析：src/conf.c 负责读取
mosquitto.conf（仓库根目录即附带一份完整配置模板），支持include_dir外部配置目录（src/conf_includedir.c）； - 事件循环与多路复用：src/loop.c 是 broker 主循环，src/mux.c 配合 src/mux_epoll.c（Linux epoll）、src/mux_kqueue.c（macOS kqueue）、src/mux_poll.c（通用 poll）实现高并发连接管理；
- 网络与监听器：src/net.c 处理 TCP/Unix Socket 连接，src/listeners.c 管理多监听器配置；
- 持久化：src/persist_read.c 与 src/persist_write.c 实现内存数据库落盘，支撑保留消息与会话的持久存储；
- 安全认证：src/security_default.c 实现基于密码文件/ACL 文件的默认认证与访问控制，src/plugin_*.c 系列文件则承载插件化认证与消息事件扩展；
- 桥接（bridge）：src/bridge.c 与 src/bridge_topic.c 让 broker 之间互连、跨节点转发主题；
- $SYS 系统主题：src/sys_tree.c 发布 broker 自身状态信息（连接数、堆使用、消息统计等）。
配置模板 mosquitto.conf 展示了最常用的运维选项，例如：
# 监听端口与地址 # listener port-number [ip address/host name/unix socket path] # listener 1883 # 匿名访问控制（默认 false，仅允许本机连接） # allow_anonymous false # 认证与 ACL # password_file # acl_file # 持久化 # persistence false # autosave_interval 1800 # 日志 # log_dest stderr # log_type error此外还包含 TLS 证书配置（certfile/keyfile/cafile/require_certificate）、PSK 预共享密钥（psk_hint/psk_file）、桥接（connection/address/topic）、以及 MQTT v5 特有选项（max_topic_alias、max_packet_size、bridge_session_expiry_interval等）。
第二部分：mosquitto_pub与mosquitto_sub客户端工具
论文称这两个工具是“与 MQTT 服务器通信的一种途径”。它们位于 client/ 目录：mosquitto_pub负责发布消息，mosquitto_sub负责订阅主题并输出收到的消息，二者共享 client/client_shared.c 中的通用参数解析逻辑。
README 给出的最小可用链路（即论文所述能力的最小实践）为：
# 1. 启动 broker（默认监听 1883 端口） mosquitto # 2. 订阅主题（-v 显示消息主题） mosquitto_sub -t 'test/topic' -v # 3. 发布消息 mosquitto_pub -t 'test/topic' -m 'hello world'mosquitto_pub支持-q指定 QoS（0/1/2）、-r设置保留位、-f从文件读取负载；mosquitto_sub支持-v显示主题、-C限制接收条数、-c使用持久会话等。论文发表时的工具形态延续至今，且随 MQTT v5 支持扩展了属性传递能力（见 client/client_props.c 及-D参数）。
第三部分：C 客户端库与 C++ 封装
论文强调项目包含“一个用 C 编写的 MQTT 客户端库，带 C++ 封装”。C 库（libmosquitto）实现位于 lib/ 目录，公共 API 头文件集中在 include/mosquitto/ 下，其中 include/mosquitto/libmosquitto.h 定义了核心数据结构与函数。
以最常用的客户端生命周期为例，include/mosquitto/libmosquitto_create_delete.h 声明了：
mosquitto_new()：创建客户端实例，id传 NULL 时由库自动生成随机 client id（此时clean_session必须为 true），失败时返回 NULL 并置errno（如ENOMEM、EINVAL）；mosquitto_destroy()：释放客户端内存。
include/mosquitto/libmosquitto.h 还定义了mosquitto_message结构（含mid、topic、payload、qos、retain字段）、线程安全约定（除mosquitto_lib_init外库提供线程安全操作，多线程应用需调用mosquitto_threaded_set），以及MOSQ_OPT_*系列客户端选项（协议版本、SSL 上下文、接收/发送上限、TCP_NODELAY、绑定地址、HTTP 传输等）。
C++ 封装即 lib/cpp/mosquittopp.cpp，对应头文件为 include/mosquittopp.h，提供面向对象的mosquittopp类，事件通过虚函数回调（如on_connect、on_message、on_publish）暴露。仓库还附带可直接参考的最小示例：
- examples/publish/basic-1.c：演示
mosquitto_new→ 连接 → 发布 → 断开 → 销毁的完整流程； - examples/subscribe/basic-1.c：演示订阅与回调式消息接收。
论文所述研究价值：MQTT 协议研究与系统构建积木
论文指出 Mosquitto 允许开展与 MQTT 协议本身直接相关的研究，并列举了引用文献所代表的几类工作：
- 协议对比研究：如将 MQTT 与受限应用协议 CoAP（Constrained Application Protocol）通过公共中间件进行性能评估（对应 paper.bib 中的
Thangavel_2014，对比带宽消耗、端到端时延、丢包率等指标）； - 安全机制研究：如探索 OAuth 2.0 联邦身份与访问管理（FIAM）在基于 MQTT 3.1 的 IoT 系统中的应用（
Fremantle_2014）； - 智慧城市服务评估：如将 MQTT 与 CUPUS 云中间件对比用于智慧城市服务（
Antonic_2015）； - 环境监测系统：如 PRESS 项目利用 MQTT 与 WebSocket 构建泛在环境感知与共享框架（
Bellavista_2017）； - 远程实验控制：如基于 MQTT 的远程实验室设备实时动画控制（
Schulz_2014）； - 云上 IoT 平台：如基于 AWS 构建 MQTT broker 实现室温控制与火灾报警/抑制的智能家居服务（
Kang_2017）。
论文的论述逻辑是：一方面 Mosquitto 本身是 MQTT 协议研究的直接对象（标准兼容实现、可测可比）；另一方面它作为“构建更大系统的有用积木”支撑各类工程与研究系统。这种“研究载体 + 系统积木”的双重定位正是 JOSS 收录该项目的理由。需要说明的是，上述引用文献反映的是论文发表时的研究语境（截至 2017 年），本文仅转述论文中的既有表述，不构成对后续成果的断言。
学术圈之外的生态：openHAB、OwnTracks 与商业集成
论文在正文末段描述：学术圈之外，Mosquitto 被 openHAB 家庭自动化项目与 OwnTracks 个人位置跟踪项目等开源项目使用，并已被集成进商业产品。这段描述是论文对项目生态的原始陈述，我们不做扩展演绎——它恰恰说明 Mosquitto 的“轻量消息中间件”定位在真实世界中有着广泛落脚点：家庭自动化需要设备间低开销异步消息，位置跟踪需要移动端与服务器间高频短消息，而商用产品集成则看重其开源许可与协议兼容性。
当前仓库视角：构建与运行
论文写作于 v1.4.11 时代，而当前仓库已迭代至 v2.1.0（见 config.mk 的VERSION）。为了让读者在“论文描述”与“当前源码”之间建立连接，这里给出仓库现状下的实操要点。
快速运行
参照 README.md：安装二进制包后 broker 通常已随系统启动；否则以基础配置启动mosquitto，随后用mosquitto_sub -t 'test/topic' -v订阅、用mosquitto_pub -t 'test/topic' -m 'hello world'发布，即可完成一次完整的发布/订阅闭环。
从源码构建
README-compiling.md 说明：Linux 等平台直接make（Windows/Mac 使用 CMake），具体特性通过 config.mk 控制，也可在命令行覆盖，例如make WITH_TLS=no。从源码结构看，config.mk 中可裁剪的特性与论文所述“面向受限环境”的定位一致：
| 编译开关 | 作用（摘自 config.mk 注释） |
|---|---|
WITH_TLS | broker 与客户端中的 SSL/TLS 支持；关闭后密码只能明文存储 |
WITH_BRIDGE | broker 桥接支持，允许连接其他 broker 并转发主题 |
WITH_PERSISTENCE | 持久化数据库支持，周期性/退出时将保留消息与会话写入文件 |
WITH_WEBSOCKETS | WebSocket 支持（yes内置 /lws使用旧版 libwebsockets /no禁用） |
WITH_SYS_TREE | 是否发布包含 broker 状态的$SYS主题层级 |
WITH_THREADING | 客户端线程支持（mosquitto_loop_start/stop依赖） |
WITH_SRV | DNS-SRV 记录查询支持 |
WITH_SQLITE | sqlite3 持久化插件支持 |
WITH_ARGON2 | argon2id 密码哈希支持 |
构建依赖方面，README-compiling.md 与 README.md 列出的可选包包括 openssl、c-ares（DNS-SRV）、libwebsockets、cJSON（dynamic-security 插件与客户端 JSON 输出）、libsystemd-dev 等；其中 cJSON 对当前版本的 dynamic-security 插件和mosquitto_sub/mosquitto_rr的 JSON 输出为“可选但推荐”。
测试体系
仓库自带成体系的功能与单元测试，可验证论文所述“标准兼容”并非虚言：test/broker 下是数百个基于 Python 的 broker 行为测试（覆盖连接握手、QoS 0/1/2 全流程、保留消息、遗嘱、会话恢复、TLS、ACL、插件、桥接、持久化等，如 test/broker/03-publish-qos2.py 验证 QoS 2 四次握手语义）；test/lib 下则是 C/C++ 客户端库的测试；test/unit 提供单元测试。运行方式见 README-tests.md 与 test/ 下的构建脚本。
结语
这篇 JOSS 论文以精炼篇幅定义了 Mosquitto 的使命：为 MQTT 提供标准兼容的服务器与客户端实现，服务于从资源受限设备到大型系统的各类轻量消息传递场景。对照当前仓库源码可以发现，论文确立的“broker + 命令行工具 + C/C++ 客户端库”三部分架构保持至今，而协议版本从 v3.1/v3.1.1 扩展至 v5.0、构建选项与插件生态也大幅演进。对希望理解 MQTT 落地实践或将其作为系统积木的开发者而言，doc/joss-paper/paper.md 是理解项目设计意图的最佳入口，README.md、mosquitto.conf、include/mosquitto/libmosquitto.h 与 examples/ 则是继续深入的最佳下一站。
- 物联网
- 消息队列
- 后端
- 网络/通信
【免费下载链接】mosquitto
Eclipse Mosquitto - An open source MQTT broker
相关推荐
dora-rs MCP协议：模型上下文协议服务器与客户端
dora rs MCP协议：模型上下文协议服务器与客户端 引言：重新定义AI应用开发范式 在当今AI应用开发领域，开发者面临着一个核心痛点：如何高效整合多个AI
机器人人工智能ROS消息路由MCP Go SDK 文档全景导读：从基础协议到客户端与服务端特性的完整实现地图
MCP Go SDK 文档全景导读：从基础协议到客户端与服务端特性的完整实现地图 本篇文章以官方 Go SDK（github.com/modelcontextp
MCP 服务AI Agent工具调用如何在Helix编辑器中配置LSP客户端：提升代码编辑效率的完整指南
如何在Helix编辑器中配置LSP客户端：提升代码编辑效率的完整指南 Helix是一款后现代模态文本编辑器，以其高效的编辑体验和强大的功能而受到开发者喜爱。其中
代码编辑器开发工具CLI
创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考
