背景介绍 许多项目中大家都会有一些自定义异常然后利用 ExceptionHandler 去做统一处理。
在我们的项目中同样用到，详见：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
重写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;
}
// 新增代码块 endthis.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
文章图片
- dubboExceptionFilter ：就是你给这个过滤器取的名称
- com.xxx.trace.rpc.filter.DubboExceptionFilter：过滤器对应的路径
【工作|Dubbo Filter 过滤器 —— 自定义异常过滤器（ExceptionFilter）】细心的朋友可能发现我在过滤器配置中还加了 -exception ，这是因为如果不加上 -exception 我们的过滤器确实生效了，但是Dubbo自身默认的 ExceptionFilter 任然在工作（一个异常抛出会依次进入两个过滤器），所以我们需要 禁用 掉默认的过滤器。 这一点是网上许多博客都没有说明的，请大家务必记住！！！
同理，如果我们想禁用其它的过滤器，都可以通过 -过滤器名称来实现。
推荐阅读
- Spring|Spring-Cloud-Alibaba笔记01-关于远程调用Dubbo
- 生活艺术|无题
- 生活|大学开学的第一天——计算机达人成长之路（32）
- RabbitMQ|消息中间件RabbitMQ（五）——实现RPC调用
- 嵌入式开发|键盘驱动程序的修改