org.apache.mina.transport.socket.nio

类 NioSocketAcceptor

java.lang.Object

org.apache.mina.core.service.AbstractIoService

org.apache.mina.core.service.AbstractIoAcceptor

org.apache.mina.core.polling.AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

org.apache.mina.transport.socket.nio.NioSocketAcceptor

所有已实现的接口:

IoAcceptor, IoService, SocketAcceptor

public final class NioSocketAcceptor
extends AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>
implements SocketAcceptor

IoAcceptor for socket transport (TCP/IP). This class handles incoming TCP/IP based socket connections.

作者:

Apache MINA Project

嵌套类概要

从类继承的嵌套类/接口 org.apache.mina.core.service.AbstractIoAcceptor

AbstractIoAcceptor.AcceptorOperationFuture

从类继承的嵌套类/接口 org.apache.mina.core.service.AbstractIoService

AbstractIoService.ServiceOperationFuture

字段概要

从类继承的字段 org.apache.mina.core.polling.AbstractPollingIoAcceptor

backlog, reuseAddress

从类继承的字段 org.apache.mina.core.service.AbstractIoAcceptor

bindLock

从类继承的字段 org.apache.mina.core.service.AbstractIoService

disposalLock, sessionConfig

构造器概要

构造器

构造器和说明
NioSocketAcceptor() Constructor for NioSocketAcceptor using default parameters (multiple thread model).
NioSocketAcceptor(java.util.concurrent.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, java.nio.channels.spi.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.

方法概要

方法

限定符和类型	方法和说明
protected NioSession	accept(IoProcessor<NioSession> processor, java.nio.channels.ServerSocketChannel handle) Accept a client connection for a server socket and return a new IoSession associated with the given IoProcessor
protected void	close(java.nio.channels.ServerSocketChannel handle) Close a server socket.
protected void	destroy() Destroy the polling system, will be called when this IoAcceptor implementation will be disposed.
java.net.InetSocketAddress	getDefaultLocalAddress() Returns the default local address to bind when no argument is specified in IoAcceptor.bind() method.
java.net.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(java.nio.channels.spi.SelectorProvider selectorProvider) Initialize the polling system, will be called at construction time.
protected java.net.SocketAddress	localAddress(java.nio.channels.ServerSocketChannel handle) Get the local address associated with a given server socket
protected java.nio.channels.ServerSocketChannel	open(java.net.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 java.util.Iterator<java.nio.channels.ServerSocketChannel>	selectedHandles() Iterator for the set of server sockets found with acceptable incoming connections during the last AbstractPollingIoAcceptor.select() call.
void	setDefaultLocalAddress(java.net.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.

从类继承的方法 org.apache.mina.core.polling.AbstractPollingIoAcceptor

bindInternal, dispose0, getBacklog, getSessionConfig, isReuseAddress, newSession, setBacklog, setReuseAddress, unbind0

从类继承的方法 org.apache.mina.core.service.AbstractIoAcceptor

bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, toString, unbind, unbind, unbind, unbind

从类继承的方法 org.apache.mina.core.service.AbstractIoService

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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

从接口继承的方法 org.apache.mina.transport.socket.SocketAcceptor

getBacklog, getSessionConfig, isReuseAddress, setBacklog, setReuseAddress

从接口继承的方法 org.apache.mina.core.service.IoAcceptor

bind, bind, bind, bind, bind, getDefaultLocalAddresses, getLocalAddresses, isCloseOnDeactivation, newSession, setCloseOnDeactivation, setDefaultLocalAddress, setDefaultLocalAddresses, setDefaultLocalAddresses, setDefaultLocalAddresses, unbind, unbind, unbind, unbind

从接口继承的方法 org.apache.mina.core.service.IoService

addListener, broadcast, dispose, dispose, getActivationTime, getFilterChain, getFilterChainBuilder, getHandler, getManagedSessionCount, getManagedSessions, getScheduledWriteBytes, getScheduledWriteMessages, getSessionDataStructureFactory, getStatistics, isActive, isDisposed, isDisposing, removeListener, setFilterChainBuilder, setHandler, setSessionDataStructureFactory

构造器详细资料

NioSocketAcceptor

public NioSocketAcceptor()

Constructor for NioSocketAcceptor using default parameters (multiple thread model).

NioSocketAcceptor

public NioSocketAcceptor(int processorCount)

Constructor for 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

NioSocketAcceptor

public 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.

参数:

processor - the processor to use for managing I/O events

NioSocketAcceptor

public NioSocketAcceptor(java.util.concurrent.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.

参数:

executor - the executor for connection

processor - the processor for I/O operations

NioSocketAcceptor

public NioSocketAcceptor(int processorCount,
                 java.nio.channels.spi.SelectorProvider selectorProvider)

Constructor for NioSocketAcceptor using default parameters, and given number of NioProcessor for multithreading I/O operations, and a custom SelectorProvider for NIO

参数:

processorCount - the number of processor to create and place in a

selectorProvider - teh SelectorProvider to use SimpleIoProcessorPool

方法详细资料

init

protected void init()
             throws java.lang.Exception

Initialize the polling system, will be called at construction time.

指定者:

init 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

抛出:

java.lang.Exception - any exception thrown by the underlying system calls

init

protected void init(java.nio.channels.spi.SelectorProvider selectorProvider)
             throws java.lang.Exception

Initialize the polling system, will be called at construction time.

指定者:

init 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

参数:

selectorProvider - The Selector Provider that will be used by this polling acceptor

抛出:

java.lang.Exception - any exception thrown by the underlying system calls

destroy

protected void destroy()
                throws java.lang.Exception

Destroy the polling system, will be called when this IoAcceptor implementation will be disposed.

指定者:

destroy 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

抛出:

java.lang.Exception - any exception thrown by the underlying systems calls

getTransportMetadata

public TransportMetadata getTransportMetadata()

指定者:

getTransportMetadata 在接口中 IoService

返回:

the TransportMetadata that this service runs on.

getLocalAddress

public java.net.InetSocketAddress getLocalAddress()

Returns the local address which is bound currently. If more than one address are bound, only one of them will be returned, but it's not necessarily the firstly bound address.

指定者:

getLocalAddress 在接口中 IoAcceptor

指定者:

getLocalAddress 在接口中 SocketAcceptor

覆盖:

getLocalAddress 在类中 AbstractIoAcceptor

返回:

The bound LocalAddress

getDefaultLocalAddress

public java.net.InetSocketAddress getDefaultLocalAddress()

Returns the default local address to bind when no argument is specified in 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 在接口中 IoAcceptor

指定者:

getDefaultLocalAddress 在接口中 SocketAcceptor

覆盖:

getDefaultLocalAddress 在类中 AbstractIoAcceptor

返回:

The default bound LocalAddress

setDefaultLocalAddress

public void setDefaultLocalAddress(java.net.InetSocketAddress localAddress)

Sets the default local InetSocketAddress to bind when no argument is specified in 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 在接口中 SocketAcceptor

参数:

localAddress - The local address

accept

protected NioSession accept(IoProcessor<NioSession> processor,
                java.nio.channels.ServerSocketChannel handle)
                     throws java.lang.Exception

Accept a client connection for a server socket and return a new IoSession associated with the given IoProcessor

指定者:

accept 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

参数:

processor - the IoProcessor to associate with the IoSession

handle - the server handle

返回:

the created IoSession

抛出:

java.lang.Exception - any exception thrown by the underlying systems calls

open

protected java.nio.channels.ServerSocketChannel open(java.net.SocketAddress localAddress)
                                              throws java.lang.Exception

Open a server socket for a given local address.

指定者:

open 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

参数:

localAddress - the associated local address

返回:

the opened server socket

抛出:

java.lang.Exception - any exception thrown by the underlying systems calls

localAddress

protected java.net.SocketAddress localAddress(java.nio.channels.ServerSocketChannel handle)
                                       throws java.lang.Exception

Get the local address associated with a given server socket

指定者:

localAddress 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

参数:

handle - the server socket

返回:

the local SocketAddress associated with this handle

抛出:

java.lang.Exception - any exception thrown by the underlying systems calls

select

protected int select()
              throws java.lang.Exception

Check if we have at least one key whose corresponding channels is ready for I/O operations. This method performs a blocking selection operation. It returns only after at least one channel is selected, this selector's wakeup method is invoked, or the current thread is interrupted, whichever comes first.

指定者:

select 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

返回:

The number of keys having their ready-operation set updated

抛出:

java.io.IOException - If an I/O error occurs

java.nio.channels.ClosedSelectorException - If this selector is closed

java.lang.Exception - any exception thrown by the underlying systems calls

selectedHandles

protected java.util.Iterator<java.nio.channels.ServerSocketChannel> selectedHandles()

Iterator for the set of server sockets found with acceptable incoming connections during the last AbstractPollingIoAcceptor.select() call.

指定者:

selectedHandles 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

返回:

the list of server handles ready

close

protected void close(java.nio.channels.ServerSocketChannel handle)
              throws java.lang.Exception

Close a server socket.

指定者:

close 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>

参数:

handle - the server socket

抛出:

java.lang.Exception - any exception thrown by the underlying systems calls

wakeup

protected void wakeup()

Interrupt the AbstractPollingIoAcceptor.select() method. Used when the poll set need to be modified.

指定者:

wakeup 在类中 AbstractPollingIoAcceptor<NioSession,java.nio.channels.ServerSocketChannel>