AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
MQ消息重发
2020-10-16 09:31:55
0
举报
分享方式
仅支持查看
MQ消费重发
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) 将消息发送到失败交换器
收藏
立即使用
MQ整体结构
收藏
立即使用
Quartz
收藏
立即使用
MQ消息重发
收藏
立即使用
ChannelHandler生命周期
LuffyDreams
职业：软件开发工程师
去主页
Collect
Get Started
架构 - MQ消息队列，rabbitmq，kafka
Collect
Get Started
消息中心
Collect
Get Started
配置消息
Collect
Get Started
消息订阅
评论
0
条评论
下一页
Document
