分布式事务(可靠消息服务最终一致性方案)
2021-01-11 11:41:36 0 举报
分布式事务
作者其他创作
大纲/内容
处理异常步骤的定时器
调用更改消息状态接口
解决方案
2.调用删除消息接口。结束流程。
可能发生异常的地方
消费端
预发送接口:把消息存到消息表中。状态是待发送0
结束流程
消息服务
执行A业务/成功or失败
成功/失败
1.预发送接口
成功(A业务状态:处理成功)
返回结果
成功
失败
失败(A业务:处理失败)
删除消息接口:根据消息id删除消息。
1.调用预发送消息接口。
消费mq消息,执行B业务,调用更改消息状态接口
3.(异步)更改消息状态
消费端(B事务域)
2.删除消息
1.预发送消息接口。2.删除消息接口。3.更改消息接口。
定时器:1.查询消息表中(待发送)的消息。2.根据查询结果,查询业务执行状态。3.业务处理成功,重新投递mq消息,并改消息状态为已发送4.业务处理失败,删除消息表中的数据。
结束
1.查询(第一次3分钟,第二次10,第三次15分钟)已发送待处理的消息数据。2.如果是前两次查询,重新发送mq数据。第三次标记消息死亡
发送端(A事务域)
发送端
消息表结构
可能发送异常的地方
3.调用更改消息状态接口。
收藏
0 条评论
下一页