问题描述
我们开发了停机时间至关重要的系统。假设 1.0.0 版生产者产生的消息不能被 2.0.0 版消费者处理。
目前的部署方案如下:
- 生产中有 1.0.0 版
- RabbitMQ 队列具有路由键,例如“queue:ver1”
- Kubernetes 启动新服务,这些服务使用“queue:ver2”键声明和订阅队列,并将请求路由到此服务
- Kubernetes 停止了旧生产者
- 旧工人处理来自队列“queue:ver1”的剩余消息
- Kubernetes 停止了老员工
- 生产中有 2.0.0 版
这样的方案会产生几个问题:
- 即使消息格式没有变化也会创建队列
- 排队的人太多了
- 复杂的 Kubernetes 配置
- 我们不知道旧消息是否被老工人处理过,我们只是等待一段时间
我一直在寻找 message versioning 中的解决方案,但这种方式似乎需要实现一些一次性代码(例如将消息转换为新格式)或需要停机。并且没有相关的答案 here 和 here。
有没有办法拒绝“队列版本控制”?
如何避免停机而不丢失数据?
是否有一些最佳做法?
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)