MQ监听器接收到http通讯异常日志,调用通道降级服务,并将日志传给日志中心
线程池异步捞取内存队列中的日志,并批量发送给MQ
Redis
Worker
MsgProducer
+run()
内存队列 | | | | | |
QualityService
ReportInfo
+onHttpFail()+getDowngraded()
MsgListener
+ onHttpFail()
Reporter
LinkedBlockingQueueExecutorService
+ httpFail()
根据降级规则(LUA脚本),计算通道是否满足降级条件
HttpUtil
+postOnceWithMonitor()+postRetryWithMonitor()