推送系统
2022-02-08 14:58:17 0 举报推送
作者其他创作
大纲/内容
步骤4
注册Callback
MQ.Msg.retryTime++MQ.Msg.delayLevel更新
主要是修改重试逻辑这里的代码，也就是判断retryTime该不该加1
推送流程结束
从MQ消费消息
是
是否在timeout之前拿到连接？
否
更新status=3
Push_msg
请求localhost:8080
MQ.Msg.retryTime保持不变MQ.Msg.delayLevel不设置，也就是立即投递立即消费
httpcode=2xx?
push_log
步骤5
MQ
步骤2
重试逻辑
步骤3
Service
异常=TimeoutException?
HTTP执行器
提交给HTTPClient
queue
从队列里取
步骤6
status=1
ACK
推送系统
解析出请求的url:localhost:8080
落库
步骤1
HTTPClient
http响应
0 条评论
下一页
