FlowMQ Enterprise

Appearance

快速开始 ​

本页用最少步骤帮助你建立对 FlowMQ Enterprise 的整体认知，并完成一次端到端的“发布 → 路由 → 消费”演示。

说明：本文以概念与流程为主。不同版本的安装包、命令与参数可能略有差异，请以你的企业版交付件与运维规范为准。

目标 ​

  • 了解 FlowMQ 的三类消息模型：Pub/Sub、Queue、Stream
  • 了解「统一主题」如何让 MQTT 与 Kafka 等协议互通
  • 启动一个最小可用环境并完成验证

1. 准备环境 ​

  • 一套可运行的 Linux 主机或 Kubernetes 集群
  • 访问对象存储（S3 或兼容实现）用于持久化（企业版生产环境强烈建议）
  • 获取企业版安装包与 License

2. 启动 FlowMQ（最小示例） ​

以下以“解压 → 启动”的方式演示：

bash
tar xzf flowmq-enterprise-<version>-linux-x64.tar.gz
cd flowmq

# 启动（示例）
./bin/flowmq start

启动后建议先确认：

  • Broker 实例状态正常
  • 管理面/API 可访问
  • 默认 Namespace 已创建（或按你的交付规范创建）

3. 创建统一主题（Unified Topic） ​

统一主题是跨协议互通的关键：

  • 以统一主题为语义中心
  • MQTT/Kafka/AMQP 等协议对同一主题进行发布/订阅

示例（伪命令，仅表达流程）：

bash
flowmq admin topic create \
  --namespace demo \
  --topic iot/telemetry \
  --mode stream

4. MQTT 发布，Kafka 消费（跨协议演示） ​

MQTT 发布 ​

  • 客户端连接到 FlowMQ 的 MQTT 接入地址
  • 向统一主题 iot/telemetry 发布消息
bash
# 示例：使用任意 MQTT 客户端
mqtt pub -h <host> -p 1883 -t iot/telemetry -m '{"vin":"001","speed":42}'

Kafka 消费 ​

  • Kafka 协议客户端连接到 FlowMQ 的 Kafka 接入地址
  • 在同一统一主题上消费
bash
kafka-console-consumer \
  --bootstrap-server <host>:9092 \
  --topic iot/telemetry \
  --from-beginning

你将看到 MQTT 发布的消息被 Kafka 客户端直接消费，无需桥接或同步程序。

5. 下一步 ​

FlowMQ Enterprise（企业版）

Copyright © 2026 FlowMQ