MQ消息重发

开始

ConfirmCallback方法中获取唯一标识

Y

将发送的消息存入缓存唯一标识作为键值

设置message的headers中发送到交换器标志属性为False

获取message的headers中失败重试次数属性

N

判断缓存中是否存在该值？

1）设置message的headers中发送到交换器标志属性为True2）更新消息缓存3）更新消息发送失败记录表

fail_count_exchange失败重发次数记录

判断message的headers中发送到交换器标志属性？

1）设置message的headers中失败重试次数属性+12）更新消息缓存3）将消息发送到重发交换器

结束

ACK标识？

次数>=3?

服务端发送消息-设置唯一标识correlationDataId

success_send_exchange是否存在或是否为False

1）删除消息缓存2) 将消息发送到失败交换器