核心特性
FlowMQ Enterprise 的核心目标是:用一套平台统一多种消息模型与协议生态,并以云原生架构显著降低成本与复杂度。
1. 多模消息引擎(Multi-Modal Messaging Engine)
在一个系统内同时支持:
- Pub/Sub:多订阅者广播、实时分发
- Queue:工作队列、任务分发、削峰填谷
- Stream:事件流、日志管道、可回放消费
关键在于:协议(MQTT / Kafka / AMQP)与消息模型解耦。
- 你可以用熟悉的协议接入
- 平台内部按业务语义选择最合适的消息模型
- 同一套治理能力(权限/配额/监控/审计)覆盖所有模式
2. 统一路由引擎(Unified Routing Engine)
FlowMQ 提供统一路由引擎,通过 「统一主题」机制 实现跨协议互通:
- MQTT 发布 → Kafka 消费
- Kafka 生产 → MQTT 订阅
- 以及 AMQP 等协议的接入与映射
这意味着:
- 不再需要“桥接程序 / 同步任务 / 胶水代码”
- 不再需要把消息从一个系统搬运到另一个系统
- 端到端链路更短、故障点更少、交付更快
3. 弹性无状态架构(Stateless Architecture)
FlowMQ 将 Broker 设计为无状态计算层:
- 秒级扩缩容:按吞吐与连接数弹性伸缩
- 自愈能力:节点故障可快速替换
- 无 Rebalance:避免传统有状态分区系统扩容/故障恢复时的长时间再平衡
对平台团队的价值是:
- 更少容量预留
- 更可预测的故障恢复
- 更简单的运维与升级路径
4. 基于对象存储的持久化(S3-based Persistence)
FlowMQ 以对象存储(S3)作为持久化底座:
- 11 个 9 的持久性(11 nines durability)
- 近乎无限的存储与保留周期(按需扩展)
- 相比 EBS/本地盘,存储单价可降至 约 1/10,大幅降低长期保留与回放的成本
同时,由于架构避免了不必要的跨 AZ 复制流量与客户端跨 AZ 访问,整体网络成本也显著下降。
代价:在某些场景下,持久化链路带来更高的端到端延迟。FlowMQ 为低延迟需求也提供 MQTT 等协议通道与优化策略(见成本对比页的“权衡”部分)。
5. 原生多租户(Native Multi-Tenancy)
FlowMQ 以 Namespace 为第一隔离单元,为企业多团队/多业务线共用提供原生能力:
- 独立的主题空间(Topic)
- 独立的 ACL / 鉴权策略
- 独立的配额(吞吐、连接数、存储、QPS 等)
- 独立的监控与告警视角
平台团队可以统一治理,业务团队可以按需自助使用。
6. 边云协同(Edge-Cloud Synergy)
面向车联网、工业现场、园区网络等边缘场景:
- 边缘节点可 离线独立运行(断网不停服)
- 网络恢复后与云端 自动同步(状态/数据回传)
帮助你实现“边缘实时响应 + 云端集中处理”的一体化消息底座。