Dubbo实现分布式日志链路追踪
技术场景
在日常的开发、测试或运维的过程中,经常存在这样的场景,开发人员在代码中使用日志工具(log4j、slf4j)记录日志,比如请求ID、IP等,方便在线上快速、精准的定位问题,通过完整的日志链路清晰的进行信息定位。
一般的项目都是分层的、分布式的,在众多的日志信息中,如何区分哪些日志信息是同一请求发出来的,详细的实现如下。
技术框架
项目框架:Spring boot
分布式协调:Zookeeper、Dubbo
日志工具:Sf4j
构建工具:Maven
开发工具:IDEA
项目框架
mdc-dubbo-api:接口服务
mdc-dubbo-provider:服务端服务
mdc-dubbo-consumer:消费端服务
项目配置
mdc-dubbo-api
提供一个接口
public interface OrderService {
String getOrder(String orderid);
}
mdc-dubbo-consumer
在服务端,在Controller层使用MDC工具类放入一个TRACE_LOG_ID信息,在此请求的service层、mdc-dubbo-provider中使用该信息。
项目分为Controller、Service、Filter等各层:
Controller层:存放TRACE_LOG_ID, 打印
@GetMapping("get/{id}")
public String get(@PathVariable("id") String id){
String uuid=UUID.randomUUID().toString().replaceAll("-", "");
MDC.put(Constants.TRACE_LOG_ID, uuid);
LOGGER.info("controller->param:{}", id);
return consumerService.getName(id);
}
Service层:打印TRACE_LOG_ID
@Override
public String getName(String id) {
LOGGER.info("consumer->service->param:{}", id);
return orderService.getOrder(id);
}
Filter:
public class TraceFilter implements Filter {
@Override
public Result invoke(Invoker> invoker, Invocation invocation) throws RpcException {
//从MDC中获取
String logId=MDC.get(Constants.TRACE_LOG_ID);
Map attachments=invocation.getAttachments();
attachments.put(Constants.TRACE_LOG_ID, logId);
return invoker.invoke(invocation);
}
需要过滤器配置在resources->MATE-INF->dobbo文件夹下
![过滤器配置
traceFilter=com.bestpay.provider.filter.TraceFilter
此处注意 此处使用到了Dubbo中spi机制,文件名必须是com.alibaba.dubbo.rpc.Filter
dubbo配置文件
xmlns:xsi=""
xmlns:dubbo=""
xsi:schemaLocation="
">
xmlns:xsi=""
xmlns:dubbo=""
xsi:schemaLocation="
">
其中filter="traceFilter是引用dobbo目录下配置中的key
logback配置
[%date{yyyy-MM-dd HH:mm:ss}] [%-5level] %logger %line --%mdc{client} [%X{TRACE_LOG_ID}] %msg%n
UTF-8
TRACE_LOG_ID对应放入MDC中的key
mdc-dubbo-provider
配置和## mdc-dubbo-consumer类似,其中在Filter上稍微有些差别
public class TraceFilter implements Filter {
@Override
public Result invoke(Invoker> invoker, Invocation invocation) throws RpcException {
String logId=invocation.getAttachment(Constants.TRACE_LOG_ID);
MDC.put(Constants.TRACE_LOG_ID, logId);
return invoker.invoke(invocation);
}
}
项目运行
mdc-dubbo-consumer日志:
[2018-12-19 10:16:56] [INFO ] com.bestpay.comsumer.controller.ConsumerController 33 – [d88ecba6581c47b1b3ade78d2821d13a] controller->param:223
[2018-12-19 10:16:56] [INFO ] com.bestpay.comsumer.service.impl.ComsumerServiceImpl 20 – [d88ecba6581c47b1b3ade78d2821d13a] consumer->service->param:223
mdc-dubbo-provider日志:
[2018-12-19 10:16:56] [INFO ] com.bestpay.provider.service.OrderServiceImpl 13 – [d8 provider->service->param:223
标签:Dubbo,LOG,TRACE,dubbo,mdc,链路,日志,ID From: https://www.cnblogs.com/dituirenwu/p/17064454.html