springcloud断路器异常处理

最近团队从dubbo切换到springcloud，自己碰到的一些问题，特别是这个很常见的调用异常，做一些分析。

springcloud 微服务框架有各种组件，可以搭建一个完整的微服务应用。包括

• 注册 中心：eureka 或者 consul

• 服务提供者：各种 provider

• 服务消费者：各种 consumer

• 网 关：zuul

这里一定会碰到的问题就是, consumer 调用 provider, provider 内部出现异常了，consumer 如何拿到具体的异常信息并且返回给页面。

为什么要返回具体的异常信息？

异常不具体的话，什么都是提示服务器异常，那说了等于没说，谁特么不知道是服务器异常。如果提示具体信息的话，比如订单号已存在，订单不存在，扣费失败，sku不存在，一眼就可以定位到问题在哪里，不用去翻日志找半天。
现成的方案就是使用 hystrix 断路器的功能

image.png

断路器的使用 :

1 设置 fallback

@FeignClient(name = ProviderServiceName.SERVICE_NAME, fallbackFactory=CommentServiceFallbackFactory.class)
public interface CommentService extends CommentBridge {

    //现在测试 调用这个方法，provider出现异常
    @PostMapping(value="/save")
    void save(@RequestBody Comment comment);
}

save 方法没有返回值说明:

对于这种可以没有返回值的方法调用，有些人认为要加上返回值 response, 然后在消费者的代码里面来判断返回值是否成功。其实大可不必，微服务之间的调用也是服务调用，相当于调用一个方法而已，没有抛出异常就可以认为是执行成功的，有异常的话都程序停止执行，事务回滚了。为什么还要加 response, 在里面搞一个所谓的 状态码来判断呢，它是微服务，你却把它当成 http rest 接口来使用,它有的功能你不用，这完全就是没有领会微服务的概念。

2 编写 fallback 类

@Component
@Slf4j
public class CommentServiceFallbackFactory implements feign.hystrix.FallbackFactory<CommentService> {
    
    @Override
    public CommentService create(Throwable cause) {
        //cause是调用时出现的异常信息
        final String message = cause.getMessage();
        return new CommentService() {
            @Override
            public Page<Comment> page(CommentParameter parameter) {
                return null;
            }
            
            @Override
            public void save(Comment comment) {
                log.error("进程pid: " + ManagementFactory.getRuntimeMXBean().getName());
                log.error("线程: " + Thread.currentThread().getName());

                //这里抛出异常尝试消费者的全局异常处理器捕获
                throw new BizException(message);
            }
        };
    }
}

3 尝试捕获 BizException(message)

@Component
@Slf4j
public class GlobalExceptionHandler implements HandlerExceptionResolver, Ordered {
    
    private static final String ERROR_MESSAGE = "服务器挂掉了";
    
    @Override
    public int getOrder() {
        return 0;
    }
    
    @ResponseBody
    @Nullable
    @Override
    public ModelAndView resolveException(HttpServletRequest request,HttpServletResponse response,
                                         @Nullable Object handler, Exception ex) {
        log.error("进程pid: " + ManagementFactory.getRuntimeMXBean().getName());
        log.error("线程: " + Thread.currentThread().getName());
    }
}

4 服务提供者里面直接抛异常

@RestController
public class CommentProviderController implements CommentBridge {
    
    @Resource
    private CommentRepository commentRepository;

    @Override
    public void save(Comment comment) {
        throw new BizException("provider service 抛出的异常");
    }

经过测试，CommentServiceFallbackFactory 的 save 方法抛出的异常是无法被捕获器捕获到的，这样就没法通过 fallback 方法去控制异常的展示，返回。

消费者无法捕获断路器里面抛出的异常是因为这是2个不同的线程，不同线程之间的异常是不会互相影响的，上面那个是断路器处理回滚的线程，下面那个是很典型的 servlet 线程.png

如果按照上面的方式来使用断路器的话，这种使用方式完全是不可用的，一个是 每个服务类里面要配置 fallbackFactory ，有多少个服务类就要对应的写多少个回滚类，写到你吐血。第二个是断路器里面拿到的 provider 的异常信息，如何传递给消费者，可以考虑用线程的等待通知机制，但是这么玩就不是微服务了。

现在有2种方式可以让具体的异常信息逐级上报，返回给页面

1 全局异常处理里面解析捕获到的异常信息，直接返回到页面

@Component
@Slf4j
public class GlobalExceptionHandler implements HandlerExceptionResolver, Ordered {
    
    private static final String ERROR_MESSAGE = "服务器挂掉了";
    
    @Override
    public int getOrder() {
        return 0;
    }
    
    @ResponseBody
    @Nullable
    @Override
    public ModelAndView resolveException(HttpServletRequest request,
                                         HttpServletResponse response,
                                         @Nullable Object handler,
                                         Exception ex) {
        log.error("进程pid: " + ManagementFactory.getRuntimeMXBean().getName());
        log.error("线程: " + Thread.currentThread().getName());
        
        ModelAndView modelAndView = new ModelAndView();
        MappingJackson2JsonView mappingJackson2JsonView = new MappingJackson2JsonView();
        Map<String, Object> attributes = new HashMap<>(2);
        attributes.put("succeed", false);
        
        String errorMessage = null;
        
        if (ex instanceof MethodArgumentNotValidException) {
            MethodArgumentNotValidException validException = (MethodArgumentNotValidException) ex;
            FieldError fieldError = validException.getBindingResult().getFieldErrors().get(0);
            errorMessage = fieldError.getField() + " " + fieldError.getDefaultMessage();
        }
        else if (ex instanceof HystrixRuntimeException) {
            Throwable throwable = ex.getCause();
            if (throwable instanceof FeignException) {
                String content = StringUtils.substringBetween(throwable.getMessage(), "{", "}");
                JsonObject jsonpObject = new JsonParser().parse("{" + content + "}")
                                                         .getAsJsonObject();
                errorMessage = jsonpObject.get("message").getAsString();
            }
        }
        else {
            errorMessage = ERROR_MESSAGE;
        }
        attributes.put("message", errorMessage);
        mappingJackson2JsonView.setAttributesMap(attributes);
        modelAndView.setView(mappingJackson2JsonView);
        return modelAndView;
    }
}

2 配置 feign 的 ErrorDecoder

@Component
public class FeignErrorDecoder implements ErrorDecoder{

    @Override
    public Exception decode(String methodKey, Response response){
        
        //在这里解析 response 的结果并返回的异常信息可以被全局异常处理捕获到
        return new Exception(response.getMessage());
    }
}

最终的效果就是这样,调用消费者的接口，消费者再去调用 提供者的接口，提供者处理时出现异常(参考上面第四部那个图)

把异常信息作为结果返回

image.png