分布式事务（可靠消息服务最终一致性方案)
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 条评论
下一页
