Spring中使用Hystrix实现熔断详解
Hystrix实现熔断
在使用Hystrix实现熔断的过程中遇到了两个问题
1、在修改了熔断配置之后不生效的问题
2、熔断后不恢复的问题
对于第一个问题，查看hystrix源码可以看到，如果有缓存配置是优先使用的缓存的，因此如果配置更新，必须要更新缓存，不能使用Hystrix.reset()方法来更新缓存，这个方法清理全局缓存，会影响其他commandkey的熔断状态。
public static HystrixCircuitBreaker getInstance(HystrixCommandKey key, HystrixCommandGroupKey group, HystrixCommandProperties properties, HystrixCommandMetrics metrics) {
// this should find it for all but the first time
HystrixCircuitBreaker previouslyCached = circuitBreakersByCommand.get(key.name());
if (previouslyCached != null) {
return previouslyCached;
}官方提供的方法是通过archaius动态更新
Hystrix uses Archaius for the default implementation of properties for configuration.
实现接口com.netflix.config.PolledConfigurationSource，将对应的commandkey通过形如下面的key来放入poll方法响应的map中，hystrix会根据这个key自动更新缓存
hystrix.command.HystrixCommandKey.execution.isolation.thread.timeoutInMilliseconds
第二个问题经过debughystrix源码发现是由于，使用了响应式的调用，hystrix使用的是V1版本的rxjava，而项目使用的是V3版本的rxjava，在V3转V1后响应给hystrixcircuitbreaker时，hystrix没有收到oncomplete事件，导致没有在断路器半开状态时调用成功关闭断路器。
在com.netflix.hystrix.AbstractCommand类中实现了断路器的控制逻辑：
可以看到在onCompleted的观察者逻辑中会将断路器markSuccess
private Observable<R> executeCommandAndObserve(final AbstractCommand<R> _cmd) {
final HystrixRequestContext currentRequestContext = HystrixRequestContext.getContextForCurrentThread();
final Action1<R> markEmits = new Action1<R>() {
@Override
public void call(R r) {
if (shouldOutputOnNextEvents()) {
executionResult = executionResult.addEvent(HystrixEventType.EMIT);
eventNotifier.markEvent(HystrixEventType.EMIT, commandKey);
}
if (commandIsScalar()) {
long latency = System.currentTimeMillis() - executionResult.getStartTimestamp();
eventNotifier.markCommandExecution(getCommandKey(), properties.executionIsolationStrategy().get(), (int) latency, executionResult.getOrderedList());
eventNotifier.markEvent(HystrixEventType.SUCCESS, commandKey);
executionResult = executionResult.addEvent((int) latency, HystrixEventType.SUCCESS);
circuitBreaker.markSuccess();
}
}
};
final Action0 markOnCompleted = new Action0() {
@Override
public void call() {
if (!commandIsScalar()) {
long latency = System.currentTimeMillis() - executionResult.getStartTimestamp();
eventNotifier.markCommandExecution(getCommandKey(), properties.executionIsolationStrategy().get(), (int) latency, executionResult.getOrderedList());
eventNotifier.markEvent(HystrixEventType.SUCCESS, commandKey);
executionResult = executionResult.addEvent((int) latency, HystrixEventType.SUCCESS);
circuitBreaker.markSuccess();
}
}
};目前想到的解决办法是一种是在接收调用服务响应时blockingfirst()，但是这样会导致异步调用变成同步，还有一种是在调用服务的Observable的onnext方法中添加onCompleted事件，来通知hystrix调用服务接收到了complete事件，但是这样就只能接收到单个onNext事件，两种都有缺点，还有想到更好的解决办法。
到此这篇关于Spring中使用Hystrix实现熔断详解的文章就介绍到这了,更多相关Hystrix实现熔断内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
Apache ECharts是一个基于 JavaScript 的开源可视化图表库，在网页上实现数据的可视化，非常好用，本文将通过一个简单的demo来给大家介绍一下Spring + ECharts如何数据可视化,需要的朋友可以参考下2023-07-07
解决Springboot2.1.x配置Activiti7单独数据源问题
这篇文章主要介绍了Springboot2.1.x配置Activiti7单独数据源问题,非常不错，具有一定的参考借鉴价值，需要的朋友可以参考下2019-09-09
今天带大家学习eclipse如何搭建Spring boot项目,文中有非常详细的图文解说,对正在学习java的小伙伴们有很好地帮助,需要的朋友可以参考下2021-05-05
SpringBoot修改子模块Module的jdk版本的方法 附修改原因
这篇文章主要介绍了SpringBoot修改子模块Module的jdk版本的方法 附修改原因,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-04-04
Java字符串是一系列的Unicode字符序列,但是它却常常被误认为是char序列,这篇文章主要给大家介绍了关于java字符串遍历的几种常用方法,文中通过实例代码介绍的非常详细,需要的朋友可以参考下2023-04-04
SpringBoot与Elasticsearch8.0集成的实现步骤
本文介绍了SpringBoot与Elasticsearch8.0的集成方法和最佳实践,详细探讨了Elasticsearch8.0的安全增强、性能优化、API改进等新特性,下面就一起来了解一下2026-04-04
这篇文章主要介绍了Java之Algorithm_analysis案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下2021-09-09
本篇总结的是Spring MVC框架相关的面试题，后续会持续更新，希望我的分享可以帮助到正在备战面试的实习生或者已经工作的同行，如果发现错误还望大家多多包涵，不吝赐教，谢谢2021-07-07
今天小编就为大家分享一篇java字符串常用操作方法(查找、截取、分割)，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2018-07-07
这篇文章主要介绍了解决Maven中关于依赖导入不进的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-11-11
最新评论