cloudamqp/amqpcat

amqpcat

镜像概述

amqpcat 是一款针对 AMQP 协议的命令行工具，相当于 AMQP 版本的 netcat（nc）工具。它提供简洁的命令行界面，用于向 AMQP 服务器发布消息（生产者模式）和从 AMQP 服务器消费消息（消费者模式），适用于消息测试、集成脚本和自动化流程。

核心功能与特性

• 双模式支持：生产者模式（从标准输入读取消息，每行一条）和消费者模式（消息体输出到标准输出）
• 灵活连接配置：支持通过 URI 指定 AMQP 服务器，可配置交换器、路由键和队列
• 消息格式化：自定义输出格式，支持包含交换器名称、路由键、消息体等元数据
• 轻量易用：命令行工具，可与其他命令行工具（如tail、jq）无缝集成

使用场景

• 快速向 AMQP 队列发送测试消息
• 从指定队列消费并查看消息内容
• 格式化输出消息元数据与内容
• 实时日志转发至 AMQP 服务器
• 解析 JSON 格式消息并提取关键信息

安装与运行

通过 Docker 运行 amqpcat：

bash
docker run -it --rm cloudamqp/amqpcat

说明：-it 启用交互模式，--rm 确保容器退出后自动清理

命令参数说明

Usage: amqpcat [arguments]
    -P, --producer                   生产者模式，从标准输入读取，每行作为新消息
    -C, --consumer                   消费者模式，消息体写入标准输出
    -u URI, --uri=URI                AMQP 服务器连接 URI
    -e EXCHANGE, --exchange=EXCHANGE 交换器名称
    -r ROUTINGKEY, --routing-key=KEY 发布消息时的路由键
    -q QUEUE, --queue=QUEUE          消费消息的队列
    -f FORMAT, --format=FORMAT       格式化字符串（默认 "%s\n"）
                                     %e: 交换器名称
                                     %r: 路由键
                                     %s: 消息体（字符串形式）
                                     \n: 换行符
                                     \t: 制表符
    -v, --version                    显示版本信息
    -h, --help                       显示帮助信息

使用示例

1. 发送消息到队列

向名为 test 的队列发送消息：

bash
echo "Hello World" | docker run -i --rm cloudamqp/amqpcat --producer --uri=$CLOUDAMQP_URL --queue test

说明：-i 确保标准输入传递到容器，--queue 指定目标队列

2. 从队列消费消息

从名为 test 的队列消费消息：

bash
docker run -it --rm cloudamqp/amqpcat --consumer --uri=$CLOUDAMQP_URL --queue test

3. 临时队列消费消息

从临时队列消费发送到 amq.topic 交换器且路由键为 hello.world 的消息：

bash
docker run -it --rm cloudamqp/amqpcat --consumer --uri=$CLOUDAMQP_URL --exchange amq.topic --routing-key hello.world

4. 格式化输出消息到文件

消费消息并以 CSV 格式输出到文件：

bash
docker run -it --rm cloudamqp/amqpcat --consumer --uri=$CLOUDAMQP_URL --queue test --format "%e,%r,"%s"\n" | tee messages.csv

5. 系统日志转发

实时跟踪系统日志并发送到 syslog 交换器：

bash
tail -f /var/log/syslog | docker run -i --rm cloudamqp/amqpcat --producer --uri=$CLOUDAMQP_URL --exchange syslog --routing-key $HOSTNAME

6. JSON 消息解析

消费 JSON 消息并使用 jq 提取属性：

bash
docker run -it --rm cloudamqp/amqpcat --consumer --uri=$CLOUDAMQP_URL --queue json | jq .property