public abstract class AbstractServerConnectionFactory extends AbstractConnectionFactory implements TcpServerConnectionFactory, SchedulingAwareRunnable, OrderlyShutdownCapable
DEFAULT_REPLY_TIMEOUT, lifecycleMonitor
EXPRESSION_PARSER, logger
コンストラクターと説明 |
---|
AbstractServerConnectionFactory(int port) ファクトリがリッスンするポート。 |
修飾子と型 | メソッドと説明 |
---|---|
int | afterShutdown() スケジューラー、エグゼキューターなどの通常のシャットダウンの後、シャットダウン遅延が経過した後、残りのアクティブなスケジューラー / エグゼキュータースレッドの強制シャットダウンの前に呼び出されます。オプションで、まだ処理中のアクティブなメッセージの数を返すことができます。 |
int | beforeShutdown() シャットダウンが始まる前に呼び出されます。 |
int | getBacklog() サーバー接続バックログ内のソケットの数。 |
TcpConnection | getConnection() ファクトリで複数の接続を管理しており、この方法では識別できないため、サポートされていません。 |
StringSE | getLocalAddress() |
SocketAddressSE | getServerSocketAddress() 基になる ServerSocket がバインドされている SocketAddress SE を返します。 |
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, wrapConnection
afterPropertiesSet, 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, setTaskScheduler
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
getPort
runSE
public AbstractServerConnectionFactory(int port)
port
- ポート。public boolean isLongLived()
SchedulingAwareRunnable
の isLongLived
@Nullable public SocketAddressSE getServerSocketAddress()
TcpServerConnectionFactory
ServerSocket
がバインドされている SocketAddress
SE を返します。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()
OrderlyShutdownCapable
OrderlyShutdownCapable
の beforeShutdown
public int afterShutdown()
OrderlyShutdownCapable
OrderlyShutdownCapable
の afterShutdown
protected void publishServerExceptionEvent(ExceptionSE e)
protected void publishServerListeningEvent(int port)