Hystrix之API使用

Hystrix使用了命令设计模式，提供了两个Command， HystrixCommand 和 HystrixObservableCommand，只需要编写命令即可

public class CommandThatFailsSilently extends HystrixCommand<List<String>> {
    private final boolean throwException;
    public CommandThatFailsSilently(boolean throwException) {
        super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
        this.throwException = throwException;
    }
    @Override
    protected List<String> run() {
        if (throwException) {
            throw new RuntimeException("failure from hystrix.examples.basic.CommandThatFailsFast");
        } else {
            ArrayList<String> values = new ArrayList<String>();
            values.add("success");
            return values;
        }
    }
    @Override
    protected List<String> getFallback() {
        return Collections.emptyList();
    }
}

 

Hystrix提供了一个类库javanica，可以使用@HystrixCommand注解完成命令的编写。例如使用 @HystrixCommand 注解标记方法，Hystrix 将利用AOP自动将目标方法包装成HystrixCommand来执行

@GetMapping("/getHostMessage/{id}")
@HystrixCommand(fallbackMethod = "getHostMessageFallback")
public Map<String, Object> getHostMessage(@PathVariable String id){...}

 

源码中有几个关键的概念：groupKey、commandKey、threadPoolKey。

 

每个请求系统会有自己的com.netflix.hystrix.HystrixCommand.Setter实例，groupKey要求非空是一切实例的基础，用于标识系统；commandKey对于请求，fallback的统计数据是通过commandKey来区分的，所以最好每个线程池也有自己的commandKey；每个threadPoolKey一个线程池，根据threadPoolKey来区分不同的线程池。

 

HystrixCommand实现线程隔离

要实现线程隔离的关键在于threadPoolKey，一个threadPoolKey映射一个线程池。这里探讨两种线程隔离的方式：类级别和实例级别，重点讲讲实例级别的线程隔离

 

类级别，是实现很多的HystrixCommand<T>，如上面代码里的HelloCommand，你还可以有ACommand，BCommand，CCommand，DCommand……这样每个类都会有自己的线程池，从而实现线程隔离。每个类在实例化的时候，如果没有指定线程池（通过Setter指定），默认会使用组名作为一组线程池，组名必须设置，因为构造Setter实例的唯一方法是withGroupKey。

 

实例级别线程隔离

但其实很多时候你并不希望有这么多的类，你可能希望在HelloCommand#run中根据不同的请求系统进行线程隔离，比如：HelloCommand#run根据不同的请求参数，会访问系统A、系统B、系统C、系统D……你不希望系统A出现问题影响到代码对其他系统的访问。

这个时候你的代码可能是这样的：

public class Bean {

    // 需要请求的系统

    private String requestSystem;

    // 省略其他属性和setter/getter方法

}

 

public class Serivce() {

    public String doService(Bean bean) {

        // 每个请求的外部系统一个setter实例

        Setter setter = getSetterFromRequestSystem(bean.getRequestSystem());

        HelloCommand command = new HelloCommand(setter);

        return command.execute();

    }

    public Setter getSetterFromRequestSystem(String requestSystem) {

        // 将requestSystem设置为组名，或者threadPoolKey

        return Setter.withGroupKey(requestSystem)...;

    }

}