扒一扒隔离熔断之HystrixVSSentinel

惠普刘宝海

publicObservabletoObservable(){...finalFunc0>applyHystrixSemantics=newFunc0>(){@OverridepublicObservablecall(){if(commandState.get().equals(CommandState.UNSUBSCRIBED)){returnObservable.never();}returnapplyHystrixSemantics(_cmd);//1.关键步骤，命令处理}};...privateObservableapplyHystrixSemantics(finalAbstractCommand_cmd){...if(circuitBreaker.attemptExecution()){//1.【断路器相关处理】，之后HystrixCircuitBreaker中展示..if(executionSemaphore.tryAcquire()){//2.获取信号量，如果是THREAD线程池策略，【直接返回true】，这里需要注意，不然流程将进行不下去try{executionResult=executionResult.setInvocationStartTime(System.currentTimeMillis());returnexecuteCommandAndObserve(_cmd)//3.核心执行方法.doOnError(markExceptionThrown).doOnTerminate(singleSemaphoreRelease).doOnUnsubscribe(singleSemaphoreRelease);}...}