分布式事物本地消息时序图
2018-02-02 12:38:54 2 举报分布式事物本地消息实现
作者其他创作
大纲/内容
回调消息生产接口
TransactionInterceptor
本地消息表 消息状态:准备状态就绪成功状态就绪失败状态发送状态 已发送状态 成功消费状态 异常消费状态
业务请求开始
rpc接口 修改消息状态: 异常消费状态
回调生产者定时扫描程序：扫描事件状态为:(准备状态)并且超过了指定时间。回调生产者的接口。(比如：消息生产者，提交完本地事物，刚好断电了。需要回调生产者做出相关处理)
业务请求结束
业务（消息消费者）
处理成功
分布式事物中间件
业务处理
发送消息扫描定时程序: 扫描事件状态为（就绪状态，异常消费状态） 发送mq 并且 修改事件状态为：（已发送状态）
MQ
处理失败
aop(eventPublish) start rpc 准备状态
开始处理消息
业务（消息回调接口）
业务（消息生产者）
aop(eventPublish) end rpc 就绪状态
收藏
职业：暂无
0 条评论
下一页
