您的位置:首页 > 其它

Dubbo抛出自定义异常

2017-09-07 13:40 369 查看
问题描述:

在使用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类)后发现了以下这段代码:



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

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



再回到之前公共异常处理方法,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
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  Dubbo RuntimeException