Hystrix是为了提高微服务的健壮性而生的,它能起到如下作用:
1. 控制与保护微服务的延迟与失败问题,尤其是通过网络访问依赖的微服务导致的延迟与错误传播问题;
2. 阻止连锁的服务调用失败问题;
3. 快速失败与快速恢复;
4. 优雅的降级(降低服务质量)与反馈;
5. 实时监控、告警与控制;

简单点说,因为一个用户请求需要调用多个微服务,那么只要有一个微服务出现问题,那么整个请求都必然受到影响,这也是短板效应,Hystrix就是为了尽可能将这种影响降到最低(不可能消除)。

1. 错误处理

为了降低业务密集性的服务受到影响,我们有必要为此服务提供备用处理手段,这也是Hystrix最常用的应用场景,具体应用步骤如下:

  1. 在Spring Boot程序中启用@EnableCircuitBreaker注解,如下:
@EnableEurekaClient
@EnableCircuitBreaker
@SpringBootApplication
@Import({ServiceConfigs.class, MvcConfigs.class})
public class MiranaAssetApplication extends SpringBootServletInitializer {

    /**
     * 添加自身的配置信息
     * @param application
     * @return 
     */
    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
            return application.sources(MiranaAssetApplication.class);
    }

    public static void main(String[] args) {
        SpringApplication.run(MiranaAssetApplication.class, args);
    }

}
  1. 在微服务端(Eureka客户端)添加Hystrix依赖如下:
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>
  1. 在服务接口上添加HystrixCommand注解,并指向备份方法,如下:
@Override
@HystrixCommand(fallbackMethod = "findAllDefault")
public List<Asset> findAll() {
    throw new RuntimeException("内部错误");
}

/**
  * 备份的处理方法
  */
public List<Asset> findAllDefault() {
    return assets.values().asList();
}

现在如果测试我们的Controller,你会发现,调用findAll方法虽然失败了,但是会返回findAllDefault方法的执行结构。

2. 延时处理

如果任务的耗时较长,例如上述代码的finfAll()方法耗时十秒,那么也会自动切换到备份的处理方法,如下:

@HystrixCommand(fallbackMethod = "findAllDefault")
public List<Asset> findAll() {
    try {
        // 自动进行超时处理
        Thread.sleep(10000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return null;
}

在异常处理中,除了支持同步调用,还是异步调用Future

响应式任务

参考文档

  1. Hystrix wiki
  2. hystrix-javanica
  3. 应对复杂分布式系统中的延时和故障容错
Logo

权威|前沿|技术|干货|国内首个API全生命周期开发者社区

更多推荐