public final class NioSocketAcceptor extends AbstractPollingIoAcceptor<NioSession,ServerSocketChannel> implements SocketAcceptor
IoAcceptor
for socket transport (TCP/IP). This class
handles incoming TCP/IP based socket connections.AbstractIoAcceptor.AcceptorOperationFuture
AbstractIoService.ServiceOperationFuture
backlog, reuseAddress
bindLock
disposalLock, sessionConfig
Constructor and Description |
---|
NioSocketAcceptor()
Constructor for
NioSocketAcceptor using default parameters (multiple thread model). |
NioSocketAcceptor(Executor executor,
IoProcessor<NioSession> processor)
Constructor for
NioSocketAcceptor with a given Executor for handling
connection events and a given IoProcessor for handling I/O events, useful for
sharing the same processor and executor over multiple IoService of the same type. |
NioSocketAcceptor(int processorCount)
Constructor for
NioSocketAcceptor using default parameters, and
given number of NioProcessor for multithreading I/O operations. |
NioSocketAcceptor(int processorCount,
SelectorProvider selectorProvider)
Constructor for
NioSocketAcceptor using default parameters, and
given number of NioProcessor for multithreading I/O operations, and
a custom SelectorProvider for NIO |
NioSocketAcceptor(IoProcessor<NioSession> processor)
Constructor for
NioSocketAcceptor with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |
Modifier and Type | Method and Description |
---|---|
protected NioSession |
accept(IoProcessor<NioSession> processor,
ServerSocketChannel handle)
Accept a client connection for a server socket and return a new
IoSession
associated with the given IoProcessor |
protected void |
close(ServerSocketChannel handle)
Close a server socket.
|
protected void |
destroy()
Destroy the polling system, will be called when this
IoAcceptor
implementation will be disposed. |
InetSocketAddress |
getDefaultLocalAddress()
Returns the default local address to bind when no argument is specified
in
IoAcceptor.bind() method. |
InetSocketAddress |
getLocalAddress()
Returns the local address which is bound currently.
|
TransportMetadata |
getTransportMetadata() |
protected void |
init()
Initialize the polling system, will be called at construction time.
|
protected void |
init(SelectorProvider selectorProvider)
Initialize the polling system, will be called at construction time.
|
protected SocketAddress |
localAddress(ServerSocketChannel handle)
Get the local address associated with a given server socket
|
protected ServerSocketChannel |
open(SocketAddress localAddress)
Open a server socket for a given local address.
|
protected int |
select()
Check if we have at least one key whose corresponding channels is
ready for I/O operations.
|
protected Iterator<ServerSocketChannel> |
selectedHandles()
Iterator for the set of server sockets found with acceptable incoming connections
during the last AbstractPollingIoAcceptor.select() call. |
void |
setDefaultLocalAddress(InetSocketAddress localAddress)
Sets the default local InetSocketAddress to bind when no argument is specified in
IoAcceptor.bind() method. |
protected void |
wakeup()
Interrupt the
AbstractPollingIoAcceptor.select() method. |
bindInternal, dispose0, getBacklog, getSessionConfig, isReuseAddress, newSession, setBacklog, setReuseAddress, unbind0
bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, toString, unbind, unbind, unbind, unbind
addListener, broadcast, dispose, dispose, executeWorker, executeWorker, finishSessionInitialization0, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getListeners, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, initSession, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getBacklog, getSessionConfig, isReuseAddress, setBacklog, setReuseAddress
bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, newSession, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, unbind, unbind, unbind, unbind
addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory
public NioSocketAcceptor()
NioSocketAcceptor
using default parameters (multiple thread model).public NioSocketAcceptor(int processorCount)
NioSocketAcceptor
using default parameters, and
given number of NioProcessor
for multithreading I/O operations.processorCount
- the number of processor to create and place in a
SimpleIoProcessorPool
public NioSocketAcceptor(IoProcessor<NioSession> processor)
NioSocketAcceptor
with default configuration but a
specific IoProcessor
, useful for sharing the same processor over multiple
IoService
of the same type.processor
- the processor to use for managing I/O eventspublic NioSocketAcceptor(Executor executor, IoProcessor<NioSession> processor)
NioSocketAcceptor
with a given Executor
for handling
connection events and a given IoProcessor
for handling I/O events, useful for
sharing the same processor and executor over multiple IoService
of the same type.executor
- the executor for connectionprocessor
- the processor for I/O operationspublic NioSocketAcceptor(int processorCount, SelectorProvider selectorProvider)
NioSocketAcceptor
using default parameters, and
given number of NioProcessor
for multithreading I/O operations, and
a custom SelectorProvider for NIOprocessorCount
- the number of processor to create and place in aselectorProvider
- teh SelectorProvider to use
SimpleIoProcessorPool
protected void init() throws Exception
init
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
Exception
- any exception thrown by the underlying system callsprotected void init(SelectorProvider selectorProvider) throws Exception
init
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
selectorProvider
- The Selector Provider that will be used by this polling acceptorException
- any exception thrown by the underlying system callsprotected void destroy() throws Exception
IoAcceptor
implementation will be disposed.destroy
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
Exception
- any exception thrown by the underlying systems callspublic TransportMetadata getTransportMetadata()
getTransportMetadata
in interface IoService
TransportMetadata
that this service runs on.public InetSocketAddress getLocalAddress()
getLocalAddress
in interface IoAcceptor
getLocalAddress
in interface SocketAcceptor
getLocalAddress
in class AbstractIoAcceptor
public InetSocketAddress getDefaultLocalAddress()
IoAcceptor.bind()
method. Please note that the default will not be
used if any local address is specified. If more than one address are
set, only one of them will be returned, but it's not necessarily the
firstly specified address in IoAcceptor.setDefaultLocalAddresses(List)
.getDefaultLocalAddress
in interface IoAcceptor
getDefaultLocalAddress
in interface SocketAcceptor
getDefaultLocalAddress
in class AbstractIoAcceptor
public void setDefaultLocalAddress(InetSocketAddress localAddress)
IoAcceptor.bind()
method. Please note that the default will not be used
if any local InetSocketAddress is specified.
This method overrides the IoAcceptor.setDefaultLocalAddress(java.net.SocketAddress)
method.setDefaultLocalAddress
in interface SocketAcceptor
localAddress
- The local addressprotected NioSession accept(IoProcessor<NioSession> processor, ServerSocketChannel handle) throws Exception
IoSession
associated with the given IoProcessor
accept
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
processor
- the IoProcessor
to associate with the IoSession
handle
- the server handleIoSession
Exception
- any exception thrown by the underlying systems callsprotected ServerSocketChannel open(SocketAddress localAddress) throws Exception
open
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
localAddress
- the associated local addressException
- any exception thrown by the underlying systems callsprotected SocketAddress localAddress(ServerSocketChannel handle) throws Exception
localAddress
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
handle
- the server socketSocketAddress
associated with this handleException
- any exception thrown by the underlying systems callsprotected int select() throws Exception
select
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
IOException
- If an I/O error occursClosedSelectorException
- If this selector is closedException
- any exception thrown by the underlying systems callsprotected Iterator<ServerSocketChannel> selectedHandles()
Iterator
for the set of server sockets found with acceptable incoming connections
during the last AbstractPollingIoAcceptor.select()
call.selectedHandles
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
protected void close(ServerSocketChannel handle) throws Exception
close
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
handle
- the server socketException
- any exception thrown by the underlying systems callsprotected void wakeup()
AbstractPollingIoAcceptor.select()
method. Used when the poll set need to be modified.wakeup
in class AbstractPollingIoAcceptor<NioSession,ServerSocketChannel>
Copyright © 2004–2016 Apache MINA Project. All rights reserved.