RabbitMQ 中的消息模式演进：使用虚拟主机作为部署边界

Source: Dev.to

示例场景

初始流程 (v1)

1. 后端在结账时同步授权付款。
2. 授权成功后，发布 PaymentAuthorized 事件。

{
  "paymentId": "p-123",
  "authorizedAmount": 100.00,
  "currency": "EUR"
}

消费者收到该事件并捕获全部授权金额：

capture(authorizedAmount);

演进后流程 (v2)

随后，某些商品可能缺货。后端仍然授权付款，但在捕获之前会检查库存。它现在发布 PaymentCaptureRequested 事件，其中包含 实际需要捕获的金额，该金额可能低于授权金额。

{
  "paymentId": "p-123",
  "authorizedAmount": 100.00,
  "captureAmount": 80.00,
  "currency": "EUR"
}

消费者应只捕获指定的金额：

capture(captureAmount);

版本共存时的失效模式

• 缺少字段：如果 v1 消费者收到 v2 消息，captureAmount 字段未知，会导致处理错误或不可预测的行为。
• 忽略字段：v1 消费者可能会忽略 captureAmount，而回退使用 authorizedAmount，导致客户被多收费用。

根本原因是 同时处理不兼容的消息版本。

使用 RabbitMQ 虚拟主机作为部署边界

虚拟主机（vhost）在 RabbitMQ broker 中提供隔离的命名空间，允许你将通信限制在兼容的生产者/消费者对之间。

1. 在 Spring Boot 中外部化 vhost 与凭证

spring.rabbitmq.virtualHost=${RABBITMQ_VHOST}
spring.rabbitmq.username=${RABBITMQ_USER}
spring.rabbitmq.password=${RABBITMQ_PASSWORD}

2. 在流水线中为特定版本创建 vhost、用户和权限

# 为 1.0 版本创建 vhost
rabbitmqctl add_vhost payments-v1.0

# 创建专用用户
rabbitmqctl add_user payments-v1.0-app YourStrongPassword

# （可选）设置用户标签
rabbitmqctl set_user_tags payments-v1.0-app

# 为新 vhost 授予全部权限
rabbitmqctl set_permissions -p payments-v1.0 \
  payments-v1.0-app \
  ".*" ".*" ".*"

3. 通过容器环境变量传递配置

environment:
  RABBITMQ_VHOST: ${RABBITMQ_VHOST}
  RABBITMQ_USER: ${RABBITMQ_USER}
  RABBITMQ_PASSWORD: ${RABBITMQ_PASSWORD}
command: java -jar ...

4. 部署新版本

1. 部署指向新建 vhost 的更新后生产者和消费者。
2. 运行健康检查，确认所有节点均正常。
3. 验证上一版本的消息已全部被消费。

5. 成功切换后清理

• 删除旧的虚拟主机：rabbitmqctl delete_vhost payments-v0.x。
• 删除关联的用户：rabbitmqctl delete_user payments-v0.x-app。

清理可以防止陈旧的部署边界堆积。

进一步阅读

• Spring AMQP RabbitAutoConfiguration Reference – Spring AMQP Docs
• Spring AMQP Reference Documentation – Spring AMQP Docs

封面照片来源：Ivan N 在 Unsplash