Dubbo Filter 过滤器 —— 自定义异常过滤器（ExceptionFilter）

太过爱你忘了你带给我的痛 2022-09-08 11:55 243阅读 0赞

## 背景介绍 ##

许多项目中大家都会有一些自定义异常然后利用 **ExceptionHandler** 去做统一处理。  
在我们的项目中同样用到，详见：[SpringMVC之全局异常处理 ——统一返回格式][SpringMVC_]  
这种操作方式在常规项目使用中是没有任何问题的，但是当调用Dubbo接口时，**服务方(provider)** 抛出自定义异常，消费者拿到的却是一个 **RuntimeException** 并非我们自定义的异常类型。  
并且还会打印Error级别的日志：

> Got unchecked and undeclared exception which called by xxx.xxx.xxx.x. service: com.xxxx.xxx.service.xxxService, method: addxxx, exception: com.xxx.xxx.exception.xxxException: xxxxxxxxxxxx!, dubbo version: 2.7.4, current host: x.x.x.x

这对我们的日志监控报警系统非常不友好。  
鉴于以上情况我们需要 **重写** Dubbo的ExceptionFilter类，已达到我们想要的目的  
关于Dubbo Filter扫盲知识详见我的另一篇博客：[Dubbo Filter 过滤器（拦截器）的使用——dubbo.rpc.Filter][Dubbo Filter _dubbo.rpc.Filter]

## 重写ExceptionFilter ##

根据不同的版本 ExceptionFilter 具体代码也有所区别大家去找到对应的类拷贝出来修改即可。博主目前使用的版本是： **org.apache.dubbo 2.7.4**

package com.xxx.trace.rpc.filter;
    
    import java.lang.reflect.Method;
    import org.apache.dubbo.common.extension.Activate;
    import org.apache.dubbo.common.logger.Logger;
    import org.apache.dubbo.common.logger.LoggerFactory;
    import org.apache.dubbo.common.utils.ReflectUtils;
    import org.apache.dubbo.common.utils.StringUtils;
    import org.apache.dubbo.rpc.Invocation;
    import org.apache.dubbo.rpc.Invoker;
    import org.apache.dubbo.rpc.ListenableFilter;
    import org.apache.dubbo.rpc.Result;
    import org.apache.dubbo.rpc.RpcContext;
    import org.apache.dubbo.rpc.RpcException;
    import org.apache.dubbo.rpc.service.GenericService;
    
    /** * Dubbo 异常过滤器重写 */
    @Activate(
            group = { "provider"}
    )
    public class DubboExceptionFilter extends ListenableFilter { 
        public DubboExceptionFilter() { 
            super.listener = new DubboExceptionFilter.ExceptionListener();
        }
    
        public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException { 
            return invoker.invoke(invocation);
        }
    
        static class ExceptionListener implements Listener { 
            private Logger logger = LoggerFactory.getLogger(DubboExceptionFilter.class);
    
            ExceptionListener() { 
            }
    
            public void onResponse(Result appResponse, Invoker<?> invoker, Invocation invocation) { 
                if (appResponse.hasException() && GenericService.class != invoker.getInterface()) { 
                    try { 
                        Throwable exception = appResponse.getException();
                        if (exception instanceof RuntimeException || !(exception instanceof Exception)) { 
                            try { 
                                Method method = invoker.getInterface().getMethod(invocation.getMethodName(), invocation.getParameterTypes());
                                Class<?>[] exceptionClassses = method.getExceptionTypes();
                                Class[] var7 = exceptionClassses;
                                int var8 = exceptionClassses.length;
    
                                for(int var9 = 0; var9 < var8; ++var9) { 
                                    Class<?> exceptionClass = var7[var9];
                                    if (exception.getClass().equals(exceptionClass)) { 
                                        return;
                                    }
                                }
                            } catch (NoSuchMethodException var11) { 
                                return;
                            }
                            String serviceFile = ReflectUtils.getCodeBase(invoker.getInterface());
                            String exceptionFile = ReflectUtils.getCodeBase(exception.getClass());
    						// 新增代码块 Begin
                            if (exceptionFile != null && exception.getClass().getName().startsWith("com.xxx")) { 
                                //判断异常类如果是com.xxx开头则属于自定义业务异常，无需额外处理，直接return 消费者拿到的就是 服务提供者锁抛出的异常
                                this.logger.info("DubboExceptionFilter 业务校验异常:" + exception.getMessage());
                                return;
                            }
    						// 新增代码块 end
    						
                            this.logger.error("Got unchecked and undeclared exception which called by " + RpcContext.getContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + exception.getClass().getName() + ": " + exception.getMessage(), exception);
    
                            if (serviceFile != null && exceptionFile != null && !serviceFile.equals(exceptionFile)) { 
                            // 因为这里有判断!serviceFile.equals(exceptionFile) 所以新增代码如果写在这里有一定的风险会导致此处无法进入该IF内部
                                String className = exception.getClass().getName();
                                if (!className.startsWith("java.") && !className.startsWith("javax.")) { 
                                    if (!(exception instanceof RpcException)) { 
                                        appResponse.setException(new RuntimeException(StringUtils.toString(exception)));
                                    }
                                }
                            }
                        }
                    } catch (Throwable var12) { 
                        this.logger.warn("Fail to ExceptionFilter when called by " + RpcContext.getContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + var12.getClass().getName() + ": " + var12.getMessage(), var12);
                    }
                }
            }
    
            public void onError(Throwable e, Invoker<?> invoker, Invocation invocation) { 
                this.logger.error("Got unchecked and undeclared exception which called by " + RpcContext.getContext().getRemoteHost() + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName() + ", exception: " + e.getClass().getName() + ": " + e.getMessage(), e);
            }
    
            public void setLogger(Logger logger) { 
                this.logger = logger;
            }
        }
    }

然后在resources目录下新建META-INF文件夹，然后建立子文件夹dubbo,最后新建文件com.alibaba.dubbo.rpc.Filter。（敲黑板划重点拉！这里不要弄错了）  
在文件中新增：**dubboExceptionFilter**=com.xxx.trace.rpc.filter.DubboExceptionFilter  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA6Z-t6Z-t6Z-t6Z-t6I-c_size_33_color_FFFFFF_t_70_g_se_x_16]

*  dubboExceptionFilter ：就是你给这个过滤器取的名称
 *  com.xxx.trace.rpc.filter.DubboExceptionFilter：过滤器对应的路径

## 过滤器配置 ##

在大家各自的 **dubbo-provider.xml** 中新增该过滤器即可，多个过滤器可以以英文逗号 “ **,** ” 隔开。

<dubbo:provider filter="traceId,dubboExceptionFilter,-exception" version="${dubbo.provider.version:1.0}"/>

细心的朋友可能发现我在过滤器配置中还加了 **-exception** ，这是因为如果不加上 **-exception** 我们的过滤器确实生效了，但是Dubbo自身默认的 **ExceptionFilter** 任然在工作（一个异常抛出会依次进入两个过滤器），所以我们需要 **禁用** 掉默认的过滤器。 这一点是网上许多博客都没有说明的，请大家务必记住！！！  
同理，如果我们想禁用其它的过滤器，都可以通过 **-过滤器名称**来实现。

[SpringMVC_]: https://blog.csdn.net/zhibo_lv/article/details/83146347
[Dubbo Filter _dubbo.rpc.Filter]: https://blog.csdn.net/zhibo_lv/article/details/104796122
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_Q1NETiBA6Z-t6Z-t6Z-t6Z-t6I-c_size_33_color_FFFFFF_t_70_g_se_x_16]: /images/20220829/a4e461f5c61148ac981b09ca6ec6d3b0.png