4. RabbitMQ 安装与配置：单机部署、用户权限、虚拟主机、交换机与队列声明

在多批次并行召回通知链路中，RabbitMQ 作为核心消息中间件，承担着指令下发、状态回传与异常重试的通信职责。本章将围绕单机部署、用户权限体系、虚拟主机隔离、交换机与队列声明四个关键环节，完成 RabbitMQ 运行环境的搭建与验证。

4.1 单机部署

开发与测试环境通常采用单机部署模式。以下基于 CentOS 7 / Ubuntu 20.04 环境，使用官方提供的 YUM/APT 源进行安装。

# 安装示例（Ubuntu）
sudo apt-get install curl gnupg -y
curl -fsSL https://github.com/rabbitmq/signing-keys/releases/download/2.0/rabbitmq-release-signing-key.asc | sudo apt-key add -
sudo apt-get install rabbitmq-server -y
sudo systemctl start rabbitmq-server
sudo systemctl enable rabbitmq-server

4.2 用户权限与虚拟主机

RabbitMQ 通过虚拟主机（vhost）实现资源隔离，每个 vhost 拥有独立的交换机、队列与绑定关系。用户权限在 vhost 粒度上配置，支持读、写、配置三种权限标签。

# 创建虚拟主机
rabbitmqctl add_vhost recall_vhost

# 创建用户并设置密码
rabbitmqctl add_user recall_admin Recall@2024
rabbitmqctl add_user recall_producer Recall@2024
rabbitmqctl add_user recall_consumer Recall@2024

# 设置权限（vhost 级别）
rabbitmqctl set_permissions -p recall_vhost recall_admin ".*" ".*" ".*"
rabbitmqctl set_permissions -p recall_vhost recall_producer "" ".*" ""
rabbitmqctl set_permissions -p recall_vhost recall_consumer "" "" ".*"

4.3 交换机与队列声明

召回通知链路采用 Topic 交换机 实现多批次并行路由。交换机根据 routing key 将消息分发到对应队列，每个批次拥有独立的队列，便于并行消费与故障隔离。

# 声明 Topic 交换机
rabbitmqadmin declare exchange name=recall.exchange type=topic durable=true

# 声明三个批次队列
rabbitmqadmin declare queue name=recall.batch.01 durable=true
rabbitmqadmin declare queue name=recall.batch.02 durable=true
rabbitmqadmin declare queue name=recall.batch.03 durable=true

# 绑定队列到交换机，使用批次 routing key
rabbitmqadmin declare binding source=recall.exchange destination=recall.batch.01 routing_key=batch.01
rabbitmqadmin declare binding source=recall.exchange destination=recall.batch.02 routing_key=batch.02
rabbitmqadmin declare binding source=recall.exchange destination=recall.batch.03 routing_key=batch.03

4.4 声明确认与链路验证

完成声明后，通过 Web 管理界面或命令行确认资源状态。以下为关键验证项：

• 交换机列表： 确认 recall.exchange 存在且类型为 topic
• 队列列表： 确认 recall.batch.01 ~ 03 三个队列均处于 running 状态
• 绑定关系： 确认每个队列已绑定到 recall.exchange，且 routing key 正确
• 用户权限： 使用 recall_producer 发送测试消息，使用 recall_consumer 消费，验证权限隔离

# 命令行验证
rabbitmqctl list_exchanges -p recall_vhost
rabbitmqctl list_queues -p recall_vhost
rabbitmqctl list_bindings -p recall_vhost

# 发送测试消息
rabbitmqadmin publish exchange=recall.exchange routing_key=batch.01 payload="test_batch_01"

# 消费测试消息
rabbitmqadmin get queue=recall.batch.01 ackmode=ack_requeue_false

4.5 常见问题与避坑指南