Skip to content

CLI 工具

FlowMQ 提供 flow 命令行工具,用于从终端直接与 FlowMQ 实例交互。适合脚本自动化、快速管理和调试场景。

注意:CLI 的具体安装方式和可用命令以企业版交付件为准。以下为功能概述。

配置连接

在使用 CLI 前,需要配置连接到本地 FlowMQ 实例的参数:

bash
# 设置连接上下文
flow ctx set --host your-flowmq-host --port 9092

核心消息命令

flow pub — 发布消息

将消息发布到指定主题:

bash
# 发布简单消息
flow pub orders.new --message '{"id": 1, "product": "laptop"}'

# 发布时携带 header
flow pub sensor.temp --message '22.5' -H 'unit=celsius' -H 'location=room-a'

flow sub — 消费消息

从队列、流或订阅中消费消息,用于实时调试和检查消息流:

bash
# 从队列消费
flow sub queue my-processing-queue

# 从流的起始位置消费
flow sub stream all-events --position earliest

# 通过临时订阅消费主题
flow sub topic "sensors.#"

资源管理

flow stream — 管理流

创建、列出和管理项目中的流:

bash
# 创建绑定到主题过滤器的流
flow stream create all-orders --bind "orders.#"

# 列出所有流
flow stream list

其他命令

bash
# 查看帮助
flow --help

# 查看子命令帮助
flow pub --help
flow sub --help
flow stream --help

FlowMQ