Dubbo抛出自定义异常-蒲公英云

Dubbo抛出自定义异常

我就是我 2022-06-09 14:07 496阅读 0赞

问题描述:

在使用Dubbo分布式框架开发时，自定义了异常，但是在测试时发现，该异常没有正常抛出！代码骨架如下：

// Controller层
public Object apply(ModelMap modelMap) {
    ...
    return super.execute(modelMap, getService(), "apply", ...);
}
// 接口
public interface CommonProvider {
    CommonResponse execute(CommonParameter parameter) throws BaseException;
}
// 接口实现
public CommonResponse execute(CommonParameter parameter) throws BaseException {
    ...
}
// Service层
public void apply(String uid) throws ServiceInvokeException {
    ...
    if (xxxx == null) {
        throw new ServiceInvokeException(HttpCode.BAD_REQUEST);
    }
    ...
}

在Controller层有个apply方法，该方法通过CommonProvider接口调用了execute方法，进而调用Service层的apply方法。在service层中，抛出自定义异常ServiceInvokeException，该异常继承了BaseException，如下：

// 自定义异常
public class ServiceInvokeException extends BaseException {
    ....
}

公共的异常处理如下：

/** 异常处理 */
@ExceptionHandler(Exception.class)
public void exceptionHandler(HttpServletRequest request, HttpServletResponse response, Exception ex) throws Exception {
    if (ex instanceof IllegalParameterException) {
        ((IllegalParameterException) ex).handler(modelMap);
    } else if (ex instanceof BaseException) {
        ((BaseException) ex).handler(modelMap);
    } else if (ex instanceof IllegalArgumentException) {
        new IllegalParameterException(ex.getMessage()).handler(modelMap);
    } else {
        modelMap.put("code", HttpCode.INTERNAL_SERVER_ERROR.value());
        String msg = StringUtils.defaultIfBlank(ex.getMessage(), HttpCode.INTERNAL_SERVER_ERROR.msg());
        modelMap.put("message", msg.length() > 100 ? "系统错误,请稍候再试." : msg);
    }
    ...
    response.getOutputStream().write(bytes);
}

按照逻辑，我在方法中抛出了自定义异常ServiceInvokeException，而这个异常是BaseException的子类（ex instanceof BaseException为true），代码应该进入else if分支，但最终结果却到了最后的else中，也就是ex instanceof BaseException为false！启动调试后，发现，ex并不是预想的ServiceInvokeException，而是RuntimeException！为什么会这样呢？

查看Dubbo源码（com.alibaba.dubbo.rpc.filter.ExceptionFilter类）后发现了以下这段代码：

SouthEast

通过打断点调试后发现，在这里时，exception.getClass()得到的结果是xxx.xxx.ServiceInvokeException，但是exceptionClass却是xxx.xxx.BaseException，而两者是通过equals比较的，结果为false！

再往下看，在前面各种结果条件都不满足时，Dubbo将该异常封装成了一个RuntimeException，将错误堆栈放入了message中！

SouthEast 1

再回到之前公共异常处理方法，ex是RuntimeException，instanceof BaseException时就是false了！

理解了怎么自定义异常怎么变成RuntimeException，以及Dubbo的源码如何处理异常后（通过equals严格比较，即使是父类也不可以），就可以修改错误了：

在接口和实现处，将自定义的异常给抛出来：

// 接口
public interface CommonProvider {
    CommonResponse execute(CommonParameter parameter) throws ServiceInvokeException, BaseException;
}
// 接口实现
public CommonResponse execute(CommonParameter parameter) throws ServiceInvokeException, BaseException {
    ...
}