dubbo-自定义日志拦截器
背景
目前的项目，远程服务调用全部都是基于dubbo，有的是部门内部互相调用，有的是调用其他部门的服务。由于业务里面涉及到远程调用服务的地方比较多，目前调用每个服务的时候都要手动写打印入参、响应和异常，比较麻烦。
现在对这块进行优化，目的是实现自动打印入参、响应和异常，从而避免每个服务都要手动写重复的代码。
实现
1.实现过滤器
新建包
XXX.solid.filter //以filter结尾
新建类-自定义服务消费者日志拦截器
package XXX.solid.filter;
import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.*;
import com.alibaba.dubbo.rpc.service.GenericService;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
/**
* 服务消费者日志拦截器，作用是打印dubbo调用的入参和响应
* @author gongzhihao
*/
@Slf4j
@Activate(group = {Constants.CONSUMER})
public class LogDubboConsumerFilter implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
//打印入参
log.info("dubbo入参，InterfaceName={},MethodName={},Parameter={}", invocation.getInvoker().getInterface().getName(), invocation.getMethodName(), invocation.getArguments());
//开始时间
long startTime = System.currentTimeMillis();
//执行接口调用逻辑
Result result = invoker.invoke(invocation);
//调用耗时
long elapsed = System.currentTimeMillis() - startTime;
//如果发生异常，则打印异常日志
if (result.hasException() && invoker.getInterface() != GenericService.class) {
// log.error("dubbo执行异常: ", result.getException());
log.error("dubbo执行异常！！！");
} else {
log.info("dubbo响应，InterfaceName={},MethodName={},Resposne={},SpendTime={} ms", invocation.getInvoker().getInterface().getName(), invocation.getMethodName(), JSON.toJSONString(new Object[]{result.getValue()}), elapsed);
}
//返回结果响应数据
return result;
}
}
新建类-自定义服务提供者日志拦截器
package XXX.solid.filter;
import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.rpc.*;
import com.alibaba.dubbo.rpc.service.GenericService;
import com.alibaba.fastjson.JSON;
import lombok.extern.slf4j.Slf4j;
/**
* 服务提供者日志拦截器，作用是打印dubbo调用的入参和响应
* @author gongzhihao
*/
@Slf4j
@Activate(group = { Constants.PROVIDER })
public class LogDubboProviderFilter implements Filter {
@Override
public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
//打印入参
log.info("dubbo入参，InterfaceName={},MethodName={},Parameter={}", invocation.getInvoker().getInterface().getName(), invocation.getMethodName(), invocation.getArguments());
//开始时间
long startTime = System.currentTimeMillis();
//执行接口调用逻辑
Result result = invoker.invoke(invocation);
//调用耗时
long elapsed = System.currentTimeMillis() - startTime;
//如果发生异常，则打印异常日志
if (result.hasException() && invoker.getInterface() != GenericService.class) {
// log.error("dubbo响应，dubbo执行异常: ", result.getException());
log.error("dubbo执行异常！！！");
} else {
log.info("dubbo响应，InterfaceName={},MethodName={},Response={},SpendTime={} ms", invocation.getInvoker().getInterface().getName(), invocation.getMethodName(), JSON.toJSONString(new Object[]{result.getValue()}), elapsed);
}
//返回结果响应数据
return result;
}
}
2.配置
新建目录和文件：META-INF/dubbo/org.apache.dubbo.rpc.Filter
添加配置内容：
logDubboProviderFilter=XXX.solid.filter.LogDubboProviderFilter logDubboConsumerFilter=XXX.solid.filter.LogDubboConsumerFilter
注：如果不生效，配置以下内容
1.springboot项目
application.properties
dubbo.provider.filter=logDubboProviderFilter dubbo.consumer.filter=logDubboConsumerFilter
2.spring项目
<dubbo:provider filter="logDubboProviderFilter"/>
<dubbo:consumer retries="0" timeout="60000" loadbalance="roundrobin" actives="0"
validation="false" filter="logDubboConsumerFilter"/>
关闭dubbo自带的日志拦截器
自带的accesslog配置，只打印入参，且只在服务提供者打印入参。
如果有accesslog配置，则去掉，避免打印重复日志。
异常
1.dubbo有自带的异常拦截器，使用默认的自带的异常拦截器即可，不做改动。
2.如果需要在异常日志里打印特殊信息(比如，定位是哪一笔订单异常)，也可以捕获异常，并且打印日志。
参考
http://dubbo.apache.org/zh-cn...
正文到此结束
热门推荐
相关文章
近期评论
-
666
-
文章和留言都翻到11页了 没有OOM
-
-
朋友，翻页到11页，及以后，会出现OOM，无法访问
-
-
-
-
版本号是多少，你可以下载哪个代码仓库，jdk选1.8 直接跑就行
-
-
Loading...
![[HBLOG]公众号](https://www.liuhaihua.cn/img/qrcode_gzh.jpg)
