《Spring Cloud Netflix官方文档》3.熔断器:Hystrix Clients

原文链接

Netfilix创建了一个名为Hystrix的库,实现了熔断器模式。在微服务架构中,它通常有多个服务调用层。

《Spring Cloud Netflix官方文档》3.熔断器:Hystrix Clients

图3.1 微服务图

一个底层服务的故障会引发直至用户交互层的连锁故障。在一个设定时长为“metrics.rollingStats.timeInMilliseconds”(默认为十秒)的滚动窗口内,对一个特定服务的请求数大于“circuitBreaker.requestVolumeThreshold”(默认为20个),并且故障率大于“circuitBreaker.errorThresholdPercentage”(默认大于百分之五十)的时候,启用熔断机制以使请求失效。在熔断和报错的情况下,开发者可以启用回退机制。

《Spring Cloud Netflix官方文档》3.熔断器:Hystrix Clients

图3.2 Hystrix回退以防止连锁故障

 

启用熔断机制能防止连锁故障的情况,给故障服务提供时间以恢复正常。回退操作可以是另一个Hystrix受保护的调用、静态数据或是一个恰当的空值。回退操作可能是成串的,所以第一个回退操作会做一些其他的业务请求,让故障回退到预设的值。

 

3.1 如何引入Hystrix

使用group为“org.springframework.cloud”, artifact id为“spring-cloud-starter-hystrix”的启动器引入Hystrix。请参阅Spring Cloud Project页面,以获取有关使用当前Spring Cloud Release Train设置构建系统的详细信息。

Boot app 样例:

@SpringBootApplication
@EnableCircuitBreaker
public class Application {

    public static void main(String[] args) {
        new SpringApplicationBuilder(Application.class).web(true).run(args);
    }

}

@Component
public class StoreIntegration {

    @HystrixCommand(fallbackMethod = "defaultStores")
    public Object getStores(Map<String, Object> parameters) {
        //do stuff that might fail
    }

    public Object defaultStores(Map<String, Object> parameters) {
        return /* something useful */;
    }
}

注解@HystrixCommand由Netflix contrib library提供,被称作“javanica”。Spring Cloud会自动将包含该注释的Spring bean封装在连接到Hystrix熔断器的代理中。熔断器会计算何时启用或关闭熔断机制,并决定在故障时该做什么。

可以使用带有@HystrixProperty注解列表的commandProperties属性配置@HystrixCommand。点击这里获取更多详情。另外,有关可用属性的详细信息,请参阅Hystrix wiki。

 

3.2传播Security Context或使用Spring Scope

如果想要一些线程本地上下文传播到@HystrixCommand,默认的声明将不起作用,因为它执行的是线程池中的命令(在超时的情况下)。可以使用某种配置将Hystrix切换为使用与调用方相同的线程,或直接在注解中请求使用不同的“隔离策略”。如下所示:

@HystrixCommand(fallbackMethod = "stubMyService",
    commandProperties = {
      @HystrixProperty(name="execution.isolation.strategy", value="SEMAPHORE")
    }
)

以上操作,同样适用于使用@SessionScope或@RequestScope的时候。当抛出“无法找到范围内的上下文”的运行时异常,就需要执行这些操作。

同样可以设置属性“hystrix.shareSecurityContext”为true。这样做会自动配置一个Hystrix并发策略插件钩子,它将从主线程传输SecurityContext到Hystrix命令使用的钩子。Hystrix不允许注册多个hystrix并发策略。因此会通过将自己的HystrixConcurrencyStrategy声明为Spring bean的方法,使用扩展机制。Spring Cloud会在上下文中查找你的实现,并封装进它自己的插件中。

 

3.3健康监控

连接熔断器的状态也可以在请求应用程序的/health端口查看。

{
    "hystrix": {
        "openCircuitBreakers": [
            "StoreIntegration::getStoresByLocationLink"
        ],
        "status": "CIRCUIT_OPEN"
    },
    "status": "UP"
}

 

3.4 Hystrix 数据流

配置spring-boot-starter-actuator的依赖以启用Hystrix 数据流。这将启用端口/hystrix.stream作为一个管理终端。

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator<artifactId>
    </dependency>

原创文章,作者:ItWorker,如若转载,请注明出处:https://blog.ytso.com/98832.html

(0)
上一篇 2021年8月21日
下一篇 2021年8月21日

相关推荐

发表回复

登录后才能评论