Hystrix简介– Hello World

在先前的博客文章中，我谈到了需要像Netflix Hystrix这样的库的动机。在这里，我将跳入一些非常基本的方法来开始使用Hystrix，并在更复杂的用例中进行后续介绍。

你好，世界

以下是“ Hystrix命令”的一个简单的Hello World示例：

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class HelloWorldCommand extends HystrixCommand<String> {private static final Logger logger = LoggerFactory.getLogger(HelloWorldCommand.class);private final String name;public HelloWorldCommand(String name) {super(HystrixCommandGroupKey.Factory.asKey("default"));this.name = name;}@Overrideprotected String run() throws Exception {logger.info("HelloWorld Command Invoked");return "Hello " + name;}
}

run方法保存了我们要保护的所有依赖活动，该活动最终返回此特定实例中的参数化类型– String。如果您是Netflix Rx-java库的粉丝，那么创建Hystrix命令的另一种方法如下：

import com.netflix.hystrix.HystrixCommandGroupKey;
import com.netflix.hystrix.HystrixObservableCommand;
import rx.Observable;public class HelloWorldObservableCommand extends HystrixObservableCommand<String> {private String name;public HelloWorldObservableCommand(String name) {super(HystrixCommandGroupKey.Factory.asKey("default"));this.name = name;}@Overrideprotected Observable<String> resumeWithFallback() {return Observable.just("Returning a Fallback");}@Overrideprotected Observable<String> construct() {return Observable.just("Hello " + this.name);}
}

在这里，“ construct”方法返回Rx-java Observable 。

使用Hystrix命令

现在我们有了一个Hystrix命令来包装我们的调用，它可以用很多不同的方式使用，让我们从最简单的同步调用开始–

HelloWorldCommand helloWorldCommand = new HelloWorldCommand("World");
assertEquals("Hello World", helloWorldCommand.execute());

或者，可以使它返回Future：

HelloWorldCommand helloWorldCommand = new HelloWorldCommand("World");
Future future = helloWorldCommand.queue();
assertEquals("Hello World", future.get());

或者，甚至可以使它返回Rx-Java可观察的：

HelloWorldCommand helloWorldCommand = new HelloWorldCommand("World");CountDownLatch l = new CountDownLatch(1);Observable<String> obs = helloWorldCommand.observe();
obs.subscribe(s -> logger.info("Received : " + s),t -> logger.error(t.getMessage(), t),() -> l.countDown()
);
l.await(5, TimeUnit.SECONDS);

该命令的Observable变体也沿相同的方向工作，但是我们应该对比一下小的行为差异：

HelloWorldObservableCommand helloWorldCommand = new HelloWorldObservableCommand("World");
logger.info("Completed executing HelloWorld Command");
Observable<String> obs = helloWorldCommand.observe();

这里有两种获取Observable的方法，一种是通过调用“ .observe（）”的方法，另一种是以下方法：

HelloWorldObservableCommand helloWorldCommand = new HelloWorldObservableCommand("World");
Observable<String> obs = helloWorldCommand.toObservable();

另一个是以下使用“ .toObservable（）”调用的内容：

HelloWorldObservableCommand helloWorldCommand = new HelloWorldObservableCommand("World");
Observable<String> obs = helloWorldCommand.toObservable();

区别在于，“。observe（）”方法返回的是Hot Observable，可立即开始执行“ construct”方法，而“ .toObservable”的变体将返回“ Cold Observable”，除非已预订，否则不会调用“ construct”方法，请按以下方式说：

CountDownLatch l = new CountDownLatch(1);
obs.subscribe(System.out::println, t -> l.countDown(), () -> l.countDown());
l.await();

我在这里有更多信息。

请注意，尽管Hystrix Command不是Singleton，但使用Hystrix Command的典型方法是在需要的地方构造它，并在完成后将其处置。

后备和命令组密钥

在HelloWorldCommand的构造函数中，我调用了具有以下签名的超类构造函数方法：

public HelloWorldCommand(String name) {super(HystrixCommandGroupKey.Factory.asKey("default"));this.name = name;
}

该参数指定一个Hystrix“命令组”键，以及默认情况下是类的简单名称的Command Key，它控制着Hystrix行为的许多细节，下面是属性示例，我将稍后再回到这些细节：

hystrix.command.HelloWorldCommand.metrics.rollingStats.timeInMilliseconds=10000
hystrix.command.HelloWorldCommand.execution.isolation.strategy=THREAD
hystrix.command.HelloWorldCommand.execution.isolation.thread.timeoutInMilliseconds=1000
hystrix.command.HelloWorldCommand.execution.isolation.semaphore.maxConcurrentRequests=10
hystrix.command.HelloWorldCommand.circuitBreaker.errorThresholdPercentage=50
hystrix.command.HelloWorldCommand.circuitBreaker.requestVolumeThreshold=20
hystrix.command.HelloWorldCommand.circuitBreaker.sleepWindowInMilliseconds=5000hystrix.threadpool.default.coreSize=10
hystrix.threadpool.default.queueSizeRejectionThreshold=5

我们可能要控制的另一种行为是在对依赖服务的调用失败的情况下的响应，后备方法提供了这种行为，因此请考虑依赖服务始终失败的情况：

import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class FallbackCommand extends HystrixCommand<String> {private static final String COMMAND_GROUP="default";private static final Logger logger = LoggerFactory.getLogger(FallbackCommand.class);public FallbackCommand() {super(HystrixCommandGroupKey.Factory.asKey(COMMAND_GROUP));}@Overrideprotected String run() throws Exception {throw new RuntimeException("Always fail");}@Overrideprotected String getFallback() {logger.info("About to fallback");return "Falling back";}
}

在这里，从属服务调用始终失败，并且以下测试中所示的响应将始终是fallback方法的响应：

FallbackCommand fallbackCommand = new FallbackCommand();
assertEquals("Falling back", fallbackCommand.execute());

监控方式

在总结基础之前，最好先演示一下Hystrix在Hystrix流和Hystrix仪表板方面的出色功能。让我们从Hystrix流开始，如果通常在基于Java的Web应用程序中将其作为servlet启用，它会提供SSE实时统计流，有关Web应用程序中存在的Hystrix命令的行为。

由于我的演示基于基于Karyon2 Rx-Netty的应用程序，因此可以在此处查看我的配置。 Hystrix流中的信息有点太原始了，这是很棒的Hystrix仪表板所适合的地方–它使用Hystrix流，并显示有关每个Hystrix命令和不同底层线程池如何执行的实时汇总信息。我这里有一个基于很棒的Spring-Cloud项目的示例Hystrix仪表板项目。此处是一个示例仪表板：

Hystrix仪表板