org.apache.shenyu.plugin.hystrix.command

类 HystrixCommandOnThread

java.lang.Object

com.netflix.hystrix.HystrixCommand<reactor.core.publisher.Mono<java.lang.Void>>

org.apache.shenyu.plugin.hystrix.command.HystrixCommandOnThread

所有已实现的接口:

com.netflix.hystrix.HystrixExecutable<reactor.core.publisher.Mono<java.lang.Void>>, com.netflix.hystrix.HystrixInvokable<reactor.core.publisher.Mono<java.lang.Void>>, com.netflix.hystrix.HystrixInvokableInfo<reactor.core.publisher.Mono<java.lang.Void>>, com.netflix.hystrix.HystrixObservable<reactor.core.publisher.Mono<java.lang.Void>>, org.apache.shenyu.plugin.base.fallback.FallbackHandler, Command

public class HystrixCommandOnThread
extends com.netflix.hystrix.HystrixCommand<reactor.core.publisher.Mono<java.lang.Void>>
implements Command

hystrix command in thread isolation mode.

嵌套类概要

嵌套类

限定符和类型	类和说明
protected static class	com.netflix.hystrix.AbstractCommand.CommandState
protected static class	com.netflix.hystrix.AbstractCommand.ThreadState
protected static class	com.netflix.hystrix.AbstractCommand.TimedOutStatus

从类继承的嵌套类/接口 com.netflix.hystrix.HystrixCommand

com.netflix.hystrix.HystrixCommand.Setter

字段概要

字段

限定符和类型	字段和说明
protected com.netflix.hystrix.HystrixCircuitBreaker	circuitBreaker
protected static java.util.concurrent.ConcurrentHashMap<com.netflix.hystrix.HystrixCommandKey,java.lang.Boolean>	commandContainsFallback
protected com.netflix.hystrix.HystrixCommandGroupKey	commandGroup
protected com.netflix.hystrix.HystrixCommandKey	commandKey
protected long	commandStartTimestamp
protected java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.CommandState>	commandState
protected com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy	concurrencyStrategy
protected com.netflix.hystrix.HystrixRequestLog	currentRequestLog
protected rx.functions.Action0	endCurrentThreadExecutingCommand
protected com.netflix.hystrix.strategy.eventnotifier.HystrixEventNotifier	eventNotifier
protected com.netflix.hystrix.strategy.executionhook.HystrixCommandExecutionHook	executionHook
protected com.netflix.hystrix.ExecutionResult	executionResult
protected com.netflix.hystrix.ExecutionResult	executionResultAtTimeOfCancellation
protected com.netflix.hystrix.AbstractCommand.TryableSemaphore	executionSemaphoreOverride
protected static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.netflix.hystrix.AbstractCommand.TryableSemaphore>	executionSemaphorePerCircuit
protected com.netflix.hystrix.AbstractCommand.TryableSemaphore	fallbackSemaphoreOverride
protected static java.util.concurrent.ConcurrentHashMap<java.lang.String,com.netflix.hystrix.AbstractCommand.TryableSemaphore>	fallbackSemaphorePerCircuit
protected java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.TimedOutStatus>	isCommandTimedOut
protected boolean	isResponseFromCache
protected com.netflix.hystrix.HystrixCommandMetrics	metrics
protected com.netflix.hystrix.HystrixCommandProperties	properties
protected com.netflix.hystrix.HystrixRequestCache	requestCache
protected com.netflix.hystrix.HystrixThreadPool	threadPool
protected com.netflix.hystrix.HystrixThreadPoolKey	threadPoolKey
protected java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.ThreadState>	threadState
protected java.util.concurrent.atomic.AtomicReference<java.lang.ref.Reference<com.netflix.hystrix.util.HystrixTimer.TimerListener>>	timeoutTimer

从接口继承的字段 org.apache.shenyu.plugin.base.fallback.FallbackHandler

PREFIX

构造器概要

构造器

构造器和说明
HystrixCommandOnThread(com.netflix.hystrix.HystrixCommand.Setter setter, org.springframework.web.server.ServerWebExchange exchange, org.apache.shenyu.plugin.api.ShenyuPluginChain chain, java.lang.String callBackUri) Instantiates a new Http command.

方法概要

限定符和类型	方法和说明
void	cleanCommand() clean all command.
protected java.lang.Throwable	decomposeException(java.lang.Exception arg0)
rx.Observable<java.lang.Void>	fetchObservable() wrap fetch Observable in HystrixCommand and HystrixCommandOnThread.
protected java.lang.String	getCacheKey()
java.net.URI	getCallBackUri() get call back uri.
protected java.lang.Exception	getExceptionFromThrowable(java.lang.Throwable arg0)
protected com.netflix.hystrix.AbstractCommand.TryableSemaphore	getExecutionSemaphore()
protected reactor.core.publisher.Mono<java.lang.Void>	getFallback()
protected com.netflix.hystrix.AbstractCommand.TryableSemaphore	getFallbackSemaphore()
protected java.lang.String	getLogMessagePrefix()
protected void	handleThreadEnd(com.netflix.hystrix.AbstractCommand<R> arg0)
protected boolean	isRequestCachingEnabled()
void	removeCommandKey(java.lang.String commandKey) removeCommandKey rule data.
protected reactor.core.publisher.Mono<java.lang.Void>	run()
protected boolean	shouldNotBeWrapped(java.lang.Throwable arg0)
protected boolean	shouldOutputOnNextEvents()

从类继承的方法 com.netflix.hystrix.HystrixCommand

commandIsScalar, execute, getExecutionObservable, getFallbackMethodName, getFallbackObservable, isFallbackUserDefined, queue

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.shenyu.plugin.hystrix.command.Command

isCircuitBreakerOpen, withoutFallback

从接口继承的方法 org.apache.shenyu.plugin.base.fallback.FallbackHandler

fallback

字段详细资料

circuitBreaker

protected final com.netflix.hystrix.HystrixCircuitBreaker circuitBreaker

threadPool

protected final com.netflix.hystrix.HystrixThreadPool threadPool

threadPoolKey

protected final com.netflix.hystrix.HystrixThreadPoolKey threadPoolKey

properties

protected final com.netflix.hystrix.HystrixCommandProperties properties

metrics

protected final com.netflix.hystrix.HystrixCommandMetrics metrics

commandKey

protected final com.netflix.hystrix.HystrixCommandKey commandKey

commandGroup

protected final com.netflix.hystrix.HystrixCommandGroupKey commandGroup

eventNotifier

protected final com.netflix.hystrix.strategy.eventnotifier.HystrixEventNotifier eventNotifier

concurrencyStrategy

protected final com.netflix.hystrix.strategy.concurrency.HystrixConcurrencyStrategy concurrencyStrategy

executionHook

protected final com.netflix.hystrix.strategy.executionhook.HystrixCommandExecutionHook executionHook

fallbackSemaphoreOverride

protected final com.netflix.hystrix.AbstractCommand.TryableSemaphore fallbackSemaphoreOverride

fallbackSemaphorePerCircuit

protected static final java.util.concurrent.ConcurrentHashMap<java.lang.String,com.netflix.hystrix.AbstractCommand.TryableSemaphore> fallbackSemaphorePerCircuit

executionSemaphoreOverride

protected final com.netflix.hystrix.AbstractCommand.TryableSemaphore executionSemaphoreOverride

executionSemaphorePerCircuit

protected static final java.util.concurrent.ConcurrentHashMap<java.lang.String,com.netflix.hystrix.AbstractCommand.TryableSemaphore> executionSemaphorePerCircuit

timeoutTimer

protected final java.util.concurrent.atomic.AtomicReference<java.lang.ref.Reference<com.netflix.hystrix.util.HystrixTimer.TimerListener>> timeoutTimer

commandState

protected java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.CommandState> commandState

threadState

protected java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.ThreadState> threadState

executionResult

protected volatile com.netflix.hystrix.ExecutionResult executionResult

isResponseFromCache

protected volatile boolean isResponseFromCache

executionResultAtTimeOfCancellation

protected volatile com.netflix.hystrix.ExecutionResult executionResultAtTimeOfCancellation

commandStartTimestamp

protected volatile long commandStartTimestamp

isCommandTimedOut

protected final java.util.concurrent.atomic.AtomicReference<com.netflix.hystrix.AbstractCommand.TimedOutStatus> isCommandTimedOut

endCurrentThreadExecutingCommand

protected volatile rx.functions.Action0 endCurrentThreadExecutingCommand

requestCache

protected final com.netflix.hystrix.HystrixRequestCache requestCache

currentRequestLog

protected final com.netflix.hystrix.HystrixRequestLog currentRequestLog

commandContainsFallback

protected static java.util.concurrent.ConcurrentHashMap<com.netflix.hystrix.HystrixCommandKey,java.lang.Boolean> commandContainsFallback

构造器详细资料

HystrixCommandOnThread

public HystrixCommandOnThread(com.netflix.hystrix.HystrixCommand.Setter setter,
                              org.springframework.web.server.ServerWebExchange exchange,
                              org.apache.shenyu.plugin.api.ShenyuPluginChain chain,
                              java.lang.String callBackUri)

Instantiates a new Http command.

参数:

setter - the setter

exchange - the exchange

chain - the chain

callBackUri - the call back uri

方法详细资料

run

protected reactor.core.publisher.Mono<java.lang.Void> run()

指定者:

run 在类中 com.netflix.hystrix.HystrixCommand<reactor.core.publisher.Mono<java.lang.Void>>

getFallback

protected reactor.core.publisher.Mono<java.lang.Void> getFallback()

覆盖:

getFallback 在类中 com.netflix.hystrix.HystrixCommand<reactor.core.publisher.Mono<java.lang.Void>>

fetchObservable

public rx.Observable<java.lang.Void> fetchObservable()

从接口复制的说明: Command

wrap fetch Observable in HystrixCommand and HystrixCommandOnThread.

指定者:

fetchObservable 在接口中 Command

返回:

Observable<R> that executes and calls back with the result of command execution or a fallback if the command fails for any reason.

getCallBackUri

public java.net.URI getCallBackUri()

从接口复制的说明: Command

get call back uri.

指定者:

getCallBackUri 在接口中 Command

返回:

when some error occurs in hystrix invoke it will forward to this

removeCommandKey

public void removeCommandKey(java.lang.String commandKey)

从接口复制的说明: Command

removeCommandKey rule data.

指定者:

removeCommandKey 在接口中 Command

参数:

commandKey - commandKey

cleanCommand

public void cleanCommand()

从接口复制的说明: Command

clean all command.

指定者:

cleanCommand 在接口中 Command

shouldNotBeWrapped

protected boolean shouldNotBeWrapped(java.lang.Throwable arg0)

handleThreadEnd

protected void handleThreadEnd(com.netflix.hystrix.AbstractCommand<R> arg0)

shouldOutputOnNextEvents

protected boolean shouldOutputOnNextEvents()

getFallbackSemaphore

protected com.netflix.hystrix.AbstractCommand.TryableSemaphore getFallbackSemaphore()

getExecutionSemaphore

protected com.netflix.hystrix.AbstractCommand.TryableSemaphore getExecutionSemaphore()

decomposeException

protected java.lang.Throwable decomposeException(java.lang.Exception arg0)

getCacheKey

protected java.lang.String getCacheKey()

isRequestCachingEnabled

protected boolean isRequestCachingEnabled()

getLogMessagePrefix

protected java.lang.String getLogMessagePrefix()

getExceptionFromThrowable

protected java.lang.Exception getExceptionFromThrowable(java.lang.Throwable arg0)