Hystrix降级逻辑中如何获取触发的异常？

通过之前Spring Cloud系列教程中的《Spring Cloud构建微服务架构：服务容错保护（Hystrix服务降级）》一文，我们已经知道如何通过Hystrix来保护自己的服务不被外部依赖方拖垮的情况。但是实际使用过程中经常碰到开发反应“莫名”触发了降级逻辑的情况。

为了更精准的定位触发原因，或是在降级逻辑中需要根据不同的异常做不同的处理时，在降级方法中，我们希望可以获取到主逻辑中抛出的异常信息。接下来就来介绍一下Hystrix两种不同实现方式中如何在降级逻辑中获取异常信息的方法。

注解方式

先介绍一下用注解方式定义的Hystrix命令是如何在降级逻辑中获取异常的，实现非常简单，先看下面的例子：

1. @HystrixCommand(fallbackMethod = "fallback")

2. User getUserById(String id) {

3.    throw new RuntimeException("getUserById command failed");

4. }

6. User fallback(String id, Throwable throwable) {

7.    return new User("def", "def");

这里定义了一个主逻辑函数 getUserById，主逻辑中会主动抛出一个异常，从而触发该主逻辑的降级函数 fallback。重点看 fallback函数中的最后一个传参 Throwablethrowable。通过这样的简单定义，开发人员就可以很方便的获取触发降级逻辑的异常信息，用作日志记录或者其它复杂的业务逻辑了。

继承方式

在继承方式中要获取触发异常也非常简单，具体如下：

1. public static class UserCommand extends HystrixCommand<User> {

2.    protected UserCommand() {

3.        super(HystrixCommandGroupKey.Factory.asKey("UserCommand"));

4.    }

5.    @Override

6.    protected User run() throws Exception {

7.        throw new RuntimeException("getUserById command failed");

8.    protected User getFallback() {

9.        System.out.println(getFailedExecutionException().getMessage());

10.        return new User("def", "def");

上面的实现同上一节注解方式的实现一样，在使用继承方式的时候通过 getFailedExecutionException方法就可以获取到触发降级的异常信息了。

总结

我们在实际使用Hystrix的时候，有时候一些业务异常或者内部RPC由服务提供方抛出的异常在消费方没能考虑周到，会触发一些意料之外的降级。所以在降级逻辑中，建议每一段都加入触发异常的日志记录，以方便定位问题原因。

- END -

 往期推荐：

• 死磕Java系列：

1. 深入分析ThreadLocal

2. 深入分析synchronized的实现原理
   

3. 深入分析volatile的实现原理
   

4. Java内存模型之happens-before

5. Java内存模型之重排序

6. Java内存模型之分析volatile

7. Java内存模型之总结

8. J.U.C之AQS简介

9. J.U.C之AQS：CLH同步队列

10. J.U.C之AQS同步状态的获取与释放

11. J.U.C之AQS阻塞和唤醒线程

12. J.U.C之重入锁：ReentrantLock

13. J.U.C之读写锁：ReentrantReadWriteLock

14. J.U.C之Condition

15. J.U.C之并发工具类：CyclicBarrier

16. J.U.C之并发工具类：Semaphore

17. J.U.C之并发工具类：CountDownLatch

18.  J.U.C之并发工具类：Exchanger

……

• Spring系列：

1. Spring Cloud Zuul中使用Swagger汇总API接口文档
   

2. Spring Cloud Config Server迁移节点或容器化带来的问题

3. Spring Cloud Config对特殊字符加密的处理

4. Spring Boot使用@Async实现异步调用：使用Future以及定义超时

5. Spring Cloud构建微服务架构：分布式配置中心（加密解密）

6. Spring Boot快速开发利器：Spring Boot CLI

……

可关注我的公众号

深入交流、更多福利

扫码加入我的知识星球

点击“阅读原文”，看本号其他精彩内容