public class TCPController extends SocketChannelController
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 |
---|
TCPController() |
TCPController(Configuration configuration) |
TCPController(Configuration configuration,
CodecFactory codecFactory) |
TCPController(Configuration configuration,
Handler handler,
CodecFactory codecFactory) |
Modifier and Type | Method and Description |
---|---|
void |
closeChannel(Selector selector) |
protected void |
doStart()
Inner startup
|
int |
getBacklog() |
void |
onAccept(SelectionKey selectionKey) |
void |
setBacklog(int backlog) |
void |
setPerformancePreferences(int connectionTime,
int latency,
int bandwidth) |
void |
unbind() |
buildSession, configureSocketChannel, dispatchReadEvent, dispatchWriteEvent, setSoLinger
bind, buildSessionConfig, closeSelectionKey, 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, 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
onConnect
public TCPController()
public TCPController(Configuration configuration)
public TCPController(Configuration configuration, CodecFactory codecFactory)
public TCPController(Configuration configuration, Handler handler, CodecFactory codecFactory)
public int getBacklog()
public void setBacklog(int backlog)
public void setPerformancePreferences(int connectionTime, int latency, int bandwidth)
protected void doStart() throws IOException
NioController
doStart
in class NioController
IOException
public void onAccept(SelectionKey selectionKey) throws IOException
onAccept
in interface SelectionKeyHandler
onAccept
in class AbstractController
IOException
public void closeChannel(Selector selector) throws IOException
IOException
public void unbind() throws IOException
IOException
Copyright © 2021. All rights reserved.