Dubbo的异常处理

Stella981
• 阅读 779

最近在整Dubbo的框架,使用zookeeper做注册中心,项目中有service层作为provider(提供者),web层作为consumer(消费者),当在做自定义异常的抛出时,遇到了问题:

1、web层不能识别异常为自定义异常类型,异常类型为RuntimeException。

2、当修改识别类型为RuntimeException时,从异常当中获取到的message,多出了一大堆异常堆栈的信息。

就这两个问题,在网上搜索了很多资料,大部分都把Dubbo中的ExceptionFilter代码贴出来,然后分析逻辑,这里也将代码贴一下(以下是改过之后的代码,因为最终我选用了改源码的形式解决问题。)。

/*
 * Copyright 1999-2011 Alibaba Group.
 *  
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *  
 *      http://www.apache.org/licenses/LICENSE-2.0
 *  
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package com.alibaba.dubbo.rpc.filter;

import java.lang.reflect.Method;

import com.alibaba.dubbo.common.Constants;
import com.alibaba.dubbo.common.extension.Activate;
import com.alibaba.dubbo.common.logger.Logger;
import com.alibaba.dubbo.common.logger.LoggerFactory;
import com.alibaba.dubbo.common.utils.ReflectUtils;
import com.alibaba.dubbo.common.utils.StringUtils;
import com.alibaba.dubbo.rpc.Filter;
import com.alibaba.dubbo.rpc.Invocation;
import com.alibaba.dubbo.rpc.Invoker;
import com.alibaba.dubbo.rpc.Result;
import com.alibaba.dubbo.rpc.RpcContext;
import com.alibaba.dubbo.rpc.RpcException;
import com.alibaba.dubbo.rpc.RpcResult;
import com.alibaba.dubbo.rpc.service.GenericService;

/**
 * ExceptionInvokerFilter
 * <p>
 * 功能:
 * <ol>
 * <li>不期望的异常打ERROR日志(Provider端)<br>
 * 不期望的日志即是,没有的接口上声明的Unchecked异常。
 * <li>异常不在API包中,则Wrap一层RuntimeException。<br>
 * RPC对于第一层异常会直接序列化传输(Cause异常会String化),避免异常在Client出不能反序列化问题。
 * </ol>
 *
 * @author william.liangf
 * @author ding.lid
 */
@Activate(group = Constants.PROVIDER)
public class ExceptionFilter implements Filter {

    private final Logger logger;

    public ExceptionFilter() {
        this(LoggerFactory.getLogger(ExceptionFilter.class));
    }

    public ExceptionFilter(Logger logger) {
        this.logger = logger;
    }

    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        try {
            Result result = invoker.invoke(invocation);
            if (result.hasException() && GenericService.class != invoker.getInterface()) {
                try {
                    Throwable exception = result.getException();

                    // 如果是checked异常,直接抛出
                    if (!(exception instanceof RuntimeException) && (exception instanceof Exception)) {
                        return result;
                    }
                    // 在方法签名上有声明,直接抛出
                    try {
                        Method method = invoker.getInterface().getMethod(invocation.getMethodName(), invocation.getParameterTypes());
                        Class<?>[] exceptionClassses = method.getExceptionTypes();
                        for (Class<?> exceptionClass : exceptionClassses) {
                            if (exception.getClass().equals(exceptionClass)) {
                                return result;
                            }
                        }
                    } catch (NoSuchMethodException e) {
                        return result;
                    }

                    // 未在方法签名上定义的异常,在服务器端打印ERROR日志
                    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);

                    // 异常类和接口类在同一jar包里,直接抛出
                    String serviceFile = ReflectUtils.getCodeBase(invoker.getInterface());
                    String exceptionFile = ReflectUtils.getCodeBase(exception.getClass());
                    if (serviceFile == null || exceptionFile == null || serviceFile.equals(exceptionFile)) {
                        return result;
                    }
                    // 是JDK自带的异常,直接抛出
                    String className = exception.getClass().getName();
                    if (className.startsWith("java.") || className.startsWith("javax.")) {
                        return result;
                    }
                    if (className.startsWith("******") ||  className.startsWith("******")) {
                        logger.debug("===========自定义异常,直接抛出===========");
                        return result;
                    }
                    
                    // 是Dubbo本身的异常,直接抛出
                    if (exception instanceof RpcException) {
                        return result;
                    }
                    
                    // 否则,包装成RuntimeException抛给客户端
                    return new RpcResult(new RuntimeException(StringUtils.toString(exception)));
                } catch (Throwable e) {
                    logger.warn("Fail to ExceptionFilter when called by " + RpcContext.getContext().getRemoteHost()
                            + ". service: " + invoker.getInterface().getName() + ", method: " + invocation.getMethodName()
                            + ", exception: " + e.getClass().getName() + ": " + e.getMessage(), e);
                    return result;
                }
            }
            return result;
        } catch (RuntimeException e) {
            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);
            throw e;
        }
    }

}

其中的

if (className.startsWith("******") ||  className.startsWith("******")) {
    logger.debug("===========自定义异常,直接抛出===========");
    return result;
}

这一部分是我自己新添的代码,其中的**********是我们项目内部的自定义异常的包名,为项目保密在这里以******代替。

关于这里面的逻辑,在这里我就不过多赘述,注释都写的很清楚了。

而出现我所说的1和2两个情况,是在这段代码中,并没有检测自定义异常,甚至RuntimeException。

而是直接将不符合条件的异常全部进行了RuntimeException的包装。

                    // 否则,包装成RuntimeException抛给客户端
                    return new RpcResult(new RuntimeException(StringUtils.toString(exception)));

注意这里的StringUtils.toString。就是这个操作,将本来就几个字的message,直接给整成了一大堆带异常堆栈的信息。

这里要说明一下,为什么要贴出来ExceptionFilter的代码,因为provider抛出异常后,经过dubbo,然后在consumer捕获异常时,进行了异常的反序列化,ExceptionFilter负责的就是将异常还原包装。

所以,看到这里,问题就很明确了:

1、ExceptionFilter并不认识我自定义的异常。

2、ExceptionFilter没有检测RuntimeException异常(我的自定义异常继承了RuntimeException)。

依照ExceptionFilter的逻辑,解决办法有以下几种:

1、 将该异常的包名以"java.或者"javax. " 开头,但自己的项目都有自己特定的包名,所以弃用。

2、使用受检异常(继承Exception),继承根Exception,鬼知道会出现其他什么BUG,pass。

3、 把自定义异常放到provider的api模块中,每个api都定义自定义异常的话,平白增加了很多工作量,pass。

4、 provider实现GenericService接口,查了很多资料,也看到有人使用了这种方法,要弃用$invoke方法,最终也没有成功,懒惰的我也就没去试,有兴趣的朋友可以试试,然后跟我说说是个什么情况(我得懒到什么程度)。

5、provider的api明确写明抛出的异常,我连自定义异常放到api里面都懒得做,你让我每个接口都写抛出异常?开个玩笑。弃用这种方法的原因有三:1)在做这个异常处理的时候,已经完成了一部分代码了,要加抛出异常,是个不小的工作量。2)抛出的自定义异常只为了中止代码执行,返回给前台做消息提示,所以不涉及到业务的处理。3)添加抛出异常,增加了开发的工作量,也会影响到开发时专注于业务处理的初衷。

6、让ExceptionFilter支持自定义异常,修改源码使之直接抛出自定义异常。这种解决办法无疑是工作量最小,影响最小的了。但这其中也有一个隐患,如果要进行dubbo的版本更新的话,就必须将新的版本的ExceptionFilter也去修改。在此希望Dubbo能够支持配置自定义的ExceptionFilter。

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
3个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
梦
3年前
微信小程序new Date()转换时间异常问题
微信小程序苹果手机页面上显示时间异常,安卓机正常问题image(https://imghelloworld.osscnbeijing.aliyuncs.com/imgs/b691e1230e2f15efbd81fe11ef734d4f.png)错误代码vardate'2021030617:00:00'vardateT
Stella981 Stella981
3年前
Spring Cloud Feign 异常处理
问题最近在项目开发中,使用Feign调用服务,当触发熔断机制时,遇到了以下问题:异常信息形如:TestServiceaddRecord(ParamVO)failedandnofallbackavailable.;获取不到服务提供方抛出的原始异常信息;实现某些业务方法不进入熔断,直接往外抛出异常;
Wesley13 Wesley13
3年前
03.Android崩溃Crash库之ExceptionHandler分析
目录总结00.异常处理几个常用api01.UncaughtExceptionHandler02.Java线程处理异常分析03.Android中线程处理异常分析04.为何使用setDefaultUncaughtExceptionHandler前沿上一篇整体介绍了crash崩溃
Wesley13 Wesley13
3年前
初探 Objective
作者:Cyandev,iOS和MacOS开发者,目前就职于字节跳动0x00前言异常处理是许多高级语言都具有的特性,它可以直接中断当前函数并将控制权转交给能够处理异常的函数。不同语言在异常处理的实现上各不相同,本文主要来分析一下ObjectiveC和C这两个语言。为什么要把ObjectiveC和
Wesley13 Wesley13
3年前
Java异常
异常分为两种:Exception、ErrorException:异常,可以捕捉到,进行处理以后可以让程序继续正常执行Error:错误,不能捕捉,只能修改代码,重新执行ThrowableException(RuntimeException非运行时异常)throw:抛出指定的异常throws:用在方法声明处,声明该方法可能发生
Wesley13 Wesley13
3年前
Java异常情况
从网上了解了这些Java异常,遇到过一些,大部分还没遇到:1、SQLException:操作数据库异常类。2、ClassCastException:数据类型转换异常。3、NumberFormatException:字符串转换为数字类型时抛出的异常。4、java.lang.NullPointerException  异常的解释是"程
Wesley13 Wesley13
3年前
Java异常架构
Java异常简介Java异常是Java提供的一种识别及响应错误的一致性机制。Java异常机制可以使程序中异常处理代码和正常业务代码分离,保证程序代码更加优雅,并提高程序健壮性。在有效使用异常的情况下,异常能清晰的回答what,where,why这3个问题:异常类型回答了“什么”被抛出,异常堆栈跟踪回答了“在哪“抛出,异常信息