分布式事务解决方案笔记 Segment4

消息发送一致性的异常流程处理

异常情况分析

https://s0.wailian.download/2019/01/23/messageDeliveryConsistencyApp-min.pngmessageDeliveryConsistencyApp-min

1、从主动方应用的角度来分析:

异常情况 可能的状态 一致性
预发送消息失败 消息未进存储,业务操作未执行(可能的原因:主动方应用、网络、消息中间件、消息存储) 一致
预发送消息后,主动方应用没有收到返回消息存储结果 1.消息未进存储,业务操作未执行。2.消息已进存储(待确认),业务操作未执行 1.一致。2.不一致
收到消息存储成功的返回结果,但未执行业务操作就失败 消息已进存储(待确认),业务操作未执行 不一致

https://s0.wailian.download/2019/01/23/messageDeliveryConsistencyMq-min.pngmessageDeliveryConsistencyMq-min

2、从消息中间件的角度来分析:

异常情况 可能的状态 一致性
消息中间件没有收到主动方应用的业务操作处理结果 1.消息已进存储(待确认),业务操作未执行(或业务操作出错回滚了)。2.消息已进存储(待确认),业务操作成功 1.一致。2.不一致
消息中间件收到业务操作结果(成功/失败),但处理消息存储中的消息状态失败 1.消息已进存储(待确认),业务操作未执行(或业务操作出错回滚了)。2.消息已进存储(待确认),业务操作成功 1.一致。2.不一致

异常情况总结

异常情况 一致性 异常处理方法
消息未进存储,业务操作未执行 一致
消息已进存储(状态待确认),业务操作未执行 不一致 确认业务操作结果,处理消息(删除消息)
消息已进存储(状态待确认),业务操作成功 不一致 确认业务操作结果,处理消息(更新消息状态,执行消息投递)