RocketMQ消息回溯实践与解析

文章预览

架构师（JiaGouX） 我们都是架构师！ 架构未来，你来不来？ 1 问题背景 2 验证 2.1 生产者启动 2.2 消费者启动 2.3 执行回溯 2.4 结果验证 2.5 验证小结 3 分析 3.1 策略模式，解析命令行 3.2 创建客户端，与服务端交互 3.3 获取topic对应的broker地址，提交重置请求 3.4 与 nameserver交互获取broker地址 3.5 与broker交互，执行重置操作 3.6 消费客户端收到请求，开始处理 4 核心流程 5 总结 6 延申 7 对比 1 问题背景 前段时间，小A公司的短信服务出现了问题，导致一段时间内的短信没有发出去，等服务修复后，需要重新补发这批数据。 由于短信服务是直接通过RocketMQ触发，因此在修复这些数据的时候，小A犯了难，于是就有了以下对话 领导 ：小A呀，这数据这么多，你准备怎么修呀？ 小A ：头大呀领导，一般业务我们都有一个本地消息表来做幂等，我只需要把数据库表 ………………………………