核心特性

1. 多模消息引擎

FlowMQ 在一个系统内同时支持多种消息范式：

• Pub/Sub：多订阅者广播、实时分发
• Stream：事件流、日志管道、可回放消费
• Queue：工作队列、任务分发、削峰填谷

关键在于：协议（MQTT / Kafka / AMQP）与消息模型解耦。

• 你可以用熟悉的协议接入
• 平台内部按业务语义选择最合适的消息模型
• 同一套治理能力（权限/配额/监控/审计）覆盖所有模式

2. 无缝跨协议互通

FlowMQ 的核心路由引擎是协议无关的， 不同协议接入的消息都会经过相同的路由引擎，因此可以自然地实现不同协议之间的消息互通，比如：

• MQTT 设备发布的数据，Kafka consumer 可直接消费
• Kafka 写入的告警，MQTT 订阅者可实时接收
• 无需桥接程序、同步任务或胶水代码，端到端链路更短，故障点更少

3. 弹性无状态架构

FlowMQ 将 Broker 设计为无状态计算层：

• 秒级扩缩容：按吞吐与连接数弹性伸缩
• 自愈能力：节点故障可快速替换
• 无 Rebalance：避免传统有状态分区系统扩容/故障恢复时的长时间再平衡

对平台团队的价值是：

• 更少容量预留
• 更可预测的故障恢复
• 更简单的运维与升级路径

4. 基于对象存储的持久化

FlowMQ 以对象存储（兼容 S3 协议）作为持久化底座：

• 高持久性：由底层对象存储服务保障，如 AWS S3、Ceph、MinIO 等
• 存储容量按需扩展：相比预分配本地盘或 EBS，容量规划更灵活
• 存储成本更低：对象存储单价通常远低于块存储，长期保留与历史回放的成本优势显著

5. 原生多租户

FlowMQ 以 Namespace 为第一隔离单元，为企业多团队/多业务线共用提供原生能力：

• 独立的资源空间
• 独立的访问控制
• 独立的配额（吞吐、连接数、存储、QPS 等）

平台团队可以统一治理，业务团队可以按需自助使用。