温馨提示]

• 在这里推荐给大家martinfowler的熔断器介绍和权威指南,有兴趣的小伙伴们可以研究一下哈。
  
• 主要介绍相关：官网说明

[背景介绍]

• 分布式系统的规模和复杂度不断增加，随着而来的是对分布式系统可用性的要求越来越高。在各种高可用设计模式中，【熔断、隔离、降级、限流】是经常被使用的。而相关的技术，Hystrix本身早已算不上什么新技术，但它却是最经典的技术体系！。
  
• Hystrix以实现熔断降级的设计，从而提高了系统的可用性。
  
• Hystrix是一个在调用端上，实现断路器模式，以及隔舱模式，通过避免级联故障，提高系统容错能力，从而实现高可用设计的一个Java服务组件库。
  
• Hystrix实现了资源隔离机制

[内容介绍]

• 介绍Hystrix的基本使用方式和基本配置
  
• 使用Hystrix实现基本的熔断设计，以保护应用的安全，实现初步的高可用设计。

[基本使用]

• Hystrix的主要目的是保护跨进程调用，避免因为超时等问题，导致的级联故障。
  
• Hystrix的实现方法是封装跨进程调用。具体的使用方式有多种：从编程方式看可分为编程方式和注解方式两种；从调用方式看可分为同步调用方式、异步调用方式和反应式调用方式三种。

我们先来看最常见的同步编程方式：

代码示例

@Component
public class AuthService {
  @Autowired
  private UserService userService;
  public boolean validateUser(String userId) {
    User user = new GetUserCommand(userId).execute(); // 6
    if (user == null) {
      return false;
    } else {
      return user.isValid();
    }
  }
class GetUserCommand extends HystrixCommand<User> { // 1
    private Long userId;
    public GetUserCommand(Long userId) { // 2
      super(Setter.withGroupKey(HystrixCommandGroupKey.
      Factory.asKey("UserService")) // 3
          .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
              .withCoreSize(20) // 3
          )
          .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
              .withExecutionTimeoutInMilliseconds(100) // 3
          )
      );
      this.userId = userId;
    }
    @Override
    public User run() throws Exception {
      return userService.getUserById(userId); // 4
    }
    @Override
    public User getFallback() {
      return new InvalidUser(); // 5
    }
  }
}
复制代码

代码解释

• Hystrix常见的使用方法是在一个业务处理类（在本例中是AuthService）新建一个内部类（本例中是GetUserCommand）。

• 这个内部类需要扩展HystrixCommand。之所以使用内部类是因为Hystrix通常用来封装一次远程调用，一般直接调用一个业务方法。

• 这个业务方法通常位于一个业务处理类或这个业务处理类所依赖的类中。而使用内部类的方式可以简化这种调用。

• 扩展HystrixCommand还需声明一个泛型类型，这个泛型类型表示这个HystrixCommand的执行方法（run、construct等）的返回值。

• 定义一个HystrixCommand还需定义一个构造函数。这个构造函数十分重要，因为在使用这个 HystrixCommand 时，需要通过构造函数传递参数。
• 
  
• 
  构造函数中，需要调用父构造函数对当前的HystrixCommand进行配置。主要的配置主要有三个：GroupKey、ThreadPoolSize和Timeout。 具体的配置方式有多种，较常用的一种方式是通过一个名为Setter的Builder类进行配置。

GroupKey

Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("UserService")) 
复制代码

ThreadPoolSize

.andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter().withCoreSize(20)) 
复制代码

Timeout

.andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(100) 
复制代码

• 通过实现run()方法，在其中实现业务逻辑。通常是调用外部类的方法或外部类依赖的方法。通过实现getFallback()方法，实现失败逻辑，可以在其中实现降级等功能。

• 编写完GetUserCommand之后，使用的时候每次都需要new一个新对象，再调用execute()方法。注意，不要调用run()方法，否则熔断、隔离等功能是不生效的。

基本配置

上面的部分介绍了HystrixCommand的基本使用方法，但只是简单介绍了几个配置。所以，下面将对 HystrixCommand的相关配置的作用做一个较为详细的介绍。

配置模式

Hystrix的配置有三个维度：全局默认配置、Instance默认配置、Instance动态配置。除了少部分配置项外，大部分配置都支持动态修改。

接下来介绍一下一些主要参数的Instance默认配置方式。这种配置方式也是使用Hystrix最先接触到的配置方式。

Command Group(必选)

GroupKey是HystrixCommand不可缺少的配置，其它配置均为可选。所以，使用Hystrix可以使用下面的代码：

public class CommandHelloWorld extends HystrixCommand<String> {
  private final String name;
  public CommandHelloWorld(String name) {
    super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
    this.name = name;
  }
  @Override
  protected String run() {
    return "Hello " + name + "!";
  }
}
复制代码

HystrixCommandGroupKey是一个接口，除了可以HystrixCommandGroupKey.Factory.asKey("ExampleGroup") 的方式定义以外，也可以直接实现这个接口。比如使用如下的方式：

public enum Groups implements HystrixCommandGroupKey {
  GROUP_1
}
class EnumGroupCommand extends HystrixCommand<String> {
  EnumGroupCommand() {
    super(Groups.GROUP_1);
  }
  @Override
  protected String run() throws Exception {
    LOGGER.info("Thread of Command: {}", Thread.currentThread().getName());
    return null;
  }
}
复制代码

如上面代码这样，使用自定义的枚举类，实现HystrixCommandGroupKey接口，可以统一Hystrix Command Group的定义，简化配置。

HystrixCommandGroupKey的作用主要有两个：

• 一是起到分组监控、报警的作用。后面的文章会对监控等方面进行介绍；
  
• 二是在不配置HystrixThreadPoolKey的情况下，起到分组线程池的作用。默认使用HystrixCommandGroupKey去命名线程池,使用同一个HystrixCommandGroupKey且没有自定义HystrixThreadPoolKey的HystrixCommand将使用同一个线程池

Command Thread-Pool

虽然HystrixCommandGroupKey可以起到隔离线程池的作用，但是无法起到对线程池进行精细配置的作用。

所以这里就需要线程池进行配置：

Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("MyService"))
    .andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("MyThreadPool"))
    .andThreadPoolPropertiesDefaults(HystrixThreadPoolProperties.Setter()
        .withCoreSize(10)
        .withKeepAliveTimeMinutes(1)
        .withMaxQueueSize(-1)
    )
)
复制代码

andThreadPoolPropertiesDefaults配置中的数值表示的是默认值。

接下来逐项介绍：

• andThreadPoolKey(HystrixThreadPoolKey.Factory.asKey("MyThreadPool")) 这是配置 ThreadPoolKey。如果需要在同一个GroupKey下面配置不同的ThreadPool就需要这个配置。

• withCoreSize(10) 用来配置线程池大小。Hystrix对线程池的配置有一些限制，这里只能配置线程数的Core Size，不能配置Max Size。不配置的话使用的默认值是10。

• withKeepAliveTimeMinutes(1) 用来配置核心线程数空闲时keep alive的时长，默认1 mins。这项配置一般不需要修改。

• withMaxQueueSize(-1) 用来配置线程池任务队列的大小，默认值为 -1。

• 当使用-1 时，SynchronousQueue将被使用，即意味着其实这个队列只是一个交换器，任务将被直接交给工作线程处理。如果工作线程不足，那任务将被拒绝；如果使用任何正整数，LinkedBlockingQueue将被使用。

Command Properties

命令执行直接相关的配置，包括隔离策略、超时时间、Fallback相关配置。

接下来介绍几个主要的配置：

隔离策略

默认的隔离策略是实现线程池隔离，另外一种隔离策略是Semaphore。Instance默认配置可使用如下方法设置：

HystrixCommandProperties.Setter().withExecutionIsolationStrategy(ExecutionIsolationStrategy.SEMAPHORE)
复制代码

这项配置通常不用配置

超时时间

默认时间是1000ms，单位是毫秒。

Instance默认配置可以使用如下方法设置：

.andCommandPropertiesDefaults(HystrixCommandProperties.Setter().withExecutionTimeoutInMilliseconds(100))
复制代码

这项配置比较重要，后文还会详细介绍如何调配这个参数。

Fallback并发度（fallback可以支持的并发量，也就是是执行fallback的线程池大小）

在Instance默认配置中是通过如下代码设置的：

super(Setter.withGroupKey(BASIC_USAGE_GROUP)
    .andCommandPropertiesDefaults(HystrixCommandProperties.Setter()
        .withFallbackIsolationSemaphoreMaxConcurrentRequests(10)
    )
);
复制代码

• 默认值为 10。因为 getFallback()方法是和run()方法使用同一个线程池执行的，并发过高会影响主逻辑的执行，所有需要控制并发量。

• 如果getFallback()执行速度很快，那不用修改此值。如果getFallback()中执行一个较为耗时的操作，那就需要考虑修改此值。