public abstract class SocketChannelController extends NioController
Modifier and Type | Field and Description |
---|---|
protected boolean |
soLingerOn |
selectorManager, selectorPoolSize
codecFactory, configuration, dispatchMessageDispatcher, dispatchMessageThreadCount, handler, handleReadWriteConcurrently, localSocketAddress, log, readEventDispatcher, readThreadCount, sessionSet, sessionTimeout, socketOptions, soTimeout, started, stateListeners, statistics, statisticsInterval, writeEventDispatcher, writeThreadCount
Constructor and Description |
---|
SocketChannelController() |
SocketChannelController(Configuration configuration) |
SocketChannelController(Configuration configuration,
CodecFactory codecFactory) |
SocketChannelController(Configuration configuration,
Handler handler,
CodecFactory codecFactory) |
Modifier and Type | Method and Description |
---|---|
protected NioSession |
buildSession(SocketChannel sc) |
protected void |
configureSocketChannel(SocketChannel sc)
Confiure socket channel
|
protected void |
dispatchReadEvent(SelectionKey key)
Dispatch read event
|
protected void |
dispatchWriteEvent(SelectionKey key)
Dispatch write event
|
void |
setSoLinger(boolean on,
int value) |
bind, buildSessionConfig, closeSelectionKey, doStart, getSelectorManager, getSelectorPoolSize, initialSelectorManager, onRead, onWrite, setSelectorPoolSize, start0, stop0
addStateListener, bind, buildQueue, checkStatisticsForRestart, getCodecFactory, getConfiguration, getDispatchMessageThreadCount, getHandler, getLocalSocketAddress, getPort, getReadThreadCount, getReceiveThroughputLimit, getSendThroughputLimit, getSessionIdleTimeout, getSessionSet, getSessionTimeout, getSocketOption, getSoTimeout, getStatistics, getWriteThreadCount, isHandleReadWriteConcurrently, isStarted, notifyAllSessionClosed, notifyException, notifyReady, notifyStarted, notifyStopped, onAccept, onConnect, registerSession, removeStateListener, setCodecFactory, setConfiguration, setDispatchMessageThreadCount, setHandler, setHandleReadWriteConcurrently, setLocalSocketAddress, setReadThreadCount, setReceiveThroughputLimit, setSendThroughputLimit, setSessionIdleTimeout, setSessionTimeout, setSocketOption, setSocketOptions, setSoTimeout, setWriteThreadCount, start, stop, unregisterSession
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
closeChannel, onAccept, onConnect
public SocketChannelController()
public SocketChannelController(Configuration configuration)
public SocketChannelController(Configuration configuration, CodecFactory codecFactory)
public SocketChannelController(Configuration configuration, Handler handler, CodecFactory codecFactory)
public void setSoLinger(boolean on, int value)
protected final void dispatchReadEvent(SelectionKey key)
NioController
dispatchReadEvent
in class NioController
protected final void dispatchWriteEvent(SelectionKey key)
NioController
dispatchWriteEvent
in class NioController
protected NioSession buildSession(SocketChannel sc)
protected final void configureSocketChannel(SocketChannel sc) throws IOException
sc
- IOException
Copyright © 2021. All rights reserved.