目前的项目,远程服务调用全部都是基于dubbo,有的是部门内部互相调用,有的是调用其他部门的服务。由于业务里面涉及到远程调用服务的地方比较多,目前调用每个服务的时候都要手动写打印入参、响应和异常,比较麻烦。
现在对这块进行优化,目的是实现自动打印入参、响应和异常,从而避免每个服务都要手动写重复的代码。
新建包
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; } }
新建目录和文件: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"/>
自带的accesslog配置,只打印入参,且只在服务提供者打印入参。
如果有accesslog配置,则去掉,避免打印重复日志。
1.dubbo有自带的异常拦截器,使用默认的自带的异常拦截器即可,不做改动。
2.如果需要在异常日志里打印特殊信息(比如,定位是哪一笔订单异常),也可以捕获异常,并且打印日志。
http://dubbo.apache.org/zh-cn...