IoT 数据可直接进入事件流处理;业务事件可被分析、告警、审计系统复用;跨系统集成从"搬运数据"变为"直接订阅"。
一套平台覆盖 Pub/Sub、Queue、Stream;协议与模型解耦,团队用熟悉协议接入;无缝跨协议互通,减少胶水代码。
基于对象存储的高持久性与可扩展保留;无状态架构秒级扩缩容与自愈;故障恢复路径更短、更可预测。
无状态 Broker 减少容量预留,对象存储替代 EBS 降低存储成本,统一平台替代多套集群减少运维开销。
三步实现跨协议消息互通
协议适配器接收来自 MQTT、Kafka、AMQP 客户端的消息,将其转换为内部统一格式,并提取 Topic 作为路由地址。
路由引擎根据消息的 Topic,与所有 Destination 的 topic filter 进行匹配,确定投递目标。路由逻辑完全协议无关——新增协议只需新增适配器,核心路由无需变动。
消息到达匹配的 Destination,按其类型完成最终投递:Subscription — 实时推送给在线订阅者;Stream — 追加日志持久化,支持回放与重新消费;Queue — 消息队列,支持 ACK、重试与死信。
不再桥接,无需集成,一套引擎,三种消息范式
同时支持 Pub/Sub(实时广播)、Stream(事件流与日志回放)、Queue(消息队列与削峰填谷)。协议与消息模型解耦,统一治理权限、配额、监控与审计。
原生支持 MQTT、Kafka、AMQP 协议适配器,客户端使用现有 SDK 直接接入,无需修改代码。各协议的标识自动映射为统一的 FlowMQ Topic。
协议无关的核心路由引擎,不同协议接入的消息经过相同路由,自然实现跨协议互通。MQTT 发布的数据 Kafka consumer 可直接消费,反之亦然,无需桥接程序与同步任务。
Broker 设计为无状态计算层,关键状态由控制面和存储层托管。秒级扩缩容,节点故障可快速替换自愈,无需传统有状态分区系统的长时间 Rebalance。
以 S3 兼容对象存储(AWS S3、Ceph、MinIO)作为持久化底座。存储容量按需扩展,单价远低于块存储,长期保留与历史回放的成本优势显著。
以 Namespace 为第一隔离单元:独立的资源空间、访问控制与配额(吞吐、连接数、存储、QPS)。平台团队统一治理,业务团队按需自助使用。
设备侧使用 MQTT,数据侧使用 Kafka,全程无需桥接,各取所长
从物联网到微服务,FlowMQ 为不同行业提供统一的消息基础设施