可靠消息服务
2018-07-20 11:14:04 12 举报可靠消息服务(跨系统调用最终一致解决方案)
作者其他创作
大纲/内容
可靠消息服务
逻辑处理2
逻辑处理3
消息确认子系统
消息恢复子系统
将消息状态设置为发送中
发送至中间件
消息预发送
消息服务子系统
消息发送确认
逻辑处理1
重新发送消息
OK？
MQ中间件
A系统
B系统
调用A系统确认业务执行
此处一定要是异步的，如果是同步的会因为超时等原因，导致A系统数据回滚
业务成功执行
消费消息
成功消费
预发送成功
NO
删除消息
将消息状态设置为成功消费
B系统需要实现幂等
需要这个的原因是：预发送消息成功，但是由于客观问题，未发送到MQ，需要把这部分消息处理1、重发 2、删除
YES
更新消息状态为成功消费
找出所有发送中但未被确认的消息
找出所有预发送消息
0 条评论
下一页
