服务d
根据应用查询
new MyTransfer()
服务A
《include》
根据traceId查询
服务B
服务c
loadClass()
注册
new Class()
发送报警信息
ClassLoader
KafkaAppender
+kafkaClient:KafkaProducerClient+appName:String+kafkaHosts:String+threadPoolSize:int+maxCount:int
+append(LoggingEvent)+close()
TraceID: XXXSpanID: 0006p-SpanID:0003
根据traceID查询
登录
addTransformer()
warn
+userId:long+applicationId:long+methodId:long+
DB
存储数据至ES
报警模块
敏感信息加密
批量异步发送
登记报警配置
日志存储
发送日志
服务C
TraceID: XXXSpanID: 0002p-SpanId:0001
服务e
TraceID: XXXSpanID: 0005p-SpanID:0002
extends
根据采样率采集
application
+appName:string+owner:string+level:int
post_class_file_load_hook
服务b
Agent
生成链路ID
服务D
method
+methodName+applicationId:long+warnLevel:int+warnWay:int
根据日志级别查询
TraceID: XXXSpanID: 0003p-SpanID:0001
拦截请求
登录模块
transform
KafkaLogCollect
+collectRuningLog()+kafkaStart()
报警
服务a
组装参数
查询模块
TraceID: XXXSpanID: 0001p-SpanID:null
JVMTI_EVENT_CLASS_FILE_LOAD_HOOK
日志查询
MyTranster
HDFS
byte[] newClassBytes
获取关键信息
TraceID: XXXSpanID: 0004p-SpanID:0002
User
+userName:string+passoword:string+phoneNumer:string+dingtalkId:string+mail :string
写入链路ID
用户请求
mq
日志发送
降级措施
日志采集
服务f
配置采样率
BaseLogCollect
+logger:Logger+threadPoolExecutor:ThreadPoolExecutor+elasticLowerClient:ElasticLowerClient+applicationEventPublisher:ApplicationEventPublisher
+getRunLogIndex():string+getTraceLogIndex()+publisherMonitorEvent()
消费采集端消息
