hystrix基本介绍和使用(1)

时间:2023-01-18 13:05:20

一、hystrix基本介绍

Hystrix(https://github.com/Netflix/Hystrix)是Netflix(https://www.netflix.com/global)的一个开源项目,主要作用是通过控制那些访问远程系统、服务和第三方库的节点,从而对延迟和故障提供更强大的容错能力。 其可以看做是Netflix团队对分布式系统运维的各种理念和实践的总结。

二、基本用法

①pom.xml加上以下依赖

<dependency>
<groupId>com.netflix.hystrix</groupId>
<artifactId>hystrix-core</artifactId>
<version>1.5.8</version>
</dependency>

②基本使用

如果某程序或class要使用Hystrix,只需简单继承HystrixCommand/HystrixObservableCommand并重写run()/construct()
然后调用程序实例化此class并执行execute()/queue()/observe()/toObservable()
例如:
public class HelloWorldHystrixCommand extends HystrixCommand<String>{
private final String name;
public HelloWorldHystrixCommand(String name) {
super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
this.name = name;
} @Override
protected String run() throws Exception {
//Thread.sleep(100);
return "hello"+name;
}
}
public static void main(String[] args){
String result = new HelloWorldHystrixCommand("test").execute();
System.out.println(result);
}

hystrix基本介绍和使用(1)

或者

public class HelloWorldHystrixObservableCommand extends HystrixObservableCommand<String>{

	private final String name;

	protected HelloWorldHystrixObservableCommand(String  name) {
super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));
this.name = name;
} @Override
protected Observable<String> construct() {
System.out.println("in construct! thread:" + Thread.currentThread().getName());
     return (Observable<String>) Observable.create(new Observable.OnSubscribe<String>() {
// @Override
public void call(Subscriber<? super String> observer) {
try {
System.out.println("in call of construct! thread:" + Thread.currentThread().getName());
if (!observer.isUnsubscribed()) {
// observer.onError(getExecutionException()); // 直接抛异常退出,不会往下执行
observer.onNext("Hello1" + " thread:" + Thread.currentThread().getName());
observer.onNext("Hello2" + " thread:" + Thread.currentThread().getName());
observer.onNext(name + " thread:" + Thread.currentThread().getName());
System.out.println("complete before------" + " thread:" + Thread.currentThread().getName());
observer.onCompleted(); // 不会往下执行observer的任何方法
System.out.println("complete after------" + " thread:" + Thread.currentThread().getName());
observer.onCompleted(); // 不会执行到
observer.onNext("abc"); // 不会执行到
}
} catch (Exception e) {
observer.onError(e);
}
}
});
}
}
public static void main(String[] args) {
    Observable<String> observable = new HelloWorldHystrixObservableCommand("test").observe();
    observable.subscribe(new Subscriber<String>() {
public void onCompleted() {
   System.out.println("completed");
}
public void onError(Throwable throwable) {
System.out.println("error-----------"+throwable);
}
public void onNext(String v) {
System.out.println("next------------" + v);
}
  });
}

hystrix基本介绍和使用(1)

③HystrixCommand 与 HystrixObservableCommand对比

要想使用hystrix,只需要继承HystrixCommandHystrixObservableCommand,简单用法见上面例子。

两者主要区别是:

(1)前者的命令逻辑写在run();后者的命令逻辑写在construct()

(2)前者的run()是由新创建的线程执行;后者的construct()是由调用程序线程执行

(3)前者一个实例只能向调用程序发送(emit)单条数据,比如上面例子中run()只能返回一个String结果;后者一个实例可以顺序发送多条数据,比如demo中顺序调用多个onNext(),便实现了向调用程序发送多条数据;

④4个命令的执行方法对比

execute()queue()observe()toObservable()这4个方法用来触发执行run()/construct(),一个实例只能执行一次这4个方法,特别说明的是HystrixObservableCommand没有execute()queue()
4个方法的主要区别是:

(1)execute():以同步堵塞方式执行run()。调用execute()后,hystrix先创建一个新线程运行run(),接着调用程序要在execute()调用处一直堵塞着,直到run()运行完成(2)queue():以异步非堵塞方式执行run()。一调用queue()就直接返回一个Future对象,同时hystrix创建一个新线程运行run(),调用程序通过Future.get()拿到run()的返回结果,而Future.get()是堵塞执行的。

测试代码如下:

@Test
public void testQueue() throws Exception {
// queue()是异步非堵塞性执行:直接返回,同时创建一个线程运行HelloWorldHystrixCommand.run()
// 一个对象只能queue()一次
// queue()事实上是toObservable().toBlocking().toFuture()
Future<String> future = new HelloWorldHystrixCommand("Hlx").queue(); // 使用future时会堵塞,必须等待HelloWorldHystrixCommand.run()执行完返回
String queueResult = future.get(10000, TimeUnit.MILLISECONDS);
// String queueResult = future.get();
System.out.println("queue异步结果:" + queueResult);
assertEquals("hello", queueResult.substring(0, 5));
}

(3)observe():事件注册前执行run()/construct()。第一步是事件注册前,先调用observe()自动触发执行run()/construct()(如果继承的是HystrixCommand,hystrix将创建新线程非堵塞执行run();如果继承的是HystrixObservableCommand,将以调用程序线程堵塞执行construct()),第二步是从observe()返回后调用程序调用subscribe()完成事件注册,如果run()/construct()执行成功则触发onNext()onCompleted(),如果执行异常则触发onError()

测试代码如下:

@Test
public void testObservable() throws Exception { // observe()是异步非堵塞性执行,同queue
Observable<String> hotObservable = new HelloWorldHystrixCommand("Hlx").observe(); // single()是堵塞的
//System.out.println("hotObservable single结果:" + hotObservable.toBlocking().single());
//System.out.println("------------------single");
// 注册观察者事件
// subscribe()是非堵塞的
hotObservable.subscribe(new Observer<String>() { // 先执行onNext再执行onCompleted
// @Override
public void onCompleted() {
System.out.println("hotObservable completed");
}
// @Override
public void onError(Throwable e) {
e.printStackTrace();
}
// @Override
public void onNext(String v) {
System.out.println("hotObservable onNext: " + v);
}
});
// 非堵塞
// - also verbose anonymous inner-class
// - ignore errors and onCompleted signal
hotObservable.subscribe(new Action1<String>() { // 相当于上面的onNext()
// @Override
public void call(String v) {
System.out.println("hotObservable call: " + v);
}
});
// 主线程不直接退出,在此一直等待其他线程执行
System.in.read();
}

(4)toObservable():事件注册后执行run()/construct()。第一步是事件注册前,一调用toObservable()就直接返回一个Observable<String>对象,第二步调用subscribe()完成事件注册后自动触发执行run()/construct()(如果继承的是HystrixCommand,hystrix将创建新线程非堵塞执行run(),调用程序不必等待run();如果继承的是HystrixObservableCommand,将以调用程序线程堵塞执行construct(),调用程序等待construct()执行完才能继续往下走),如果run()/construct()执行成功则触发onNext()onCompleted(),如果执行异常则触发onError()

测试代码如下:

@Test
public void testToObservable() throws Exception { // toObservable()是异步非堵塞性执行,同queue
Observable<String> coldObservable = new HelloWorldHystrixCommand("Hlx").toObservable(); // single()是堵塞的
//System.out.println("coldObservable single结果:" + coldObservable.toBlocking().single()); // 注册观察者事件
// subscribe()是非堵塞的
// - this is a verbose anonymous inner-class approach and doesn't do assertions
coldObservable.subscribe(new Observer<String>() { // 先执行onNext再执行onCompleted
// @Override
public void onCompleted() {
System.out.println("coldObservable completed");
}
// @Override
public void onError(Throwable e) {
System.out.println("coldObservable error");
e.printStackTrace();
}
// @Override
public void onNext(String v) {
System.out.println("coldObservable onNext: " + v);
}
});
// 非堵塞
// - also verbose anonymous inner-class
// - ignore errors and onCompleted signal
/*coldObservable.subscribe(new Action1<String>() { public void call(String v) {
// 相当于上面的onNext()
// @Override
System.out.println("coldObservable call: " + v);
}
});*/
// 主线程不直接退出,在此一直等待其他线程执行
System.in.read(); }

参考文献:

http://www.jianshu.com/p/b9af028efebb

hystrix基本介绍和使用(1)的更多相关文章

  1. hystrix应用介绍(一)

    声明:本文仅做个人的一次接口重构过程记录,期间参考了一些写的不错的博客,如果存在抄袭,请留言. hystrix基本介绍 hystrix 是一个开源的容灾框架,目的是为了解决当依赖服务出现故障或者接口响 ...

  2. Hystrix的介绍和简单使用

    这周在看项目的相关代码时,接触到了Hystrix,因此查询了相关资料学习了下. 一.什么是Hystrix Hystrix是Netflix针对微服务分布式系统的熔断保护中间件,当我们的客户端连接远程的微 ...

  3. Hystrix简单介绍

    Netflix的Hystrix是一个帮助解决分布式系统交互超时处理和容错的类库,同样拥有保护系统的能力. 服务隔离 服务降级 1.服务隔离 在一个系统中,一个业务通常会依赖多个服务,且这若干个服务的调 ...

  4. hystrix应用介绍(四)

    前几章已经讲了hystrix的应用场景,以及如何使用,本章我们针对如何进行hystrix参数配置做一些分析 //异步的执行 @HystrixCommand(groupKey = "testK ...

  5. hystrix应用介绍(三)

    hystrix提供了两种隔离策略:线程池隔离和信号量隔离.hystrix默认采用线程池隔离. 1.线程池隔离 不同服务通过使用不同线程池,彼此间将不受影响,达到隔离效果. 例如: 我们可以通过andT ...

  6. hystrix应用介绍(二)

    上篇博客中讲了hystrix在公司中的一些应用场景,由于保密的原因没办法贴出优化的代码,这里专门写一篇hystrix代码的demo,供大家在使用的过程中快速上手 Hystrix有两个请求命令 Hyst ...

  7. Hystrix的介绍(断路、降级)

    在大中型分布式系统中,通常系统很多依赖(HTTP,hession,Netty,Dubbo等),如下图:     在高并发访问下,这些依赖的稳定性与否对系统的影响非常大,但是依赖有很多不可控问题:如网络 ...

  8. Hystrix介绍以及服务的降级限流熔断

    (dubbo熔断,Hystrix问的少) 无论是缓存层还是存储层都会有出错的概率,可以将它们视同为资源.作为并发量较大的系统,假如有一个资源不可用,可能会造成线程全部 hang (挂起)在这个资源上, ...

  9. 【第十九章】 springboot &plus; hystrix(1)

    hystrix是微服务中用于做熔断.降级的工具. 作用:防止因为一个服务的调用失败.调用延时导致多个请求的阻塞以及多个请求的调用失败. 1.pom.xml(引入hystrix-core包) 1 &lt ...

随机推荐

  1. 第三周作业(一):安装VS以及创建单元测试

    安装的时候找的是最新版本的VS2015,因为不想花钱也不想用破解版,所以用社区版本. 下了一个IOS文件,社区版VS2015,个人免费版,强行表示不用盗版来表现自己高尚的情操:D 放入虚拟光驱软件后, ...

  2. 中国大学MOOC-陈越、何钦铭-数据结构-2016秋期末考试

    判断题: 1-1 N2logN和NlogN2具有相同的增长速度. (2分) 1-2 对一棵平衡二叉树,所有非叶结点的平衡因子都是0,当且仅当该树是完全二叉树.(2分) 1-3 无向连通图所有顶点的度之 ...

  3. 一篇文章,读懂 Netty 的高性能架构之道

    原文 Netty是一个高性能.异步事件驱动的NIO框架,它提供了对TCP.UDP和文件传输的支持,作为一个异步NIO框架,Netty的所有IO操作都是异步非阻塞的,通过Future-Listener机 ...

  4. 实验12:Problem H&colon; 整型数组运算符重载

    Home Web Board ProblemSet Standing Status Statistics   Problem H: 整型数组运算符重载 Problem H: 整型数组运算符重载 Tim ...

  5. 精通iOS开发&lpar;第5版&rpar;

    <精通iOS开发(第5版)> 基本信息 原书名:Beginning ios 6 development:exploring the ios sdk 作者: (美)David Mark   ...

  6. angularjs 利用&dollar;http 请求出现 400 Bad Request

    1. 出现400错误-代表错误的请求,说明我们的参数有问题 说明此时传入的参数存在问题,我们看下此时参数的格式是什么: 此时的参数是对象格式,查了一下,如果利用ajax格式传输数据的话,参数必须是js ...

  7. Android 针对单个Activity设置状态栏颜色

    代码如下: if (Build.VERSION.SDK_INT >= Build.VERSION_CODES.LOLLIPOP) {//因为不是所有的系统都可以设置颜色的,在4.4以下就不可以. ...

  8. Javaweb学习笔记——(二十一)——————过滤器

    过滤器     过滤器概述         1.什么是过滤器:             过滤器javaweb三大组件之一,它与Serlvet很相似,不过它过滤器是用来拦截请求的,而不是处理       ...

  9. mysql分库分区分表

    分表: 分表分为水平分表和垂直分表. 水平分表原理: 分表策略通常是用户ID取模,如果不是整数,可以首先将其进行hash获取到整. 水平分表遇到的问题: 1. 跨表直接连接查询无法进行 2. 我们需要 ...

  10. Eclipse&sol;MyEclipse上配置Spring环境

    在MyEclipse上配置Spring环境 myeclipse其实已经集成Spring的开发环境,我们只需在新建的项目上添加spring的配置环境就可以 新建一个java项目 选中创建好的项目之后,在 ...