reddec/amqp-exec

Fluent AMQP镜像概述

Fluent AMQP是对streadway-amqp API的封装库及配套工具集，提供流畅易用的AMQP消息处理能力，支持连接重连、非阻塞消息处理等增强特性，适用于构建消息驱动的应用系统。

核心功能

• 自动重连：连接断开后自动恢复所有已配置的基础设施
• 非阻塞处理：高效处理消息队列，避免阻塞主线程
• 自动重排队：消息处理失败时可配置带延迟的自动重新排队
• 消息签名验证：通过公私钥对实现消息ID和内容的签名与验证，保障消息安全性
• 命令行工具：提供amqp-exec（CGI式消息触发执行）、amqp-recv（消息接收）、amqp-send（消息发送）等实用工具

使用场景

• 构建消息驱动的自动化任务系统（如通过AMQP消息触发脚本执行）
• 跨服务间的可靠消息传递与通信
• 需要消息签名验证的安全消息场景
• AMQP消息收发的快速测试与调试

配置说明

消息签名与验证

采用SHA512-RSA算法（PKCS#1 v1.5），签名者使用私钥对消息ID和体内容签名，验证者使用公证书验证。签名存储在X-Signature头部（二进制格式）。

Docker部署示例

amqp-exec服务部署

bash
docker run -d \
  --name amqp-exec-service \
  -e AMQP_URL=amqp://username:password@rabbitmq-host:5672/vhost \
  -v /host/path/to/scripts:/app/scripts \
  reddec/amqp-exec \
  --queue task-queue \
  --exec /app/scripts/process-task.sh

说明：监听task-queue队列，收到消息时执行指定脚本。

接收消息示例

bash
docker run --rm \
  -e AMQP_URL=amqp://username:password@rabbitmq-host:5672/vhost \
  reddec/amqp-exec amqp-recv \
  --queue log-queue \
  --output plain

发送消息示例

bash
echo "测试消息内容" | docker run --rm -i \
  -e AMQP_URL=amqp://username:password@rabbitmq-host:5672/vhost \
  reddec/amqp-exec amqp-send \
  --exchange amqp.topic \
  --routing-key service.logs