public abstract class AbstractServerConnectionFactory extends AbstractConnectionFactory implements TcpServerConnectionFactory, SchedulingAwareRunnable, OrderlyShutdownCapable
DEFAULT_REPLY_TIMEOUT, lifecycleMonitorEXPRESSION_PARSER, logger| コンストラクターと説明 |
|---|
AbstractServerConnectionFactory(int port) ファクトリがリッスンするポート。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
int | afterShutdown() スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。 |
int | beforeShutdown() シャットダウンが始まる前に呼び出されます。 |
int | getBacklog() サーバー接続バックログ内のソケットの数。 |
TcpConnection | getConnection() ファクトリで複数の接続を管理しており、この方法では識別できないため、サポートされていません。 |
StringSE | getLocalAddress() |
SocketAddressSE | getServerSocketAddress() 基になる ServerSocket がバインドされている SocketAddressSE を返します。 |
protected void | initializeConnection(TcpConnectionSupport connection, SocketSE socket)(デ)シリアライザー、マッパーなどの属性を新しい接続に転送します。 |
boolean | isListening() |
boolean | isLongLived() |
protected boolean | isShuttingDown() |
protected void | postProcessServerSocket(ServerSocketSE serverSocket) |
protected void | publishServerExceptionEvent(ExceptionSE e) |
protected void | publishServerListeningEvent(int port) |
void | setBacklog(int backlog) 接続バックログ内のソケットの数。 |
protected void | setListening(boolean listening) |
void | setLocalAddress(StringSE localAddress) マルチホームシステムで使用され、サーバーがすべてのネットワークアダプターではなく特定のネットワークアドレスでリッスンするように強制します。 |
void | start() |
addConnection, checkActive, closeConnection, delayRead, doAccept, getApplicationEventPublisher, getDelayedReads, getDeserializer, getHost, getLifecycleMonitor, getListener, getMapper, getOpenConnectionIds, getPort, 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, stop, toString, unregisterSender, wrapConnectionafterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskSchedulercloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSEgetPortrunSEpublic AbstractServerConnectionFactory(int port)
port - ポート。public boolean isLongLived()
SchedulingAwareRunnable の isLongLived @Nullable public SocketAddressSE getServerSocketAddress()
TcpServerConnectionFactoryServerSocket がバインドされている SocketAddressSE を返します。TcpServerConnectionFactory の getServerSocketAddress public void start()
Lifecycle の start ManageableLifecycle の start AbstractConnectionFactory の start public TcpConnection getConnection()
ConnectionFactory の getConnection protected void setListening(boolean listening)
listening - セットを聞く public boolean isListening()
protected boolean isShuttingDown()
protected void initializeConnection(TcpConnectionSupport connection, SocketSE socket)
connection - 新しい接続。socket - 新しいソケット。protected void postProcessServerSocket(ServerSocketSE serverSocket)
public void setLocalAddress(StringSE localAddress)
localAddress - 必要なアダプターの IP アドレス。public int getBacklog()
public void setBacklog(int backlog)
backlog - 設定するバックログ。public int beforeShutdown()
OrderlyShutdownCapableOrderlyShutdownCapable の beforeShutdown public int afterShutdown()
OrderlyShutdownCapableOrderlyShutdownCapable の afterShutdown protected void publishServerExceptionEvent(ExceptionSE e)
protected void publishServerListeningEvent(int port)