美文网首页dubboSpringFrameworkJava学习笔记
dubbo和spring mvc全局异常处理器实现

dubbo和spring mvc全局异常处理器实现

作者: cat昵称居然被占用了 | 来源:发表于2017-03-14 20:25 被阅读293次

    spring mvc 的全局异常处理器

    @ExceptionHandler
    当它在一个 controller 内部声明时,它将被用于那个controller(或它的子类)的 @RequestMapping方法抛出的异常. 你也可以在 @ControllerAdvice 类里面声明 @ExceptionHandler 方法,它将会处理很多controller的 @RequestMapping方法抛出的异常. 我的例子就是写一个异常处理类,其被@ControllerAdvice注解。
    例如:

    @ControllerAdvice
    public class BizExceptionFilter implements Filter {
      @ExceptionHandler(value = Exception.class)
      public Object handleIOException(Exception e){
        log.info("Catch exception", e);
        String exceptionName=e.getClass().getName();
        ResultExceptionInfoBean resultExceptionInfoBean=getInfoBean(exceptionName);
        FResponse rsp = new FResponse<Object>();
        rsp.setCode(resultExceptionInfoBean.getCode());
        rsp.setMessage(resultExceptionInfoBean.getMessage());
        rsp.setData(e);
        return rsp;
      }
    

    @ExceptionHandler 的value可以设置一个需要被处理的异常数组. 如果一个异常被抛出并且包含在这个异常列表中, 然后就会调用 @ExceptionHandler 方法. 如果没有设置value,
    那么就会使用参数里面的异常.
    和标准controller的 @RequestMapping 方法很相似, @ExceptionHandler 方法的参数值和返回值相当灵活. 比如说, HttpServletRequest 可以在 Servlet 环境中被接收, PortletRequest 在 Portlet 环境中被接收. 返回值可以是 String, 它将解释为一个视图, 可以是 ModelAndView 对象, 可以是 ResponseEntity 对象, 或者你可以添加 @ResponseBody 方法直接返回消息.

    dubbo的异常处理

    由于spring 的全局异常处理只能对http请求有效,所以对于dubbo的调用不起作用。

    那么为了实现对dubbo调用异常的处理,我们可以使用dubbo的拦截扩展.
    具体配置方式详见 API.
    将扩展方法写到spring 的全局异常处理器中,使其继承Filter,然后配置服务方调用拦截。
    当服务被调用时就会执行该方法。
    例如:

     @ControllerAdvice
    public class BizExceptionFilter implements Filter {
    
    @Override
    public Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {
        log.debug("BizExceptionFilter:{},{}", invoker.getInterface(),
        JsonUtil.jsonFromObject(invocation.getArguments()));
        Result result = invoker.invoke(invocation);
        Object realResult = result.getValue();
        FResponse rsp = new FResponse<Object>();
        if (result.hasException()) {
          try {
            ExceptionHandlerMethodResolver resolver=new   ExceptionHandlerMethodResolver(this.getClass());
            Exception exception=(Exception) result.getException();
            Method method=resolver.resolveMethod(exception);
            realResult = method.invoke(this, exception);
    
            return new RpcResult(realResult);
          } catch (Throwable e) {
            log.error("Exception handler error. Caused Exception:{}", result.getException());
          }
        }
        rsp.setCode("0000");
        rsp.setMessage("Success");
        rsp.setData(realResult);
        return new RpcResult(rsp);
        }
    
      @ExceptionHandler(value = NullPointerException.class)
      public Object handleIOException(NullPointerException e){
        log.info("Catch exception", e);
        String exceptionName=e.getClass().getName();
        ResultExceptionInfoBean resultExceptionInfoBean=getInfoBean(exceptionName);
        FResponse rsp = new FResponse<Object>();
        rsp.setCode(resultExceptionInfoBean.getCode());
        rsp.setMessage(resultExceptionInfoBean.getMessage());
        rsp.setData(e);
        return rsp;
      }
      @ExceptionHandler(value = IndexOutOfBoundsException.class)
      public Object handleIOException(IndexOutOfBoundsException e){
        log.info("Catch exception", e);
        String exceptionName=e.getClass().getName();
        ResultExceptionInfoBean resultExceptionInfoBean=getInfoBean(exceptionName);
        FResponse rsp = new FResponse<Object>();
        rsp.setCode(resultExceptionInfoBean.getCode());
        rsp.setMessage(resultExceptionInfoBean.getMessage());
        rsp.setData(e);
        return rsp;
      }
    

    解析:
    Result result = invoker.invoke(invocation);这行代码之前的代码,是在服务被调用钱执行,之后的代码是在服务被调用后执行。

    Object realResult = result.getValue();获得执行结果.

    result.hasException()是否抛出了异常.

    A912450C-D6D7-4E83-85E4-12034B2569B4.png 这段代码就是利用反射机制,获得当前的类的方法,然后调用该对象的有exception参数的方法,并将结果返回。

    2017-3-15 更新
    Exception exception=(Exception) result.getException(); 这行代码的作用是获得此类中被@ExceptionHandler注解的方法。
    Method method=resolver.resolveMethod(exception);这行代码的作用是从被@ExceptionHandler注解的所有方法中找出value为exception的方法对象。
    realResult = method.invoke(this, exception); 执行这个方法。
    如图:

    6D14283E-035B-443E-9FDA-276DA93643AB.png
    这样保持了和spring 的全局异常处理一致,即被@ExceptionHandler注解的方法去处理异常。
    spring 相关源码如下:
    Paste_Image.png

    测试:
    我在服务类中直接抛出了异常。

    8EB375E9-8266-4A82-BD85-0FD9BFEC085F.png

    顺利执行:

    CB3B887D-FB1D-432B-A9CA-150FE7E3E93C.png

    相关文章

      网友评论

        本文标题:dubbo和spring mvc全局异常处理器实现

        本文链接:https://www.haomeiwen.com/subject/xmtknttx.html