本文共 3175 字，大约阅读时间需要 10 分钟。

1 pom.xml

       
    
     com.netflix.hystrix
        
    
     hystrix-core
        
    
     1.5.12
    
   

2 将商品服务接口调用的逻辑进行封装

hystrix进行资源隔离，其实是提供了一个抽象，叫做command

• 资源隔离
  对这个依赖服务的所有调用请求，全部走这个资源池内的资源，不会去用其他的资源

hystrix最基本的资源隔离的技术 — 线程池隔离技术

对某一个依赖服务，商品服务，所有的调用请求，全部隔离到一个线程池内，对商品服务的每次调用请求都封装在一个command里面

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

不让超出这个量的请求去执行了，保护说，不要因为某一个依赖服务的故障，导致耗尽了缓存服务中的所有的线程资源去执行

3 开发一个支持批量商品变更的接口

• HystrixCommand
  获取一条数据
• HystrixObservableCommand：是设计用来获取多条数据的

public class ObservableCommandHelloWorld extends HystrixObservableCommand
   
     {    private final String name;    public ObservableCommandHelloWorld(String name) {        super(HystrixCommandGroupKey.Factory.asKey("ExampleGroup"));        this.name = name;    }    @Override    protected Observable
    
      construct() {        return Observable.create(new Observable.OnSubscribe
     
      () {            @Override            public void call(Subscriber
       observer) {                try {                    if (!observer.isUnsubscribed()) {                        observer.onNext("Hello " + name + "!");                        observer.onNext("Hi " + name + "!");                        observer.onCompleted();                    }                } catch (Exception e) {                    observer.onError(e);                }            }         } ).subscribeOn(Schedulers.io());    }}
     
    
   

4 command的调用方式

4.1 同步

new CommandHelloWorld("World").execute()，new ObservableCommandHelloWorld("World").toBlocking().toFuture().get()

如果你认为observable command只会返回一条数据，那么可以调用上面的模式，去同步执行，返回一条数据

4.2 异步

new CommandHelloWorld("World").queue()，new ObservableCommandHelloWorld("World").toBlocking().toFuture()

对command调用queue()，仅仅将command放入线程池的一个等待队列，就立即返回，拿到一个Future对象，后面可以做一些其他的事情，然后过一段时间对future调用get()方法获取数据

// observe()：hot，已经执行过了// toObservable(): cold，还没执行过Observable
   
     fWorld = new CommandHelloWorld("World").observe();assertEquals("Hello World!", fWorld.toBlocking().single());fWorld.subscribe(new Observer
    
     () {    @Override    public void onCompleted() {    }    @Override    public void onError(Throwable e) {        e.printStackTrace();    }    @Override    public void onNext(String v) {        System.out.println("onNext: " + v);    }});Observable
     
       fWorld = new ObservableCommandHelloWorld("World").toObservable();assertEquals("Hello World!", fWorld.toBlocking().single());fWorld.subscribe(new Observer
      
       () {    @Override    public void onCompleted() {    }    @Override    public void onError(Throwable e) {        e.printStackTrace();    }    @Override    public void onNext(String v) {        System.out.println("onNext: " + v);    }});
      
     
    
   

5 如何解决刚才的问题

资源隔离后的效果

• 资源隔离生效的讲解
  

转载地址：https://javaedge.blog.csdn.net/article/details/95900748 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！