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