RsMQ 消息中间件 · 集群与规则

集群部署

当单机容量或可用性不足时，可将多个 RsMQ 节点组成集群，横向扩展以承载大规模设备长连接与消息流量。

• 水平扩展：新增节点分担连接与消息处理压力，吞吐随集群扩展。
• 高可用：节点冗余部署，单节点故障不影响其他节点服务，设备可重连恢复。
• 主题路由：集群内部按主题在节点间路由，发布者与订阅者即使连接不同节点也能收发。

集群节点应保持一致的认证与 TLS 策略，并通过负载均衡暴露统一接入入口。节点数量依现场规模与可用性规划。

规则引擎

规则引擎在 Broker 侧对消息自动处理，将其对接至下游业务系统。规则由触发条件与动作构成：

当 <触发条件> 满足时，执行 <动作>

触发条件

对接入消息进行匹配，例如：

• 主题匹配指定前缀或通配符模式；
• 消息内容满足约定的字段或阈值条件。

动作

条件命中后执行的动作：

示例模型

规则名称：高温告警
条件：主题匹配 site/+/device/+/telemetry，且温度字段超过阈值
动作：转发至告警主题，并触发下游告警流程

借助「集群 + 规则引擎」，RsMQ 既承担高并发消息中枢，又可在数据进入云端平台前就近完成路由、转换与告警。