クラス ThreadAffinityClientConnectionFactory
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
org.springframework.integration.ip.tcp.connection.AbstractClientConnectionFactory
org.springframework.integration.ip.tcp.connection.ThreadAffinityClientConnectionFactory
- 実装済みのインターフェース一覧:
Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, ComponentSourceAware, ExpressionCapable, ConnectionFactory, NamedComponent, ManageableLifecycle
接続をスレッドにバインドするクライアント接続ファクトリ。クローズ操作は無視されます。接続を物理的に閉じてローカルスレッドを解放するには、
releaseConnection() を呼び出します。- 導入:
- 5.0
- 作成者:
- Gary Russell
ネストされたクラスの概要
クラス AbstractConnectionFactory から継承されたネストクラス / インターフェース
AbstractConnectionFactory.PendingIOフィールド概要
クラス AbstractConnectionFactory から継承されたフィールド
connectionsMonitor, DEFAULT_REPLY_TIMEOUT, lifecycleMonitorクラス IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerコンストラクター概要
コンストラクターコンストラクター説明ThreadAffinityClientConnectionFactory(AbstractClientConnectionFactory connectionFactory) 方法の概要
修飾子と型メソッド説明booleancloseConnection(StringSE connectionId) 指定された接続 ID の接続を閉じます。voidこのファクトリによって作成された接続に自動的に(デフォルト)またはTcpListenerを追加するかどうかを設定します。voidforceClose(TcpConnection connection) 接続を強制的に閉じ、共有接続の場合はフィールドを null にします。@Nullable StringSEApplicationContextが使用可能な場合は、ApplicationContext.getId()を返します。IntegrationObjectSupport.componentNameフィールドで識別されるこのコンポーネントの名前を返します。接続を取得します。AbstractConnectionFactory.setSingleUse(boolean)が true で呼び出された場合、新しい接続が返されます。それ以外の場合、接続が開いたままの状態で、単一の接続がすべてのリクエストに再利用されます。Deserializer<?> @Nullable Expressionこのコンポーネントが式ベースの場合、プライマリ SpEL 式を返します。@Nullable StringSEgetHost()@Nullable TcpListener(現在)開いているTcpConnection接続 ID のリストを返します。たとえば、開いているすべての接続へのブロードキャスト操作を許可します。intgetPort()@Nullable TcpSender送信者のリストを返します。Serializer<?> intintintintintbooleanbooleanbooleanbooleanvoidregisterListener(TcpListener listener) ペイロードが入力データから変換された後、メッセージを受信するために TcpListener を登録します。voidregisterSender(TcpSender sender) TcpSender を登録します。サーバーソケットの場合、接続情報を提供するために使用されるため、送信者は受信メッセージに返信するために使用できます。voidvoidsetApplicationContext(ApplicationContext applicationContext) voidsetApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher) voidsetBeanFactory(BeanFactory beanFactory) voidsetChannelResolver(DestinationResolver<MessageChannel> channelResolver) 使用するDestinationResolver戦略を指定します。voidsetComponentName(StringSE componentName) このコンポーネントの名前を設定します。voidsetDeserializer(Deserializer<?> deserializer) voidホストを設定します。ファクトリを停止する必要があります。voidsetInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain) voidsetLookupHost(boolean lookupHost) true の場合、リモート IP アドレスで DNS 逆ルックアップが行われます。voidsetMapper(TcpMessageMapper mapper) voidsetMessageBuilderFactory(MessageBuilderFactory messageBuilderFactory) voidsetNioHarvestInterval(int nioHarvestInterval) soTimeout が 0 の場合に閉じられた NIO 接続をクリーンアップする頻度。voidsetPort(int port) ポートを設定します。ファクトリを停止する必要があります。voidsetReadDelay(long readDelay) 前の試行がスレッド不足のために失敗した後、読み取りを再試行するまでの遅延(ミリ秒)。voidsetSerializer(Serializer<?> serializer) voidsetSoKeepAlive(boolean soKeepAlive) voidsetSoLinger(int soLinger) voidsetSoReceiveBufferSize(int soReceiveBufferSize) voidsetSoSendBufferSize(int soSendBufferSize) voidsetSoTcpNoDelay(boolean soTcpNoDelay) voidsetSoTimeout(int soTimeout) voidsetSoTrafficClass(int soTrafficClass) voidsetSslHandshakeTimeout(int sslHandshakeTimeout) SSL ハンドシェイクデータを待機するときに使用されるハンドシェイクタイムアウトを設定します。NIO を使用する場合、SSL 接続にのみ適用されます。voidsetTaskExecutor(ExecutorSE taskExecutor) voidsetTcpSocketSupport(TcpSocketSupport tcpSocketSupport) voidstart()voidstop()サーバーの停止。toString()クラス AbstractClientConnectionFactory から継承されたメソッド
buildNewConnection, getConnectionTest, getConnectTimeout, getTheConnection, initializeConnection, obtainConnection, obtainNewConnection, obtainSharedConnection, setConnectionTest, setConnectTimeout, setTheConnectionクラス AbstractConnectionFactory から継承されたメソッド
addConnection, checkActive, delayRead, doAccept, getDelayedReads, getLifecycleMonitor, getReadDelay, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isSingleUse, onInit, processNioSelections, setActive, setLeaveOpen, setSingleUse, setSocketAttributes, unregisterSender, wrapConnectionクラス IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentSource, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setBeanName, setComponentDescription, setComponentSource, setConversionService, setPrimaryExpression, setTaskScheduler
コンストラクターの詳細
ThreadAffinityClientConnectionFactory
方法の詳細
getConnection
クラスからコピーされた説明:AbstractClientConnectionFactory接続を取得します。AbstractConnectionFactory.setSingleUse(boolean)が true で呼び出された場合、新しい接続が返されます。それ以外の場合、接続が開いたままの状態で、単一の接続がすべてのリクエストに再利用されます。- 次で指定:
- インターフェース
ConnectionFactory内のgetConnection - オーバーライド:
- クラス
AbstractClientConnectionFactoryのgetConnection - 例外:
InterruptedExceptionSE- 中断された場合。
releaseConnection
public void releaseConnection()enableManualListenerRegistration
public void enableManualListenerRegistration()クラスからコピーされた説明:AbstractClientConnectionFactoryこのファクトリによって作成された接続に自動的に(デフォルト)またはTcpListenerを追加するかどうかを設定します。デフォルトでは、ファクトリはリスナーを自動的に構成します。手動登録が行われると、リスナーが登録されるまで受信メッセージが遅延します。- オーバーライド:
- クラス
AbstractClientConnectionFactoryのenableManualListenerRegistration
getComponentName
クラスからコピーされた説明:IntegrationObjectSupportIntegrationObjectSupport.componentNameフィールドで識別されるこのコンポーネントの名前を返します。IntegrationObjectSupport.componentNameが設定されていない場合、このメソッドはデフォルトでこのコンポーネントの "beanName" を使用します。- 次で指定:
- インターフェース
NamedComponent内のgetComponentName - オーバーライド:
- クラス
IntegrationObjectSupportのgetComponentName
setComponentName
クラスからコピーされた説明:IntegrationObjectSupportこのコンポーネントの名前を設定します。- オーバーライド:
- クラス
IntegrationObjectSupportのsetComponentName - パラメーター:
componentName- コンポーネント名。
setApplicationEventPublisher
- 次で指定:
- インターフェース
ApplicationEventPublisherAware内のsetApplicationEventPublisher - オーバーライド:
- クラス
AbstractConnectionFactoryのsetApplicationEventPublisher
getComponentType
- 次で指定:
- インターフェース
NamedComponent内のgetComponentType - オーバーライド:
- クラス
AbstractConnectionFactoryのgetComponentType
setBeanFactory
- 次で指定:
- インターフェース
BeanFactoryAware内のsetBeanFactory - オーバーライド:
- クラス
IntegrationObjectSupportのsetBeanFactory
setApplicationContext
- 次で指定:
- インターフェース
ApplicationContextAware内のsetApplicationContext - オーバーライド:
- クラス
IntegrationObjectSupportのsetApplicationContext - 例外:
BeansException
getApplicationEventPublisher
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetApplicationEventPublisher
setChannelResolver
クラスからコピーされた説明:IntegrationObjectSupport使用するDestinationResolver戦略を指定します。デフォルトは BeanFactoryChannelResolver です。- オーバーライド:
- クラス
IntegrationObjectSupportのsetChannelResolver - パラメーター:
channelResolver- チャネルリゾルバー。
getExpression
インターフェースからコピーされた説明:ExpressionCapableこのコンポーネントが式ベースの場合、プライマリ SpEL 式を返します。- 次で指定:
- インターフェース
ExpressionCapable内のgetExpression - オーバーライド:
- クラス
IntegrationObjectSupportのgetExpression - 戻り値:
- 文字列としての式。
forceClose
クラスからコピーされた説明:AbstractClientConnectionFactory接続を強制的に閉じ、共有接続の場合はフィールドを null にします。- オーバーライド:
- クラス
AbstractClientConnectionFactoryのforceClose - パラメーター:
connection- 接続。
getSoTimeout
public int getSoTimeout()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSoTimeout - 戻り値:
- soTimeout
setSoTimeout
public void setSoTimeout(int soTimeout) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoTimeout - パラメーター:
soTimeout- 設定する soTimeout(ミリ秒単位)
getSoReceiveBufferSize
public int getSoReceiveBufferSize()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSoReceiveBufferSize - 戻り値:
- soReceiveBufferSize
setSoReceiveBufferSize
public void setSoReceiveBufferSize(int soReceiveBufferSize) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoReceiveBufferSize - パラメーター:
soReceiveBufferSize- 設定する soReceiveBufferSize
getSoSendBufferSize
public int getSoSendBufferSize()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSoSendBufferSize - 戻り値:
- soSendBufferSize
setSoSendBufferSize
public void setSoSendBufferSize(int soSendBufferSize) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoSendBufferSize - パラメーター:
soSendBufferSize- 設定する soSendBufferSize
isSoTcpNoDelay
public boolean isSoTcpNoDelay()- オーバーライド:
- クラス
AbstractConnectionFactoryのisSoTcpNoDelay - 戻り値:
- soTcpNoDelay
setSoTcpNoDelay
public void setSoTcpNoDelay(boolean soTcpNoDelay) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoTcpNoDelay - パラメーター:
soTcpNoDelay- 設定する soTcpNoDelay
getSoLinger
public int getSoLinger()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSoLinger - 戻り値:
- soLinger
setSoLinger
public void setSoLinger(int soLinger) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoLinger - パラメーター:
soLinger- 設定する soLinger
isSoKeepAlive
public boolean isSoKeepAlive()- オーバーライド:
- クラス
AbstractConnectionFactoryのisSoKeepAlive - 戻り値:
- soKeepAlive
setSoKeepAlive
public void setSoKeepAlive(boolean soKeepAlive) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoKeepAlive - パラメーター:
soKeepAlive- 設定する soKeepAlive
getConversionService
- オーバーライド:
- クラス
IntegrationObjectSupportのgetConversionService
getSoTrafficClass
public int getSoTrafficClass()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSoTrafficClass - 戻り値:
- soTrafficClass
setSoTrafficClass
public void setSoTrafficClass(int soTrafficClass) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetSoTrafficClass - パラメーター:
soTrafficClass- 設定する soTrafficClass
setHost
クラスからコピーされた説明:AbstractConnectionFactoryホストを設定します。ファクトリを停止する必要があります。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetHost - パラメーター:
host- ザホスト。
getHost
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetHost - 戻り値:
- ザホスト
setPort
public void setPort(int port) クラスからコピーされた説明:AbstractConnectionFactoryポートを設定します。ファクトリを停止する必要があります。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetPort - パラメーター:
port- ポート。
getApplicationContextId
クラスからコピーされた説明:IntegrationObjectSupportApplicationContextが使用可能な場合は、ApplicationContext.getId()を返します。- オーバーライド:
- クラス
IntegrationObjectSupportのgetApplicationContextId - 戻り値:
- id、またはアプリケーションコンテキストがない場合は null。
getPort
public int getPort()- オーバーライド:
- クラス
AbstractConnectionFactoryのgetPort - 戻り値:
- 港
getListener
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetListener - 戻り値:
- リスナー
getSender
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSender - 戻り値:
- 存在する場合、最初の送信者。
getSenders
クラスからコピーされた説明:AbstractConnectionFactory送信者のリストを返します。- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSenders - 戻り値:
- 送信者。
getSerializer
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetSerializer - 戻り値:
- シリアライザー
getDeserializer
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetDeserializer - 戻り値:
- デシリアライザー
getMapper
- オーバーライド:
- クラス
AbstractConnectionFactoryのgetMapper - 戻り値:
- マッパー
registerListener
クラスからコピーされた説明:AbstractConnectionFactoryペイロードが入力データから変換された後、メッセージを受信するために TcpListener を登録します。- オーバーライド:
- クラス
AbstractConnectionFactoryのregisterListener - パラメーター:
listener- TcpListener。
setMessageBuilderFactory
- オーバーライド:
- クラス
IntegrationObjectSupportのsetMessageBuilderFactory
registerSender
クラスからコピーされた説明:AbstractConnectionFactoryTcpSender を登録します。サーバーソケットの場合、接続情報を提供するために使用されるため、送信者は受信メッセージに返信するために使用できます。- オーバーライド:
- クラス
AbstractConnectionFactoryのregisterSender - パラメーター:
sender- 送り主
setTaskExecutor
- オーバーライド:
- クラス
AbstractConnectionFactoryのsetTaskExecutor - パラメーター:
taskExecutor- 設定する taskExecutor
setDeserializer
- オーバーライド:
- クラス
AbstractConnectionFactoryのsetDeserializer - パラメーター:
deserializer- 設定するデシリアライザー
setSerializer
- オーバーライド:
- クラス
AbstractConnectionFactoryのsetSerializer - パラメーター:
serializer- 設定するシリアライザー
setMapper
- オーバーライド:
- クラス
AbstractConnectionFactoryのsetMapper - パラメーター:
mapper- 設定するマッパー。デフォルトはTcpMessageMapperです
setInterceptorFactoryChain
public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain) - オーバーライド:
- クラス
AbstractConnectionFactoryのsetInterceptorFactoryChain
setLookupHost
public void setLookupHost(boolean lookupHost) クラスからコピーされた説明:AbstractConnectionFactorytrue の場合、リモート IP アドレスで DNS 逆引き参照が行われます。デフォルト false: すべての環境 (例: Docker コンテナー) が信頼できる DNS 解決を実行するわけではありません。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetLookupHost - パラメーター:
lookupHost- 設定する lookupHost
isLookupHost
public boolean isLookupHost()- オーバーライド:
- クラス
AbstractConnectionFactoryのisLookupHost - 戻り値:
- lookupHost
setNioHarvestInterval
public void setNioHarvestInterval(int nioHarvestInterval) クラスからコピーされた説明:AbstractConnectionFactorysoTimeout が 0 の場合、閉じられた NIO 接続をクリーンアップする頻度。クリーンアッププロセスはタイムアウト処理の一部として実行されるため、soTimeout > 0の場合は無視されます。デフォルトは 2000 ミリ秒です。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetNioHarvestInterval - パラメーター:
nioHarvestInterval- ミリ秒単位の間隔。
setSslHandshakeTimeout
public void setSslHandshakeTimeout(int sslHandshakeTimeout) クラスからコピーされた説明:AbstractConnectionFactorySSL ハンドシェイクデータを待機するときに使用されるハンドシェイクタイムアウトを設定します。NIO を使用する場合、SSL 接続にのみ適用されます。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetSslHandshakeTimeout - パラメーター:
sslHandshakeTimeout- タイムアウト。
setReadDelay
public void setReadDelay(long readDelay) クラスからコピーされた説明:AbstractConnectionFactoryスレッドが不十分なために前回の試行が失敗した後、読み取りを再試行するまでの遅延(ミリ秒単位)。デフォルトは 100。- オーバーライド:
- クラス
AbstractConnectionFactoryのsetReadDelay - パラメーター:
readDelay- readDelay を設定します。
start
public void start()- 次で指定:
- インターフェース
Lifecycle内のstart - 次で指定:
- インターフェース
ManageableLifecycle内のstart - オーバーライド:
- クラス
AbstractConnectionFactoryのstart
stop
public void stop()クラスからコピーされた説明:AbstractConnectionFactoryサーバーの停止。- 次で指定:
- インターフェース
Lifecycle内のstop - 次で指定:
- インターフェース
ManageableLifecycle内のstop - オーバーライド:
- クラス
AbstractConnectionFactoryのstop
isRunning
public boolean isRunning()- 次で指定:
- インターフェース
Lifecycle内のisRunning - 次で指定:
- インターフェース
ManageableLifecycle内のisRunning - オーバーライド:
- クラス
AbstractConnectionFactoryのisRunning
setTcpSocketSupport
- オーバーライド:
- クラス
AbstractConnectionFactoryのsetTcpSocketSupport
getOpenConnectionIds
クラスからコピーされた説明:AbstractConnectionFactory(現在)開いているTcpConnection接続 ID のリストを返します。たとえば、開いているすべての接続へのブロードキャスト操作を許可します。- オーバーライド:
- クラス
AbstractConnectionFactoryのgetOpenConnectionIds - 戻り値:
- 接続 ID のリスト。
closeConnection
クラスからコピーされた説明:AbstractConnectionFactory指定された接続 ID の接続を閉じます。- オーバーライド:
- クラス
AbstractConnectionFactoryのcloseConnection - パラメーター:
connectionId- 接続 ID。- 戻り値:
- 接続が閉じられた場合は true。
toString
- オーバーライド:
- クラス
AbstractConnectionFactoryのtoString