Dubbo抛出自定义异常

我就是我 2022-06-09 14:07 289阅读 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 {
        ...
    }

改动后，再次测试，问题解决！

**扩展阅读**：

浅谈dubbo的ExceptionFilter异常处理：[http://blog.csdn.net/mj158518/article/details/51228649][http_blog.csdn.net_mj158518_article_details_51228649]

[SouthEast]: /images/20220609/455fb25984af46eb983810e96ad559f1.png
[SouthEast 1]: /images/20220609/fa574c6dab1f4784baba4cfbd2340d07.png
[http_blog.csdn.net_mj158518_article_details_51228649]: http://blog.csdn.net/mj158518/article/details/51228649