Hystrix在项目中的使用(二)-基于AOP实现命令式编程(动态配置)

  1. 之前Hystrix在项目中的使用(一)中我介绍过在项目中使用Hystrix注解的方式对服务进行隔离和降级注解方式虽然简单,方便易与使用,但是他主要的问题是Hystrix参数通过注解参数进行设置,无法做到动态修改。 如果我们想对Hystrix进行动态配置,则只能使用期命令式编程方法,但如果使用命令方式对原业务接口进行改造,这个成本也有点大,所以想到使用AOP的方式,通过对目标方式进行拦截,再在拦截面上进行Hystrix操作,这样就无需对原有的业务代码进行修改

  2. 命令式编程

    • 继承HystrixCommand
继承HystrixCommand

继承HystrixCommand,重载其getFallback()和run()方法

通过线程运行helloWorldCommand
测试方法

这里需要注意的是每个Command对象只能调用一次,不可以重复调用,重复调用对应异常信息:This instance can only be executed once. Please instantiate a new instance。从截图中我们可以看出我们执行的是helloWorldCommand的execute方法,这个方法是同步的,其效果等同于helloWorldCommand.queue().get()。

我们在run()方法中sleep3秒,Hystrix配置的参数为5秒,也就是说业务应该正常处理。


正常返回了run的结果

因此,我们就可以将业务代码写在继承了HystrixCommand的run()方法中。

我们将Hystrix的配置参数修改为2秒,重新运行

触发getFallback方法

从结果可以看出,因为run方法处理时间大于hystrix的超时时间,触发了getFallback方法,所以我们可以在getFallback方法中来处理我们的服务降级逻辑。

在上面我们说过 helloWorldCommand.execute()是一个同步的调用,我们也可以修改这异步的调用

异步调用
此时result还是默认值
  1. 在项目中通过AOP使用Hystrix
    通过命令式编程我们可以将业务方法写在HystrixCommand的run方法中,但这样对原有业务代码的改动太大。然后通过注解的方式,虽然对业务代码的改动较小,但是我们没法动态的修改注册的配置参数,不够灵活。所以通过AOP与Hystrix相结合,对原有的业务方法进行拦截,为其原有方法增加Hystrix的实现。
    • 增加AOP切面


      Advice
    • Controller


      Controller
    • Service


      Service

我们在HystrixCommandAdvice中设置的withExecutionTimeoutInMilliseconds超时时间为8秒 模拟Http运行的时候为10秒 运行结果如下:

超时返回结果

修改HystrixCommandAdvice中设置的withExecutionTimeoutInMilliseconds超时时间为12秒 运行结果如下:

正常返回结果
  1. 动态修改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文件。

配置config.properties

在HystrixCommandAdvice中调用Archaius

获取参数
获取配置文件中的值

我们可以看出控制台打印出来的是8000,正是我们在config.properties中配置的值。
我们现在修改这个文件的值将其修改为12000

更改的的值

可以看到我们这里获取到的值是12000,我们的服务并没有重启,也就是这样也进行了动态配置,这里要注意的是我们修改的是类路径classes下的config.properties。
默认的:Archaius会每分钟去重新加载下属性配置。

到此,我们就可以在项目中使用hystrix对服务进行降级,熔断并通过监控数据进行动态调整参数。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,904评论 18 139
  • Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 173,204评论 25 708
  • 一、前言 现在分布式系统的规模不断增加,对可用性的要求也越来越高。在各种高可用设计模式中,熔断、隔离、降级是经常被...
    编走编想阅读 2,884评论 0 7
  • 十年之后谁会记得最难的习题?却难以忘毕业那天满满的回忆。 感觉自己就像明星不停的签名 。。。 校草在叹气,女神在哭...
    苍夜琉璃夏阅读 207评论 2 1
  • 小雨淋,大雨淋,烟雨江南木伞临。长街水幕深。柏森森,夏森森,落日无踪骚客吟。总关一念心。
    浮零先生阅读 223评论 2 4