物联网消息队列后端【免费下载链接】mosquittoEclipse Mosquitto - An open source MQTT broker项目地址https://gitcode.com/gh_mirrors/mosquit/mosquitto点击查看免费下载Eclipse Mosquitto 在 2.x 系列中提供了完整的插件体系允许以共享库.so/.dll形式挂载认证授权、消息拦截、统计上报等能力而无需改动 broker 内核。本文以仓库 plugins/README.md 为主线结合plugins/目录下的全部源码与测试用例系统讲解 Mosquitto 插件目录的组成、开发框架、编译加载方式并逐一剖析动态安全、持久化、Sparkplug 感知三大生产级插件与 19 个示例插件的实现原理帮助读者掌握用插件扩展 Mosquitto的完整实战路径。插件目录总览与定位plugins/目录是 Mosquitto 官方为 broker 扩展准备的应用商店其中dynamic-security/一个功能完整的插件通过$CONTROL主题实现认证与访问控制的动态配置详见 plugins/dynamic-security/README.mdpersist-sqlite/基于 SQLite 的持久化插件提供比默认内存/文件持久化更强的存储能力sparkplug-aware/面向 Sparkplug 规范工业 MQTT 场景的消息感知插件examples/19 个教学级示例插件覆盖插件 API 的绝大多数回调场景。顶层构建入口 plugins/CMakeLists.txt 通过四个add_subdirectory将这四部分纳入 CMake 构建体系。插件编译为模块MODULE共享库并链接common-options与mosquitto库非 Windows 平台安装时会将运行时产物放入CMAKE_INSTALL_BINDIR、库文件放入CMAKE_INSTALL_LIBDIR。每个示例插件目录都遵循统一结构mosquitto_功能.c源码、Makefile编译、test.conf运行配置、test.sh用仓库内已构建的../../../src/mosquitto -c test.conf -v启动 broker 进行验证见 plugins/examples/message-timestamp/test.sh。使用make在 plugins/examples/Makefile 中会遍历所有子目录或 CMake 均可一键构建全部插件。Mosquitto 插件开发框架速览所有插件都基于 include/mosquitto/broker_plugin.h 与 include/mosquitto/broker.h 中定义的事件回调 API。一个最简插件只包含三部分声明插件 API 版本在源码顶部调用MOSQUITTO_PLUGIN_DECLARE_VERSION(5);宏定义位于 include/mosquitto/broker_plugin.h。本仓库示例全部使用版本 5因此要求 Mosquitto 2.0 及以上wildcard-temp明确标注需要 2.1 及以上因为用到了mosquitto_subscription_delete()等较新 API。实现mosquitto_plugin_init()接收插件标识符调用mosquitto_plugin_set_info()见 include/mosquitto/broker.h设置插件名与版本再用mosquitto_callback_register()注册感兴趣的事件回调。可选实现mosquitto_plugin_cleanup()用于释放插件自身资源2.1 之后该函数可省略。编译命令在所有示例源码头部注释中均有给出形式统一为gcc -Ipath to mosquitto-repo/include -fPIC -shared mosquitto_xxx.c -o mosquitto_xxx.so在 broker 配置中加载只需一行plugin /path/to/mosquitto_xxx.so配置项写法可参考各示例的 test.conf。插件可用的事件覆盖认证、ACL 检查、连接/断开、消息进出、订阅/退订、时钟 tick 等生命周期下面按功能类别逐一展开。一、认证与访问控制类插件动态安全Dynamic Security基于 $CONTROL 主题的完整安全方案dynamic-security/是本目录中唯一的生产级安全插件实现了通过 MQTT 消息动态管理安全策略的机制JSON 命令发布到$CONTROL/feature/v1形式的主题即可完成客户端、分组、角色与 ACL 的全生命周期管理无需重启 broker 或编辑配置文件。核心概念模型详见 plugins/dynamic-security/README.mdClients客户端客户端连接时提供的用户名映射到 broker 上的一个 client 实例多个物理连接可共用同一用户名因而共享同一 broker 端 client 及其权限Groups分组broker client 可归属于零个或多个分组用于批量授权Roles角色角色可绑定到 client 或 group定义该主体允许做什么例如可/不可发布或订阅的主题。权限模型ACL 共有四种类型——publishClientSend客户端对外发布、publishClientReceive接收订阅消息、subscribe订阅、unsubscribe退订。默认行为为publishClientSend与subscribe默认拒绝publishClientReceive与unsubscribe默认允许可通过setDefaultACLAccess命令调整{ commands:[ { command: setDefaultACLAccess, acls:[ { acltype: publishClientSend, allow: false }, { acltype: publishClientReceive, allow: true }, { acltype: subscribe, allow: false }, { acltype: unsubscribe, allow: true } ] } ] }对应命令行客户端mosquitto_ctrl dynsec源码见 apps/mosquitto_ctrl/dynsec.cmosquitto_ctrl dynsec setDefaultACLAccess subscribe deny mosquitto_ctrl dynsec getDefaultACLAccess客户端管理命令全部支持 JSON 与 mosquitto_ctrl 两种方式操作JSON 命令mosquitto_ctrl 示例创建客户端createClient可带clientid、textname、textdescription、groups、roles组与角色须已存在mosquitto_ctrl dynsec createClient username password删除客户端deleteClientmosquitto_ctrl dynsec deleteClient username启用客户端enableClientmosquitto_ctrl dynsec enableClient username禁用客户端disableClient阻止登录并踢掉当前同名连接mosquitto_ctrl dynsec disableClient username查询客户端getClientmosquitto_ctrl dynsec getClient username列出客户端listClientsverbose、count-1表示全部、offset分页mosquitto_ctrl dynsec listClients 10 20修改客户端modifyClient可改clientid、password、textname、textdescription、roles、groups暂不支持 mosquitto_ctrl—设置客户端 IDsetClientId留空则清除mosquitto_ctrl dynsec setClientId username clientId设置密码setClientPasswordmosquitto_ctrl dynsec setClientPassword username password添加/移除角色addClientRole可带priority、removeClientRolemosquitto_ctrl dynsec addClientRole username rolename/removeClientRole加入/移出分组addGroupClient可带priority、removeGroupClientmosquitto_ctrl dynsec addGroupClient groupname username分组管理命令createGroup可带roles、deleteGroup、getGroup、listGroupsverbose/count/offset、modifyGroup可改textname、textdescription、roles、clients暂不支持 mosquitto_ctrl、addGroupRole/removeGroupRole、setAnonymousGroup为匿名客户端指定分组、getAnonymousGroup。对应的 mosquitto_ctrl 调用形如mosquitto_ctrl dynsec createGroup groupname、mosquitto_ctrl dynsec setAnonymousGroup groupname。角色与 ACL 管理命令createRole可携带初始acls如{ acltype: subscribePattern, topic: topic/#, priority: -1, allow: true }、getRole、listRoles、modifyRole暂不支持 mosquitto_ctrl、deleteRole、addRoleACL、removeRoleACL。ACL 类型支持subscribePattern订阅模式匹配与字面量形式subscribeLiteral命令示例mosquitto_ctrl dynsec createRole rolename mosquitto_ctrl dynsec addRoleACL rolename subscribeLiteral topic/# deny mosquitto_ctrl dynsec removeRoleACL rolename subscribeLiteral topic/#从源码结构看该插件由 acl.cACL 评估、auth.c认证、clients.c / groups.c / roles.c三类主体管理、control.c$CONTROL命令分发、config.c配置文件加载等模块组成并有test.sh与配套的 test.conf 做端到端验证broker 测试套件中14-dynsec-*.py见 test/broker覆盖了客户端、分组、角色、ACL、禁用、匿名组等大量场景。按 IP 认证auth-by-ipmosquitto_auth_by_ip.c 演示基于 IP 地址的认证回调插件直接根据客户端来源 IP 决定是否放行。README 明确提示这类简单的访问控制不如基于密码的认证可靠IP 可伪造、可被 NAT 掩盖更适合作为二次约束或演示用途。环境变量认证auth-by-envmosquitto_auth_by_env.c 从环境变量中读取用户名/密码进行校验演示插件如何利用mosquitto_opt配置参数与外部数据源对接。它是理解插件如何获得 broker 配置参数的最小范例。延迟认证delayed-authmosquitto_delayed_auth.c 演示异步/延迟认证的正确姿势当插件需要把认证请求发给外部服务器如 HTTP 鉴权服务时不能在回调里同步等待响应否则会阻塞 broker 主线程。插件可以自行派生线程处理认证请求但最终必须在 Mosquitto 主线程中调用mosquitto_complete_basic_auth()提交结果——该函数声明于 include/mosquitto/broker.h注释明确要求该调用发生在主线程。这是避免阻塞式鉴权拖垮整个 broker 的关键模式。拒绝协议版本deny-protocol-versionmosquitto_deny_protocol_version.c 演示如何拒绝指定 MQTT 协议版本的客户端连接可用于统一升级到 MQTT 5、禁用过旧协议等安全合规场景。二、连接生命周期与统计类插件连接状态connection-statemosquitto_connection_state.c 演示MOSQ_EVT_CONNECT/MOSQ_EVT_DISCONNECT事件的使用对每个客户端在连接时向$SYS/broker/connection/client/client id/state发布载荷1断开时发布0即把在线状态本身变成一条可订阅的 MQTT 消息。实现要点用mosquitto_client_id(ed-client)取客户端 ID拼装主题时检查snprintf返回值防止 client id 过长通过mosquitto_broker_publish_copy()见 include/mosquitto/broker.h让 broker 代为发布消息断开消息附带MQTT_PROP_MESSAGE_EXPIRY_INTERVAL 864001 天的 MQTT v5 消息过期属性避免离线状态永远驻留。客户端生命周期统计client-lifetime-statsmosquitto_client_lifetime_stats.c 统计会话存活时长分布用 uthash 哈希表记录每个客户端的连接时间断开时计算time(NULL) - connect并归入对应时间桶。时间桶共 28 档0, 1, 2, 5, 10, 20, 50, 100, 200, 500, 1k, 2k, 5k, 10k, 20k, 50k, 100k, 200k, 500k, 1M, 2M, 5M, 10M, 20M, 50M, 100M, 200M, 500M秒源码中lifetime_strs与lifetime_values两数组一一对应。MOSQ_EVT_TICK回调每 10 秒把有变化的计数发布到$SYS/broker/client/lifetimes/bucket。载荷大小统计payload-size-statsmosquitto_payload_size_stats.c 与生命周期统计对称统计发布消息的载荷字节数分布桶划分同为 28 档0, 1, 2, 5, ..., 500M字节周期性发布到$SYS/broker/publish/sizes/bucket。此类统计对评估流量构成、定位超大消息很有价值。发布时打印 IPprint-ip-on-publishmosquitto_print_ip_on_publish.c 在客户端向特定主题发布消息时把该客户端的client ID 与 IP 地址打印到 broker 日志用于审计谁在向敏感主题发数据。插件事件统计plugin-event-statsmosquitto_plugin_event_stats.c 统计插件系统各类事件被触发的次数是理解事件驱动模型、排查回调是否被调用的实用调试工具。三、消息处理类插件消息进入后、转发前此类插件均注册MOSQ_EVT_MESSAGE_IN回调在消息被 broker 接收之后、转发给订阅者之前介入是 Mosquitto 插件体系中最具扩展力的能力之一。附加 MQTT v5 属性add-propertiesmosquitto_add_properties.c 演示为入站消息追加 MQTT v5 用户属性user-property并展示如何获取客户端信息。它通过mosquitto_property_add_string_pair()依次写入三个属性$timestampbroker 接收消息时的 Unix 毫秒时间戳clock_gettime(CLOCK_REALTIME)获取$clientid发布者客户端 IDmosquitto_client_id()$client_username发布者认证用户名mosquitto_client_username()。注意修改的是struct mosquitto_evt_message中的ed-propertiesMQTT v5 客户端订阅时即可读到这些附加属性。消息时间戳message-timestampmosquitto_message_timestamp.c 与 add-properties 思路一致但更聚焦为每条消息追加键为timestamp的 user-property值为ISO-8601 格式%Y-%m-%dT%H:%M:%SZUTC的接收时间。README 指出这让 MQTT v5 客户端能判断一条**保留消息retained message**有多老——这是保留消息场景下消息何时到达 broker的唯一可靠信息来源。载荷修改payload-modificationmosquitto_payload_modification.c 演示修改消息载荷在每条载荷前拼接hello 前缀。实现要点也是所有载荷改写插件的通用范式计算新长度ed-payloadlen strlen(hello ) 1用mosquitto_calloc()而非裸malloc分配内存让 broker 能跟踪插件内存占用构造新载荷后将ed-payload/ed-payloadlen指向新内容绝不能 free 原始载荷broker 会负责释放。README 特意给出强烈警告必须百分百确认载荷格式正确后再修改——本插件在任何非纯文本消息上都会破坏内容二进制、压缩、序列化数据都会中毒。这正是能力越大责任越大的典型案例。主题修改topic-modificationmosquitto_topic_modification.c 演示改写消息主题先用mosquitto_topic_matches_sub(device//data/uplink, ed-topic, result)函数声明见 include/mosquitto/libcommon_topic.h判断主题是否匹配模式命中则截掉末尾的/uplink。效果是设备发布到device/0001/data/uplink订阅者实际收到的是device/0001/data——可用于在 broker 侧完成上行数据归一化/降噪设备端无需改动。强制保留force-retain与载荷禁用payload-banmosquitto_force_retain.c 演示把某些主题的消息强制设为保留消息retain适合状态型数据必须留存的场景mosquitto_payload_ban.c 演示按载荷内容拒绝消息可做简单的敏感内容拦截。四、订阅与 ACL 策略类插件通配符限时访问wildcard-tempmosquitto_wildcard_temp.c 是一个限制#通配符订阅的巧妙示例默认拒绝对#主题过滤器的订阅避免客户端探测活跃主题、防止带宽滥用但以用户名wildcard登录的客户端首次订阅#会被放行 20 秒ACCESS_PERIOD到期后订阅被静默移除。实现上组合了四个事件MOSQ_EVT_CONNECT识别wildcard用户并登记用 uthash 维护客户端表MOSQ_EVT_ACL_CHECK对#订阅返回MOSQ_ERR_SUCCESS放行一次或MOSQ_ERR_ACL_DENIED其余场景返回MOSQ_ERR_PLUGIN_IGNORE交给后续规则MOSQ_EVT_TICK通过mosquitto_subscription_delete(client-id, #)到期移除订阅并通过ed-next_s 1声明最多 1 秒后再回调一次MOSQ_EVT_DISCONNECT清理登记信息utlist 双向链表 uthash 双结构维护活跃订阅。该设计初衷源码注释是允许公共服务器如 test.mosquitto.org上的主题发现行为同时把带宽消耗限制在可控窗口内。订阅 QoS 限制limit-subscription-qosmosquitto_limit_subscription_qos.c 演示在订阅时限制允许的最大 QoS 等级可用于资源受限场景下强制降级。主题监狱topic-jailmosquitto_topic_jail.c 演示把客户端关进指定主题前缀越界订阅/发布一律拒绝是多租户隔离的经典模式。客户端属性client-propertiesmosquitto_client_properties.c 集中演示检索客户端信息的各类 APIclient id、用户名等部分函数在 add-properties 中也有使用可作为编写认证/审计插件时查阅 API 用法的参考。五、生产级扩展SQLite 持久化与 Sparkplug 感知persist-sqlite可插拔持久化后端persist-sqlite/ 是一个完整实现mosquitto_plugin_persist系列接口的插件将客户端会话、订阅、保留消息、消息队列等持久化数据落到 SQLite 数据库见 init.c、clients.c、retain_msgs.c、subscriptions.c 等模块并配套test.conf/test.sh可独立验证。相比默认持久化SQLite 后端适合需要外部可查、跨进程访问持久化数据的部署。sparkplug-aware面向工业 MQTT 的语义插件sparkplug-aware/ 针对 Sparkplug工业物联网数据规范提供消息感知处理包含 plugin.c插件入口、on_message.c消息处理与 plugin_global.h并附有自己的 README.md。该插件可作为在 Sparkplug 拓扑上叠加自定义策略如名称空间校验、命令下发控制的起点。六、如何快速上手验证构建仓库根目录make或make binary会按 plugins/examples/Makefile 的DIRS列表逐一编译所有示例插件CMake 构建则由 plugins/CMakeLists.txt 统一驱动试运行进入任一示例目录执行sh test.sh脚本会用仓库内已编译的../../../src/mosquitto -c test.conf -v启动 broker 并加载对应插件例如 message-timestamp 会为所有消息附加 ISO-8601 时间戳属性定制以示例为模板用gcc -Iinclude 目录 -fPIC -shared xxx.c -o xxx.so编译自己的插件在mosquitto.conf中用plugin /path/to/xxx.so加载必要时配合plugin_opt_前缀传递插件自定义参数深入插件 API 的权威说明在 include/mosquitto/broker.h 与 include/mosquitto/broker_plugin.h动态安全的完整命令参考在 plugins/dynamic-security/README.md官方集成测试见 test/broker 下的09-plugin-*.py、14-dynsec-*.py等脚本。结语plugins/目录是理解 Mosquitto 扩展机制的活教材动态安全插件展示了如何用$CONTROL主题把安全管理变成可编程的运行时操作message-timestamp、topic-modification 等示例则揭示了MOSQ_EVT_MESSAGE_IN背后接收后、转发前的拦截时机wildcard-temp 组合四个事件演示了有状态策略的完整写法。以此为起点读者完全可以在不改动 broker 内核的前提下为自己的部署构建认证、审计、统计、消息治理等专属能力。赞分享物联网消息队列后端【免费下载链接】mosquittoEclipse Mosquitto - An open source MQTT broker项目地址https://gitcode.com/gh_mirrors/mosquit/mosquitto点击查看免费下载相关推荐Eclipse Mosquitto插件开发指南动态安全模块实现详解Eclipse Mosquitto插件开发指南动态安全模块实现详解 动态安全模块是Eclipse Mosquitto的核心安全组件通过基于角色的访问控制R物联网消息队列后端Mosquitto 插件体系完全指南动态安全、消息处理与官方示例插件实战Mosquitto 插件体系完全指南动态安全、消息处理与官方示例插件实战 本指南以 Mosquitto 仓库中 plugins/README.md https物联网消息队列后端网络/通信Eclipse Mosquitto动态安全插件角色与权限管理实战Eclipse Mosquitto动态安全插件角色与权限管理实战 你是否在为IoT设备接入MQTT broker时的权限管理感到困扰设备越多样权限控制越复物联网消息队列后端上一篇Zotero PDF Translate插件版本兼容性深度解析3种技术架构演进路径与迁移决策框架下一篇终极免费视频加速神器Video Speed Controller 完整指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考