Class SocketAcceptor
- java.lang.Object
-
- org.apache.mina.common.support.BaseIoService
-
- org.apache.mina.common.support.BaseIoAcceptor
-
- org.apache.mina.transport.socket.nio.SocketAcceptor
-
- All Implemented Interfaces:
IoAcceptor
,IoService
public class SocketAcceptor extends BaseIoAcceptor
IoAcceptor
for socket transport (TCP/IP).
-
-
Constructor Summary
Constructors Constructor Description SocketAcceptor()
Create an acceptor with a single processing thread using a NewThreadExecutorSocketAcceptor(int processorCount, java.util.concurrent.Executor executor)
Create an acceptor with the desired number of processing threads
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
bind(java.net.SocketAddress address, IoHandler handler, IoServiceConfig config)
Binds to the specifiedaddress
and handles incoming connections with the specifiedhandler
.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 specifiedaddress
and disconnects all clients connected there.void
unbindAll()
Unbinds all addresses which were bound by this acceptor.-
Methods inherited from class org.apache.mina.common.support.BaseIoAcceptor
bind, newSession
-
Methods inherited from class org.apache.mina.common.support.BaseIoService
addListener, getFilterChain, getFilterChainBuilder, getListeners, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.mina.common.IoService
addListener, getFilterChain, getFilterChainBuilder, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder
-
-
-
-
Constructor Detail
-
SocketAcceptor
public SocketAcceptor()
Create an acceptor with a single processing thread using a NewThreadExecutor
-
SocketAcceptor
public SocketAcceptor(int processorCount, java.util.concurrent.Executor executor)
Create an acceptor with the desired number of processing threads- Parameters:
processorCount
- Number of processing threadsexecutor
- Executor to use for launching threads
-
-
Method Detail
-
bind
public void bind(java.net.SocketAddress address, IoHandler handler, IoServiceConfig config) throws java.io.IOException
Binds to the specifiedaddress
and handles incoming connections with the specifiedhandler
. Backlog value is configured to the value ofbacklog
property.config
- the configuration- Throws:
java.io.IOException
- if failed to bind
-
unbind
public void unbind(java.net.SocketAddress address)
Description copied from interface:IoAcceptor
Unbinds from the specifiedaddress
and disconnects all clients connected there.
-
unbindAll
public void unbindAll()
Description copied from interface:IoAcceptor
Unbinds all addresses which were bound by this acceptor.
-
getDefaultConfig
public SocketAcceptorConfig getDefaultConfig()
Description copied from interface:IoService
Returns the default configuration which is used when you didn't specify any configuration.
-
setDefaultConfig
public void setDefaultConfig(SocketAcceptorConfig defaultConfig)
Sets the config this acceptor will use by default.- Parameters:
defaultConfig
- the default config.- Throws:
java.lang.NullPointerException
- if the specified value isnull
.
-
-