面向生产的完整能力
从认证到 ACL、从单机到集群、从 MQTT 到数据落库，覆盖IoT 平台的每一个关键环节
账号密码认证
基于 SQLite（单机）或 Redis（集群）存储用户，支持热更新、即时生效。集群模式下变更通过事件总线广播，毫秒级全集群生效。
Client ID 级 ACL
精细到每个客户端的主题权限控制，支持前缀、后缀、中间通配符匹配，规则预编译为枚举匹配。
极致性能
预编译 ACL + superuser 短路 + DashMap 无锁缓存 + moka 结果缓存 + ahash 哈希 + mimalloc，ACL 检查稳态 ~50ns，单机 10-14 万 msg/s。
三种部署模式
standalone 单机（SQLite / Redis）、raft 强一致集群、broadcast 高吞吐集群，一个二进制通吃所有场景。
云边协同
内置 MQTT 桥接，边缘节点与云端 Broker 双向同步。边缘本地自治，云端统一汇聚，网络中断自动重连，消息零丢失。
数据落库
订阅 MQTT 主题自动批量写入 GreptimeDB / MySQL / PostgreSQL。 共享订阅 + 批量提交，集群模式下天然去重，无需分布式锁。 三个目标可同时启用。
Web 管理面板
用户管理、ACL 编辑、在线客户端监控，支持分页、搜索、一键改密码。集群模式下可查看全集群视图。
五路监听
支持 TCP、TLS、WebSocket、WSS、QUIC 五种监听，证书热加载，客户端连接全程加密。QUIC 提供 0-RTT、无队头阻塞、连接迁移，弱网环境下表现更优。
会话与消息持久化
Broker 重启后订阅关系、离线消息自动恢复（session-storage）； 未过期消息落盘，新订阅者能收到历史消息（message-storage）。 支持 Sled / Redis / RAM 多种后端。
专业级运维能力
内置排障、审计、强制运维三大工具，无需额外部署监控系统
客户端踢下线
一键强制断开异常或冲突的客户端连接，用于 Client ID 冲突、权限变更后强制重连、异常连接清理等场景。
- Web 面板一键操作
- 可选择清除会话 / 订阅
- 操作自动写入审计日志
- 集群下定位实际节点
消息追踪
在 publish 路径上实时记录消息事件，3 秒定位"消息发出但收不到"的问题，直接看到 PASS / DENY 结果。
- 按 topic / clientid 过滤
- 实时看到 ACL 通过 / 拒绝
- 未开启时零性能影响（~1ns）
- 自动过期，无需手动清理
操作审计日志
记录所有管理操作：谁、何时、做了什么、从哪个 IP。满足企业合规审计要求。
- 记录操作者 IP
- 支持按操作类型过滤
- 反代场景可提取真实 IP
- SQLite 保留 100 万条 / Redis 保留 1 万条
多协议工业接入
南向工业协议统一转为 MQTT 上云，接入层与业务层彻底解耦
覆盖多元 IoT 场景
从设备接入到数据上云，一套 Broker 全搞定，适配各类物联网业务形态
智能家居 / 楼宇
灯光、空调、安防等设备统一接入，实时状态上报与远程控制，支持场景联动。
工业物联网
PLC、传感器、网关数据采集，高并发上报与实时告警推送，保障产线稳定运行。
车联网 / 车队
车载终端定位、状态上报、远程指令下发，海量车辆并发在线，支持轨迹回传。
智慧农业
土壤、气象、灌溉设备数据采集，远程控制大棚与水利设施，提升种植效率。
能源电力
电表、光伏、储能设备数据采集，支持远程抄表与负荷监控，助力能耗分析。
物流仓储
资产追踪、仓储环境监测、冷链温湿度上报，全流程可视化，保障货物安全。
生产级性能表现
稳定、低延迟、高吞吐，从容应对海量设备连接
从单机到集群，无缝演进
通过环境变量切换部署模式，代码零改动，运维零负担
单机模式
开发、测试、单台服务器的首选。支持 SQLite 本地存储或 Redis 集中存储，按需选择。
- 10-14 万 msg/s 吞吐
- SQLite 启用 WAL，读写不互斥
- Redis 集中存储用户与 ACL
- Web 面板支持 10 万连接秒开
Raft 集群
生产环境首选。强一致性，防止 Client ID 重复登录，高可用。
- 3 节点优化后 11-15 万 msg/s
- 强一致性保证
- ACL 变更毫秒级全集群生效
- Redis 共享存储 + 事件广播
Broadcast 集群
海量传感器场景。最终一致性，追求极致吞吐与低延迟。
- 3 节点 30-40 万 msg/s
- 无 Leader，去中心化
- gRPC 广播，延迟更低
- 适合高频上报场景
常见问题
您可能关心的几个问题
MQHub 支持哪些客户端接入？
完整支持 MQTT 3.1 / 3.1.1 / 5.0 协议，提供 TCP（1883）、TLS（8883）、WebSocket（8080）、WebSocket Secure（8443）、QUIC（9443/UDP五种监听方式， 兼容主流客户端库与设备固件。QUIC 需客户端支持， 适合弱网、移动切换场景。
支持哪些工业协议接入？
通过配套网关支持多种工业协议，涵盖 Modbus（TCP / RTU / RTU over TCP / ASCII）、OPC UA、Siemens S7、Mitsubishi MC、IEC 60870-5-104 等主流总线与 PLC 驱动，南向协议统一转为 MQTT 上云。
支持把消息写入哪些数据库？
支持三种落库目标：GreptimeDB（时序数据专用，列式压缩，高吞吐）、 MySQL（通用关系型，适合业务查询 / JOIN）、 PostgreSQL（通用关系型，结构同 MySQL）。 三者可同时启用，采用共享订阅 + 批量提交，集群模式下每条消息只投递给组内一个节点， 天然去重，无需 Redis 分布式锁。
支持多节点数据同步吗？
支持。MQHub 内置 MQTT 桥接功能，可将边缘节点的数据上报至中心 Broker，也可从中心下发指令到边缘。桥接支持自动重连、消息缓冲、并发连接，网络中断时消息不丢失，恢复后自动补发。
需要额外部署 Redis 吗？
单机模式可选择 SQLite 本地存储，零外部依赖；若希望用户与 ACL 数据集中管理，也可切换为 Redis 存储；Raft / Broadcast 集群模式则必须使用 Redis。
集群模式下 ACL 修改多久生效？
通过 Web 面板或 API 修改用户 / ACL 后，会通过 Redis Pub/Sub 事件总线广播到所有节点，毫秒级（<100ms）全集群生效，无需重启或手动清缓存。
如何排查"设备发了消息但服务端收不到"？
使用 Web 面板内置的消息追踪功能：点击 header「追踪」按钮，输入 topic filter，开始追踪。实时看到消息是否到达 Broker、是否通过 ACL、Payload 大小等。3 秒定位问题环节。
能审计所有管理操作吗？
可以。操作审计日志记录所有管理操作，包括操作者、时间、操作类型、目标、来源 IP、结果。支持按操作类型过滤、分页查询。满足企业合规审计要求。
能强制断开异常客户端吗？
可以。在在线客户端列表点击「踢下线」按钮，可强制断开指定客户端。适用于 Client ID 冲突、异常连接清理、权限变更后强制重连等场景。
Broker 重启后订阅关系会丢吗？
默认会话存储在内存中，Broker 重启后会丢失。
如需保留，可启用 session-storage 插件
（配置文件存在即生效），将订阅关系、离线消息持久化到
Sled / Redis，Broker 重启后客户端重连即自动恢复。
注意：仅对 clean_session=false 的客户端生效。
新订阅者能收到历史消息吗？
两种机制：retain 消息只存
retain=true 的最后一条；message-storage
插件存储所有未过期消息。启用 message-storage 后，
在消息过期前任何新订阅该主题的客户端都能收到。
适合设备状态同步、配置分发等场景。
集群模式下单机能支撑多少连接？
连接能力由内存决定。参考值：4GB 约 6-8 万，8GB 约 12-15 万，16GB 约 30-35 万。集群模式下每节点约减少 10-20% 连接能力（用于维护集群状态），但总能力随节点数近似线性扩展。
部署和运维成本如何？
单二进制交付，空闲内存占用极低，支持 systemd 与容器化运行；通过环境变量即可一键切换部署模式，升级只需替换文件。
联系方式
技术咨询、部署协助、商务合作，请添加微信
扫码添加微信
📱 微信联系
微信号：prcloud
工作日 9:00 - 21:00 在线回复