Skip to content

产品概述

你正在面对的真实问题:消息系统烟囱化

在企业数字化与实时化的过程中,消息中间件往往会“自然生长”为多套系统并存:

  • 设备接入用 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:存储、网络、容量预留与运维成本同时下降
  • 更可靠与更弹性:云原生、易扩展、易恢复
  • 打破数据孤岛:跨协议统一主题带来真正的互通

下一步建议阅读:

FlowMQ Enterprise(企业版)