hystrix:

  command:

    #全局默认配置

    default:

      #线程隔离相关（执行相关）

      execution:

        timeout:

          enabled: false

        isolation:

          #配置请求隔离的方式，这里是默认的线程池方式。还有一种信号量的方式semaphore，使用比较少。

          strategy: THREAD

          thread:

            #方式执行的超时时间，默认为1000毫秒，在实际场景中需要根据情况设置

            timeoutInMilliseconds: 1000

            #发生超时时是否中断方法的执行，默认值为true。不要改。

            interruptOnTimeout: true

            #是否在方法执行被取消时中断方法，默认值为false。没有实际意义，默认就好！

            interruptOnCancel: false

hystrix:

  command:

    #全局默认配置

    default:

      #熔断器相关配置

      circuitBreaker:

        #说明：是否启动熔断器，默认为true。

        enabled: false

        #说明1：启用熔断器功能窗口时间内的最小请求数，假设我们设置的窗口时间为10秒，

        #说明2：那么如果此时默认值为20的话，那么即便10秒内有19个请求都失败也不会打开熔断器。

        #说明3：此配置项需要根据接口的QPS进行计算，值太小会有误打开熔断器的可能，而如果值太大超出了时间窗口内的总请求数，则熔断永远也不会被触发

        #说明4：建议设置一般为：QPS*窗口描述*60%

        requestVolumeThreshold: 20

        #说明1：熔断器被打开后，所有的请求都会被快速失败掉，但是何时恢复服务是一个问题。熔断器打开后，Hystrix会在经过一段时间后就放行一条请求

        #说明2：如果请求能够执行成功，则说明此时服务可能已经恢复了正常，那么熔断器会关闭；相反执行失败，则认为服务仍然不可用，熔断器保持打开。

        #说明3：所以此配置的作用是指定熔断器打开后多长时间内允许一次请求尝试执行，官方默认配置为5秒。

        sleepWindowInMilliseconds: 5000

        #说明1:该配置是指在通过滑动窗口获取到当前时间段内Hystrix方法执行失败的几率后，根据此配置来判断是否需要打开熔断器

        #说明2:这里官方的默认配置为50，即窗口时间内超过50%的请求失败后就会打开熔断器将后续请求快速失败掉

        errorThresholdPercentage: 50

Future<EpgFilterRespDTO> future = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),

                "204.101.161.159", 20000030, "2.3",80000013,

                "zh_tw", "tw", PlatformEnum.APPLE_TV)).queue();//异步方式

        Observable<EpgFilterRespDTO> observable = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),

                "204.101.161.159", 20000030, "2.3",80000013,

                "zh_tw", "tw", PlatformEnum.APPLE_TV)).observe();//热观察

        System.out.println(observable.toBlocking().single())//直接获取

        Observable<EpgFilterRespDTO> toobservable = epgInfoClient.epgFilterFuture(EpgFilterReqDTO.of(Lists.newArrayList(2447052500L),

                "204.101.161.159", 20000030, "2.3",80000013,

                "zh_tw", "tw", PlatformEnum.APPLE_TV)).toObservable();//冷观察

observable.subscribe(new Observer<EpgFilterRespDTO>() {

    @Override

    public void onCompleted() {

        System.out.println();

    }

    @Override

    public void onError(Throwable throwable) {

        System.out.println(throwable);

    }

    @Override

    public void onNext(EpgFilterRespDTO epgFilterRespDTO) {

        System.out.println(epgFilterRespDTO);

    }

});

toobservable.subscribe(new Observer<EpgFilterRespDTO>() {

    @Override

    public void onCompleted() {

        System.out.println();

    }

    @Override

    public void onError(Throwable throwable) {

        System.out.println(throwable);

    }

    @Override

    public void onNext(EpgFilterRespDTO epgFilterRespDTO) {

        System.out.println(epgFilterRespDTO);

    }

});