deployment - 当 AMQP 消息格式发生变化时，最好的部署方式是什么？

Question

我们开发停机时间至关重要的系统。假设 1.0.0 版生产者生成的消息无法由 2.0.0 版消费者处理。

目前的部署方案如下：

1. 生产中有 1.0.0 版本
2. RabbitMQ 队列具有像“queue:ver1”这样的路由键
3. Kubernetes 启动新服务，使用“queue:ver2”键声明和订阅队列，并将请求路由到该服务
4. Kubernetes 停止旧生产者
5. 老员工处理来自队列“queue:ver1”的剩余消息
6. Kubernetes 停止老工人
7. 生产中有 2.0.0 版本

这样的方案会产生几个问题：

• 即使消息格式没有变化，也会创建队列
• 真的很多队列
• 复杂的 Kubernetes 配置
• 我们不知道旧消息是否已被旧工人处理，我们只是等待一定时间

我一直在寻找消息版本控制的解决方案，但这种方式似乎需要实现一些一次性代码（例如将消息转换为新格式）或需要停机。而且这里和这里都没有相关的答案。

---

有没有办法拒绝“队列版本控制”？

如何避免停机而不丢失数据？

有一些最佳实践吗？

标签： deploymentversioningamqp