Skip to content

核心特性

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)

面向车联网、工业现场、园区网络等边缘场景:

  • 边缘节点可 离线独立运行(断网不停服)
  • 网络恢复后与云端 自动同步(状态/数据回传)

帮助你实现“边缘实时响应 + 云端集中处理”的一体化消息底座。

FlowMQ Enterprise(企业版)