个人中心
gpt4 book ai didi

Dubbo实现分布式日志链路追踪

转载 作者：qq735679552 更新时间：2022-09-29 22:32:09 25 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章Dubbo实现分布式日志链路追踪由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

技术场景

在日常的开发、测试或运维的过程中，经常存在这样的场景，开发人员在代码中使用日志工具（log4j、slf4j）记录日志，比如请求ID、IP等，方便在线上快速、精准的定位问题，通过完整的日志链路清晰的进行信息定位.

一般的项目都是分层的、分布式的，在众多的日志信息中，如何区分哪些日志信息是同一请求发出来的，详细的实现如下.

技术框架

项目框架：Spring boot 。

分布式协调：Zookeeper、Dubbo 。

日志工具：Sf4j 。

构建工具：Maven 。

开发工具：IDEA 。

项目框架

Dubbo实现分布式日志链路追踪

mdc-dubbo-api：接口服务 。

mdc-dubbo-provider：服务端服务 。

mdc-dubbo-consumer：消费端服务 。

项目配置

mdc-dubbo-api

提供一个接口 。

?
1
2
3
public interface OrderService {
String getOrder(String orderid);
}

mdc-dubbo-consumer

在服务端，在Controller层使用MDC工具类放入一个TRACE_LOG_ID信息，在此请求的service层、mdc-dubbo-provider中使用该信息.


Dubbo实现分布式日志链路追踪

项目分为Controller、Service、Filter等各层:

Controller层：存放TRACE_LOG_ID， 打印 。

?
1
2
3
4
5
6
7
@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 。

?
1
2
3
4
5
@Override
     public String getName(String id) {
         LOGGER.info( "consumer->service->param:{}" , id);
         return orderService.getOrder(id);
     }

Filter:

?
1
2
3
4
5
6
7
8
9
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<String, String> attachments = invocation.getAttachments();
         attachments.put(Constants.TRACE_LOG_ID, logId);
         return invoker.invoke(invocation);
     }

需要过滤器配置在resources->MATE-INF->dobbo文件夹下 。

![过滤器配置https://img-blog.csdnimg.cn/20181219100406136.png) 。

traceFilter=com.bestpay.provider.filter.TraceFilter 。

此处注意 此处使用到了Dubbo中spi机制，文件名必须是com.alibaba.dubbo.rpc.Filter 。

dubbo配置文件 。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
<? xml version = "1.0" encoding = "UTF-8" ?>
< beans xmlns = "http://www.springframework.org/schema/beans"
        xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
        xmlns:dubbo = "http://code.alibabatech.com/schema/dubbo"
        xsi:schemaLocation="http://www.springframework.org/schema/beans
        http://www.springframework.org/schema/beans/spring-beans.xsd
        http://code.alibabatech.com/schema/dubbo
        http://code.alibabatech.com/schema/dubbo/dubbo.xsd">
     <!--过滤器配置-->
    <!-- <dubbo:provider filter="traceFilter" />-->
     <!-- 应用名-->
     < dubbo:application name = "dmc-dubbo-provider" />
     <!--zookeeper注册中心-->
     < dubbo:registry address = "zookeeper://127.0.0.1:2181" />
 
     < dubbo:protocol name = "dubbo" port = "20880" />
     <!--服务注册-->
     < dubbo:service interface = "com.bestpay.service.OrderService" ref = "orderService" timeout = "10000" ** filter = "traceFilter" **/>
     < bean id = "orderService" class = "com.bestpay.provider.service.OrderServiceImpl" />
 
</ beans >

其中filter="traceFilter是引用dobbo目录下配置中的key 。

logback配置 。

?
1
2
3
4
5
6
7
<appender name= "STDOUT" class = "ch.qos.logback.core.ConsoleAppender" >
     <encoder>
         <pattern>[%date{yyyy-MM-dd HH:mm:ss}] [%-5level] %logger %line --%mdc{client} [%X{TRACE_LOG_ID}] %msg%n</pattern>
         <!-- 控制台也要使用UTF- 8 ，不要使用GBK，否则会中文乱码 -->
         <charset>UTF- 8 </charset>
     </encoder>
</appender>

TRACE_LOG_ID对应放入MDC中的key 。

mdc-dubbo-provider 。

配置和## mdc-dubbo-consumer类似，其中在Filter上稍微有些差别 。

?
1
2
3
4
5
6
7
8
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 – [d88ecba6581c47b1b3ade78d2821d13a] provider->service->param:223 。

以上，完成了dubbo分布式服务之间日志的完整链路。为个人经验，希望能给大家一个参考，也希望大家多多支持我.

原文链接：https://blog.csdn.net/weixin_39178876/article/details/85088410 。

最后此篇关于Dubbo实现分布式日志链路追踪的文章就讲到这里了,如果你想了解更多关于Dubbo实现分布式日志链路追踪的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

25 4 0
文章推荐： python入门while循环语句理解学习
文章推荐： Python中的函数参数(位置参数、默认参数、可变参数)
文章推荐： Java日常练习题,每天进步一点点(37)
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
全站热门文章
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com