2
publisher-confirms 异步等待消息结果
step1. 数据入库同时消息(msg)入库
step2.发送消息
step3.请求确认 confirm
step4.读取数据库msg消息修改状态status:1
step5.但发送消息网络中断,通过定时任务查询状态为status:0的消息
step6.抓取消息,重新投递
step7.最大尝试次数 3次 不能成功则状态修改为2。
消息生产者投递新消息过后进行监听,收到broker反馈过后更新数据库消息状态,如果超过一定时间没有收到回复,定时任务会将消息拉取出来进行重新投递
消息确认模式,消息发出去之后异步的等待。
消息可靠性图
消息可靠性 设计思路
publisher-confirms 消息确认模式 监听相应结果
step1. 数据入库同时消息(msg)入库
step2.发送消息
step3.请求确认 confirm
step4.读取数据库msg消息修改状态status:1
step5.但发送消息网络中断,通过定时任务查询状态为status:0的消息
step6.抓取消息,重新投递
step7.最大尝试次数 3次 不能成功则状态修改为2。
订单表和消息记录表表结构
rabbitmq和springboot的配置后续
rabbitmq和springboot的配置