IoAcceptor
, IoService
public class SocketAcceptor extends BaseIoAcceptor
IoAcceptor
for socket transport (TCP/IP).Constructor | Description |
---|---|
SocketAcceptor() |
Create an acceptor with a single processing thread using a NewThreadExecutor
|
SocketAcceptor(int processorCount,
java.util.concurrent.Executor executor) |
Create an acceptor with the desired number of processing threads
|
Modifier and Type | Method | Description |
---|---|---|
void |
bind(java.net.SocketAddress address,
IoHandler handler,
IoServiceConfig config) |
Binds to the specified
address and handles incoming connections with the specified
handler . |
SocketAcceptorConfig |
getDefaultConfig() |
Returns the default configuration which is used when you didn't specify
any configuration.
|
void |
setDefaultConfig(SocketAcceptorConfig defaultConfig) |
Sets the config this acceptor will use by default.
|
void |
unbind(java.net.SocketAddress address) |
Unbinds from the specified
address and disconnects all clients
connected there. |
void |
unbindAll() |
Unbinds all addresses which were bound by this acceptor.
|
bind, newSession
addListener, getFilterChain, getFilterChainBuilder, getListeners, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
addListener, getFilterChain, getFilterChainBuilder, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
public SocketAcceptor()
public SocketAcceptor(int processorCount, java.util.concurrent.Executor executor)
processorCount
- Number of processing threadsexecutor
- Executor to use for launching threadspublic void bind(java.net.SocketAddress address, IoHandler handler, IoServiceConfig config) throws java.io.IOException
address
and handles incoming connections with the specified
handler
. Backlog value is configured to the value of backlog
property.config
- the configurationjava.io.IOException
- if failed to bindpublic void unbind(java.net.SocketAddress address)
IoAcceptor
address
and disconnects all clients
connected there.public void unbindAll()
IoAcceptor
public SocketAcceptorConfig getDefaultConfig()
IoService
public void setDefaultConfig(SocketAcceptorConfig defaultConfig)
defaultConfig
- the default config.java.lang.NullPointerException
- if the specified value is null
.