之前Hystrix在项目中的使用(一)中我介绍过在项目中使用Hystrix注解的方式对服务进行隔离和降级注解方式虽然简单,方便易与使用,但是他主要的问题是Hystrix参数通过注解参数进行设置,无法做到动态修改。 如果我们想对Hystrix进行动态配置,则只能使用期命令式编程方法,但如果使用命令方式对原业务接口进行改造,这个成本也有点大,所以想到使用AOP的方式,通过对目标方式进行拦截,再在拦截面上进行Hystrix操作,这样就无需对原有的业务代码进行修改
-
命令式编程
- 继承HystrixCommand
继承HystrixCommand,重载其getFallback()和run()方法
这里需要注意的是每个Command对象只能调用一次,不可以重复调用,重复调用对应异常信息:This instance can only be executed once. Please instantiate a new instance。从截图中我们可以看出我们执行的是helloWorldCommand的execute方法,这个方法是同步的,其效果等同于helloWorldCommand.queue().get()。
我们在run()方法中sleep3秒,Hystrix配置的参数为5秒,也就是说业务应该正常处理。
因此,我们就可以将业务代码写在继承了HystrixCommand的run()方法中。
我们将Hystrix的配置参数修改为2秒,重新运行
从结果可以看出,因为run方法处理时间大于hystrix的超时时间,触发了getFallback方法,所以我们可以在getFallback方法中来处理我们的服务降级逻辑。
在上面我们说过 helloWorldCommand.execute()是一个同步的调用,我们也可以修改这异步的调用
- 在项目中通过AOP使用Hystrix
通过命令式编程我们可以将业务方法写在HystrixCommand的run方法中,但这样对原有业务代码的改动太大。然后通过注解的方式,虽然对业务代码的改动较小,但是我们没法动态的修改注册的配置参数,不够灵活。所以通过AOP与Hystrix相结合,对原有的业务方法进行拦截,为其原有方法增加Hystrix的实现。-
增加AOP切面
-
Controller
-
Service
-
我们在HystrixCommandAdvice中设置的withExecutionTimeoutInMilliseconds超时时间为8秒 模拟Http运行的时候为10秒 运行结果如下:
修改HystrixCommandAdvice中设置的withExecutionTimeoutInMilliseconds超时时间为12秒 运行结果如下:
-
动态修改Hystrix参数
其实说到这里已经很明显了,只需要在HystrixCommandAdvice中来实时获取需要的配置参数值就可以,如从配置文件,Redis,数据库中获取。然后将其传到setter方法中即可,这里我要提一下Netflix的Archaius,Archaius用于动态的管理属性配置文件。- 引用Archaius
<dependency>
<groupId>com.netflix.archaius</groupId>
<artifactId>archaius-core</artifactId>
<version>0.6.0</version>
</dependency>
Archaius默认会自动读取项目类路径下的config.properties文件。
在HystrixCommandAdvice中调用Archaius
我们可以看出控制台打印出来的是8000,正是我们在config.properties中配置的值。
我们现在修改这个文件的值将其修改为12000
可以看到我们这里获取到的值是12000,我们的服务并没有重启,也就是这样也进行了动态配置,这里要注意的是我们修改的是类路径classes下的config.properties。
默认的:Archaius会每分钟去重新加载下属性配置。
到此,我们就可以在项目中使用hystrix对服务进行降级,熔断并通过监控数据进行动态调整参数。