产品概述

FlowMQ 是一款融合的消息与数据流平台，在单一系统中提供 Subscription（实时推送）、Stream（数据流）、Queue（队列）等多种消息范式。它原生支持 MQTT、Kafka 和 AMQP 等主流消息协议，并支持不同协议之间的直接互通。FlowMQ 的核心目标是用一个平台统一多种消息模型与协议生态，显著降低企业实时基础设施的架构复杂度与运维成本。

问题：消息系统烟囱化

企业的消息中间件往往"自然生长"为多套系统并存：

设备接入用 MQTT Broker
事件流与日志管道用 Kafka
业务异步与任务分发用 RabbitMQ / AMQP
各团队自建、各自运维、各自监控与权限

由此带来一系列问题：

数据与能力割裂：不同协议之间难以互通，跨系统消费依赖同步程序或胶水代码
成本飙升：多套集群、多套存储、多倍跨 AZ 流量与容量预留
交付变慢：新业务要先完成选型、打通、运维，才能使用消息能力
可靠性风险：故障域增多，链路更长，排障更难

FlowMQ：统一消息基础设施平台

对应用层：统一的消息能力底座，一套 API 覆盖推送、流、队列等多种消息范式
对架构层：消除消息系统烟囱化，一个平台替代多套中间件
对成本与运维：以无状态计算 + 对象存储持久化为核心的云原生方案

关键设计理念

协议与路由分离：协议适配器将各协议消息转换为内部统一格式并提取路由地址（Topic），路由引擎据此进行匹配与分发，不感知来源协议。详见消息路由。
计算与存储分离：Broker 层专注协议接入与路由执行，存储层专注消息持久化，两层独立扩缩容。
Broker 无状态化：关键状态由控制面和存储层托管，Broker 可随时扩缩与替换，适合容器化与弹性伸缩。

核心收益

更简单的架构：一套平台覆盖多类消息需求
更低的 TCO：存储、网络、机器容量预留与运维成本同时下降
更高的可靠性与弹性：云原生架构，易扩展、易恢复
打破数据孤岛：无缝跨协议互通，无需桥接

下一步建议阅读：