TcpNioServerConnectionFactory (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory
  - - org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory
    - - org.springframework.integration.ip.tcp.connection.TcpNioServerConnectionFactory

実装されたすべてのインターフェース:
RunnableSE, Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, ExpressionCapable, OrderlyShutdownCapable, ConnectionFactory, TcpServerConnectionFactory, NamedComponent, ManageableLifecycle, SchedulingAwareRunnable
```
public class TcpNioServerConnectionFactory
extends AbstractServerConnectionFactory
```
/** Implements a server connection factory that produces TcpNioConnection s using a ServerSocketChannelSE . Must have a TcpListener registered.
導入:
2.0
作成者:
Gary Russell, Artem Bilan

フィールドのサマリー
- クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたフィールド
  DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger

コンストラクターの概要
コンストラクター
コンストラクターと説明
TcpNioServerConnectionFactory(int port)
ポートの受信接続を待機します。

コンストラクター
コンストラクターと説明
`TcpNioServerConnectionFactory(int port)` ポートの受信接続を待機します。

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`doAccept(SelectorSE selectorForNewSocket, ServerSocketChannelSE server, long now)`
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`protected MapSE<SocketChannelSE, TcpNioConnection>`	`getConnections()`
`int`	`getPort()` このサーバーがリッスンしているポートを返します。
`protected ServerSocketChannelSE`	`getServerChannel()`
`SocketAddressSE`	`getServerSocketAddress()` 基になる `ServerSocket` がバインドされている `SocketAddress`SE を返します。
`protected boolean`	`isUsingDirectBuffers()`
`void`	`run()` リスナーが登録されていない場合は、終了します。
`void`	`setMultiAccept(boolean multiAccept)` false に設定すると、セレクターキーを介した反復ごとに 1 つの接続のみが受け入れられます。
`void`	`setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)`
`void`	`setUsingDirectBuffers(boolean usingDirectBuffers)`
`void`	`stop()` サーバーの停止。

クラス org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory から継承されたメソッド
afterShutdown, beforeShutdown, getBacklog, getConnection, getLocalAddress, initializeConnection, isListening, isLongLived, isShuttingDown, postProcessServerSocket, publishServerExceptionEvent, publishServerListeningEvent, setBacklog, setListening, setLocalAddress, start

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたメソッド
addConnection, checkActive, closeConnection, delayRead, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getLifecycleMonitor, getListener, getMapper, getOpenConnectionIds, getReadDelay, getSender, getSenders, getSerializer, getSoLinger, getSoReceiveBufferSize, getSoSendBufferSize, getSoTimeout, getSoTrafficClass, getSslHandshakeTimeout, getTaskExecutor, getTcpSocketSupport, harvestClosedConnections, isActive, isLookupHost, isRunning, isSingleUse, isSoKeepAlive, isSoTcpNoDelay, onInit, processNioSelections, registerListener, registerSender, setActive, setApplicationEventPublisher, setDeserializer, setHost, setInterceptorFactoryChain, setLeaveOpen, setLookupHost, setMapper, setNioHarvestInterval, setPort, setReadDelay, setSerializer, setSingleUse, setSocketAttributes, setSoKeepAlive, setSoLinger, setSoReceiveBufferSize, setSoSendBufferSize, setSoTcpNoDelay, setSoTimeout, setSoTrafficClass, setSslHandshakeTimeout, setTaskExecutor, setTcpSocketSupport, toString, unregisterSender, wrapConnection

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

- コンストラクターの詳細
  - TcpNioServerConnectionFactory
```
public TcpNioServerConnectionFactory(int port)
```
    ポートの受信接続を待機します。
    パラメーター:
    port - ポート。
- メソッドの詳細
  - setMultiAccept
```
public void setMultiAccept(boolean multiAccept)
```
    false に設定すると、セレクターキーを介した反復ごとに 1 つの接続のみが受け入れられます。これは、既存のソケットの圧倒的な読み取りを受け入れないようにするために必要な場合があります。デフォルトでは、OP_ACCEPT 操作の準備ができると、到着しなくなるまでループで接続を受け入れ続けます。
    パラメーター:
    multiAccept - 一度に 1 つずつ接続を受け入れる場合は false。
    導入:
    5.1.4
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス IntegrationObjectSupport の getComponentType
  - getPort
```
public int getPort()
```
    インターフェースからコピーされた説明: TcpServerConnectionFactory
    このサーバーがリッスンしているポートを返します。ファクトリがランダムポート (0) でリッスンするように構成されている場合、ファクトリの起動後に実際のポートが返されます。ファクトリが停止すると、以前の値を返す場合があります。
    次で指定:
    インターフェース TcpServerConnectionFactory の getPort
    オーバーライド:
    クラス AbstractConnectionFactory の getPort
    戻り値:
    港
  - getServerSocketAddress
```
@Nullable
public SocketAddressSE getServerSocketAddress()
```
    インターフェースからコピーされた説明: TcpServerConnectionFactory
    基になる ServerSocket がバインドされている SocketAddressSE を返します。
    次で指定:
    インターフェース TcpServerConnectionFactory の getServerSocketAddress
    オーバーライド:
    クラス AbstractServerConnectionFactory の getServerSocketAddress
    戻り値:
    ソケットアドレス。
  - run
```
public void run()
```
    リスナーが登録されていない場合は、終了します。受信接続を受け入れ、新しい接続ごとに TcpConnections を作成します。{AbstractServerConnectionFactory.initializeConnection(TcpConnectionSupport, Socket) を呼び出し、タスクエグゼキュータを使用して接続 Runnable.run()SE を実行します。サーバーソケット / チャネルの I/O エラーがログに記録され、ファクトリが停止します。
  - doAccept
```
protected void doAccept(SelectorSE selectorForNewSocket,
                        ServerSocketChannelSE server,
                        long now)
```
    オーバーライド:
    クラス AbstractConnectionFactory の doAccept
    パラメーター:
    selectorForNewSocket - セレクタ。
    server - サーバーソケットチャネル。
    now - 現在の時刻。
  - stop
```
public void stop()
```
    クラスからコピーされた説明: AbstractConnectionFactory
    サーバーの停止。
    次で指定:
    インターフェース Lifecycle の stop
    次で指定:
    インターフェース ManageableLifecycle の stop
    オーバーライド:
    クラス AbstractConnectionFactory の stop
  - setUsingDirectBuffers
```
public void setUsingDirectBuffers(boolean usingDirectBuffers)
```
  - setTcpNioConnectionSupport
```
public void setTcpNioConnectionSupport(TcpNioConnectionSupport tcpNioSupport)
```
  - getServerChannel
```
protected ServerSocketChannelSE getServerChannel()
```
    戻り値:
    serverChannel
  - isUsingDirectBuffers
```
protected boolean isUsingDirectBuffers()
```
    戻り値:
    usingDirectBuffers
  - getConnections
```
protected MapSE<SocketChannelSE,TcpNioConnection> getConnections()
```
    戻り値:
    接続

クラス TcpNioServerConnectionFactory

フィールドのサマリー

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.ip.tcp.connection.AbstractServerConnectionFactory から継承されたメソッド

クラス org.springframework.integration.ip.tcp.connection.AbstractConnectionFactory から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

コンストラクターの詳細

TcpNioServerConnectionFactory

メソッドの詳細

setMultiAccept

getComponentType

getPort

getServerSocketAddress

run

doAccept

stop

setUsingDirectBuffers

setTcpNioConnectionSupport

getServerChannel

isUsingDirectBuffers

getConnections