南阳企业网站排名优化,f006网站建设,自动写作文网站,培训类网站模板在先前的博客文章中#xff0c;我谈到了需要像Netflix Hystrix这样的库的动机。 在这里#xff0c;我将跳入一些非常基本的方法来开始使用Hystrix#xff0c;并在更复杂的用例中进行后续介绍。 你好#xff0c;世界 以下是“ 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 HystrixCommandString {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 HystrixObservableCommandString {private String name;public HelloWorldObservableCommand(String name) {super(HystrixCommandGroupKey.Factory.asKey(default));this.name name;}Overrideprotected ObservableString resumeWithFallback() {return Observable.just(Returning a Fallback);}Overrideprotected ObservableString 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);ObservableString 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);
ObservableString obs helloWorldCommand.observe(); 这里有两种获取Observable的方法一种是通过调用“ .observe”的方法另一种是以下方法 HelloWorldObservableCommand helloWorldCommand new HelloWorldObservableCommand(World);
ObservableString obs helloWorldCommand.toObservable(); 另一个是以下使用“ .toObservable”调用的内容 HelloWorldObservableCommand helloWorldCommand new HelloWorldObservableCommand(World);
ObservableString 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.timeInMilliseconds10000
hystrix.command.HelloWorldCommand.execution.isolation.strategyTHREAD
hystrix.command.HelloWorldCommand.execution.isolation.thread.timeoutInMilliseconds1000
hystrix.command.HelloWorldCommand.execution.isolation.semaphore.maxConcurrentRequests10
hystrix.command.HelloWorldCommand.circuitBreaker.errorThresholdPercentage50
hystrix.command.HelloWorldCommand.circuitBreaker.requestVolumeThreshold20
hystrix.command.HelloWorldCommand.circuitBreaker.sleepWindowInMilliseconds5000hystrix.threadpool.default.coreSize10
hystrix.threadpool.default.queueSizeRejectionThreshold5 我们可能要控制的另一种行为是在对依赖服务的调用失败的情况下的响应后备方法提供了这种行为因此请考虑依赖服务始终失败的情况 import com.netflix.hystrix.HystrixCommand;
import com.netflix.hystrix.HystrixCommandGroupKey;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class FallbackCommand extends HystrixCommandString {private static final String COMMAND_GROUPdefault;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的基础知识还有很多工作要做我将在下一篇博客文章中总结这些内容其中包含一些高级Hystrix功能的详细信息。 翻译自: https://www.javacodegeeks.com/2015/10/gentle-introduction-to-hystrix-hello-world.html
