FlowMQ

融合 MQTT + Kafka
消息流平台

FlowMQ 将 MQTT、Kafka 与 AMQP 统一到一个平台,连接 IoT 设备、数据管道、应用与 AI Agent,简化边缘、云和 AI 之间的实时数据流。

核心价值

为什么选择 FlowMQ

打破数据孤岛

IoT 数据可直接进入事件流处理;业务事件可被分析、告警、审计系统复用;跨系统集成从"搬运数据"变为"直接订阅"。

简化架构,加速创新

一套平台覆盖 Pub/Sub、Queue、Stream;协议与模型解耦,团队用熟悉协议接入;无缝跨协议互通,减少胶水代码。

云原生弹性与可靠性

基于对象存储的高持久性与可扩展保留;无状态架构秒级扩缩容与自愈;故障恢复路径更短、更可预测。

大幅降低 TCO

无状态 Broker 减少容量预留,对象存储替代 EBS 降低存储成本,统一平台替代多套集群减少运维开销。

工作原理

协议适配 → 统一路由 → 多模投递

三步实现跨协议消息互通

MQTT Client
Kafka Producer
AMQP Publisher
协议接入
Protocol Adapter
统一路由
Unified Router
多模投递
Multi-mode Delivery
Subscription
实时推送
Stream
日志持久化
Queue
消息队列
01

协议接入

协议适配器接收来自 MQTT、Kafka、AMQP 客户端的消息,将其转换为内部统一格式,并提取 Topic 作为路由地址。

02

统一路由

路由引擎根据消息的 Topic,与所有 Destination 的 topic filter 进行匹配,确定投递目标。路由逻辑完全协议无关——新增协议只需新增适配器,核心路由无需变动。

03

多模投递

消息到达匹配的 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,全程无需桥接,各取所长

MQTT 设备
发布遥测数据
FlowMQ
Topic
sensors/device-001/telemetry
路由引擎
匹配 topic filter
Stream
持久化事件流
Kafka Consumer
消费 sensors.device-001.telemetry

应用场景

从物联网到微服务,FlowMQ 为不同行业提供统一的消息基础设施

IoT / 车联网平台

设备用 MQTT 接入,云端用 Stream(Kafka)做事件流处理
设备数据可被不同团队用不同协议直接消费
对象存储持久化降低长期保留与回放成本

统一消息,简化架构,降低成本

了解 FlowMQ 如何帮助你用一套平台替代多套消息中间件