public class TCPController extends SocketChannelController
soLingerOnselectorManager, selectorPoolSizecodecFactory, 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, setSoLingerbind, buildSessionConfig, closeSelectionKey, getSelectorManager, getSelectorPoolSize, initialSelectorManager, onRead, onWrite, setSelectorPoolSize, start0, stop0addStateListener, 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, unregisterSessionclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonConnectpublic 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
NioControllerdoStart in class NioControllerIOExceptionpublic void onAccept(SelectionKey selectionKey) throws IOException
onAccept in interface SelectionKeyHandleronAccept in class AbstractControllerIOExceptionpublic void closeChannel(Selector selector) throws IOException
IOExceptionpublic void unbind()
throws IOException
IOExceptionCopyright © 2016. All rights reserved.