产品概述
你正在面对的真实问题:消息系统烟囱化
在企业数字化与实时化的过程中,消息中间件往往会“自然生长”为多套系统并存:
- 设备接入用 MQTT Broker
- 事件流与日志管道用 Kafka
- 业务异步与任务分发用 RabbitMQ / AMQP
- 各团队自建、各自运维、各自指标与权限
结果是:
- 数据与能力割裂:不同协议与模型之间难以互通,跨系统消费需要同步程序或胶水代码
- 成本飙升:多套集群、多套存储、多套跨 AZ 流量,多倍的容量预留
- 交付变慢:新业务要先“选型 + 打通 + 运维”,而不是直接用消息能力解决问题
- 可靠性风险:故障域增多、链路更长、排障更难
FlowMQ 的答案:统一消息基础设施平台
FlowMQ Enterprise(企业版)是一套 统一消息基础设施平台,用一个平台同时覆盖 Pub/Sub、Queue、Stream 三类消息模型,并通过 统一主题 + 统一路由 打通 MQTT、Kafka、AMQP 等协议生态。
你可以把 FlowMQ 看作:
- 对应用层:一个统一的消息能力底座
- 对架构层:一个消除消息系统烟囱化的统一平台
- 对成本与运维:一个以 无状态计算 + 对象存储持久化 为核心的云原生方案
关键设计理念(为什么它能统一)
1) 协议与消息模型解耦
传统系统往往把“协议”和“消息模型”绑定在一起(例如 Kafka ≈ Stream)。FlowMQ 将二者解耦:
- 协议层:MQTT / Kafka / AMQP 等访问入口
- 消息模型层:Pub/Sub、Queue、Stream
同一套基础设施可以被不同协议访问,并映射到合适的消息模型。
2) 统一主题(Unified Topic)
FlowMQ 使用「统一主题」作为跨协议的共同语义:
- MQTT 客户端向统一主题发布消息
- Kafka 客户端在同一主题上消费
- AMQP 客户端也可以通过映射接入
实现跨协议互通,避免旁路同步与二次落库。
3) 无状态 Broker + 对象存储持久化
- Broker 是 无状态计算层:便于秒级扩缩容与自愈,不需要分区 Rebalance
- 持久化基于 S3/对象存储:获得极高可靠性(11 个 9)与近乎无限保留能力,同时带来显著的存储与跨 AZ 成本优势
你将获得什么
- 更简单的架构:一套平台覆盖多类消息需求
- 更低的 TCO:存储、网络、容量预留与运维成本同时下降
- 更可靠与更弹性:云原生、易扩展、易恢复
- 打破数据孤岛:跨协议统一主题带来真正的互通
下一步建议阅读: