微服务组件--限流框架Spring Cloud Hystrix分析( 三 ) _生活百科

【6】分析HystrixInvokable的创建【层层追溯，其实发现是生成一个包装过的HystrixCommand】
//分析HystrixInvokable的创建public HystrixInvokable create(MetaHolder metaHolder) {HystrixInvokable executable;//判断是不是HystrixCollapser注解if (metaHolder.isCollapserAnnotationPresent()) {executable = new CommandCollapser(metaHolder);} else if (metaHolder.isObservable()) {executable = new GenericObservableCommand(HystrixCommandBuilderFactory.getInstance().create(metaHolder));} else {//主要是这里executable = new GenericCommand(HystrixCommandBuilderFactory.getInstance().create(metaHolder));}return executable;}public GenericCommand(HystrixCommandBuilder builder) {super(builder);}protected AbstractHystrixCommand(HystrixCommandBuilder builder) {super(builder.getSetterBuilder().build());this.commandActions = builder.getCommandActions();this.collapsedRequests = builder.getCollapsedRequests();this.cacheResultInvocationContext = builder.getCacheResultInvocationContext();this.cacheRemoveInvocationContext = builder.getCacheRemoveInvocationContext();this.ignoreExceptions = builder.getIgnoreExceptions();this.executionType = builder.getExecutionType();}HystrixCommand(HystrixCommandGroupKey group, HystrixCommandKey key, HystrixThreadPoolKey threadPoolKey, HystrixCircuitBreaker circuitBreaker, HystrixThreadPool threadPool,HystrixCommandProperties.Setter commandPropertiesDefaults, HystrixThreadPoolProperties.Setter threadPoolPropertiesDefaults,HystrixCommandMetrics metrics, TryableSemaphore fallbackSemaphore, TryableSemaphore executionSemaphore,HystrixPropertiesStrategy propertiesStrategy, HystrixCommandExecutionHook executionHook) {super(group, key, threadPoolKey, circuitBreaker, threadPool, commandPropertiesDefaults, threadPoolPropertiesDefaults, metrics, fallbackSemaphore, executionSemaphore, propertiesStrategy, executionHook);}protected AbstractCommand(HystrixCommandGroupKey group, HystrixCommandKey key, HystrixThreadPoolKey threadPoolKey, HystrixCircuitBreaker circuitBreaker, HystrixThreadPool threadPool,HystrixCommandProperties.Setter commandPropertiesDefaults, HystrixThreadPoolProperties.Setter threadPoolPropertiesDefaults,HystrixCommandMetrics metrics, TryableSemaphore fallbackSemaphore, TryableSemaphore executionSemaphore,HystrixPropertiesStrategy propertiesStrategy, HystrixCommandExecutionHook executionHook) {this.commandGroup = initGroupKey(group);this.commandKey = initCommandKey(key, getClass());this.properties = initCommandProperties(this.commandKey, propertiesStrategy, commandPropertiesDefaults);this.threadPoolKey = initThreadPoolKey(threadPoolKey, this.commandGroup, this.properties.executionIsolationThreadPoolKeyOverride().get());this.metrics = initMetrics(metrics, this.commandGroup, this.threadPoolKey, this.commandKey, this.properties);this.circuitBreaker = initCircuitBreaker(this.properties.circuitBreakerEnabled().get(), circuitBreaker, this.commandGroup, this.commandKey, this.properties, this.metrics);this.threadPool = initThreadPool(threadPool, this.threadPoolKey, threadPoolPropertiesDefaults);//Strategies from pluginsthis.eventNotifier = HystrixPlugins.getInstance().getEventNotifier();this.concurrencyStrategy = HystrixPlugins.getInstance().getConcurrencyStrategy();HystrixMetricsPublisherFactory.createOrRetrievePublisherForCommand(this.commandKey, this.commandGroup, this.metrics, this.circuitBreaker, this.properties);this.executionHook = initExecutionHook(executionHook);this.requestCache = HystrixRequestCache.getInstance(this.commandKey, this.concurrencyStrategy);this.currentRequestLog = initRequestLog(this.properties.requestLogEnabled().get(), this.concurrencyStrategy);/* fallback semaphore override if applicable */this.fallbackSemaphoreOverride = fallbackSemaphore;/* execution semaphore override if applicable */this.executionSemaphoreOverride = executionSemaphore;}【7】那么接下来分析CommandExecutor.execute做了什么
public static Object execute(HystrixInvokable invokable, ExecutionType executionType, MetaHolder metaHolder) throws RuntimeException {Validate.notNull(invokable);Validate.notNull(metaHolder);switch (executionType) {//基于上面构成先分析同步方法case SYNCHRONOUS: {//调用HystrixCommandreturn castToExecutable(invokable, executionType).execute();}case ASYNCHRONOUS: {HystrixExecutable executable = castToExecutable(invokable, executionType);if (metaHolder.hasFallbackMethodCommand()&& ExecutionType.ASYNCHRONOUS == metaHolder.getFallbackExecutionType()) {return new FutureDecorator(executable.queue());}return executable.queue();}case OBSERVABLE: {HystrixObservable observable = castToObservable(invokable);return ObservableExecutionMode.EAGER == metaHolder.getObservableExecutionMode() ? observable.observe() : observable.toObservable();}default:throw new RuntimeException("unsupported execution type: " + executionType);}}//HystrixCommand类#execute方法public R execute() {try {//利用了Future模式return queue().get();} catch (Exception e) {throw Exceptions.sneakyThrow(decomposeException(e));}}【8】分析queue()方法怎么使用Future模式的

微服务组件--限流框架Spring Cloud Hystrix分析( 三 )

推荐阅读

忘带驾驶证了怎么处理违章忘带驾驶证了怎么处理

树葡萄几年才能结果葡萄几年能结果

可复制的漂亮特殊符号网名，符号网名大全花样符号

小数的意义是什么意思

兔子和猪的属相性格合不合，猪和兔的属相合不合(讲解)

巨蟹座女生和双鱼座男生配对

关于联想thinkpad x1的基本详情介绍联想thinkpad x1

咖啡加盐有什么功效咖啡里加盐怎么样啊

最特别的名字最特别的1985年

守财奴是什么意思

百度三维地图，百度三维地图

京东购物文胸，京东商城文胸无钢圈？

双子座2021年下半年运势，2021年下半年双子座桃花劫是几月份

鹅蛋炒香椿芽的功效与作用香椿芽的功效与作用

苹果x换屏多少钱2022 苹果x换屏多少钱

心理素质异常强大的星座

2023年养老金到底怎么涨？22年养老金总体涨了4%算是多少？

两人打架一方轻微伤的依据是什么

风雨木林系统win7官方下载地址风木雨林win7系统哪个网站比较好

同时是3和5的倍数的特征是什么 3和5的倍数的共同特征是什么