程序包 | 说明 |
---|---|
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java
NIO (New I/O) API.
|
限定符和类型 | 字段和说明 |
---|---|
protected IoProcessor<NioSession> |
NioSession.processor
The NioSession processor
|
限定符和类型 | 方法和说明 |
---|---|
protected NioSession |
NioSocketAcceptor.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 NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle) |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle,
java.net.SocketAddress remoteAddress) |
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.SocketChannel handle)
Create a new
IoSession from a connected socket client handle. |
限定符和类型 | 方法和说明 |
---|---|
protected java.util.Iterator<NioSession> |
NioProcessor.allSessions() |
IoProcessor<NioSession> |
NioSession.getProcessor() |
protected java.util.Iterator<NioSession> |
NioProcessor.selectedSessions() |
限定符和类型 | 方法和说明 |
---|---|
void |
NioDatagramAcceptor.add(NioSession session)
Adds the specified
session to the I/O processor so that
the I/O processor starts to perform any I/O operations related
with the session . |
protected void |
NioProcessor.destroy(NioSession session) |
void |
NioDatagramAcceptor.flush(NioSession session)
Flushes the internal write request queue of the specified
session . |
protected SessionState |
NioProcessor.getState(NioSession session)
Get the state of a session (One of OPENING, OPEN, CLOSING)
|
protected void |
NioProcessor.init(NioSession session) |
protected boolean |
NioProcessor.isInterestedInRead(NioSession session) |
protected boolean |
NioProcessor.isInterestedInWrite(NioSession session) |
protected boolean |
NioProcessor.isReadable(NioSession session) |
protected boolean |
NioProcessor.isWritable(NioSession session) |
protected int |
NioProcessor.read(NioSession session,
IoBuffer buf) |
void |
NioDatagramAcceptor.remove(NioSession session)
Removes and closes the specified
session from the I/O
processor so that the I/O processor closes the connection
associated with the session and releases any other related
resources. |
protected int |
NioDatagramAcceptor.send(NioSession session,
IoBuffer buffer,
java.net.SocketAddress remoteAddress) |
protected void |
NioProcessor.setInterestedInRead(NioSession session,
boolean isInterested)
Set the session to be informed when a read event should be processed
|
protected void |
NioProcessor.setInterestedInWrite(NioSession session,
boolean isInterested)
Set the session to be informed when a write event should be processed
|
protected void |
NioDatagramAcceptor.setInterestedInWrite(NioSession session,
boolean isInterested) |
protected int |
NioProcessor.transferFile(NioSession session,
FileRegion region,
int length) |
void |
NioDatagramAcceptor.updateTrafficControl(NioSession session)
Controls the traffic of the specified
session depending of the
IoSession.isReadSuspended() and IoSession.isWriteSuspended()
flags |
protected int |
NioProcessor.write(NioSession session,
IoBuffer buf,
int length) |
void |
NioDatagramAcceptor.write(NioSession session,
WriteRequest writeRequest)
Writes the WriteRequest for the specified
session . |
限定符和类型 | 方法和说明 |
---|---|
protected NioSession |
NioSocketAcceptor.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 NioSession |
NioDatagramConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle) |
protected NioSession |
NioDatagramAcceptor.newSession(IoProcessor<NioSession> processor,
java.nio.channels.DatagramChannel handle,
java.net.SocketAddress remoteAddress) |
protected NioSession |
NioSocketConnector.newSession(IoProcessor<NioSession> processor,
java.nio.channels.SocketChannel handle)
Create a new
IoSession from a connected socket client handle. |
构造器和说明 |
---|
NioDatagramConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass)
Constructor for
NioDatagramConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioDatagramConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount)
Constructor for
NioDatagramConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
NioDatagramConnector(IoProcessor<NioSession> processor)
Creates a new instance.
|
NioSession(IoProcessor<NioSession> processor,
IoService service,
java.nio.channels.Channel channel)
Creates a new instance of NioSession, with its associated IoProcessor.
|
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(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. |
NioSocketConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass)
Constructor for
NioSocketConnector with default configuration with default configuration which will use a built-in
thread pool executor to manage the default number of processor instances. |
NioSocketConnector(java.lang.Class<? extends IoProcessor<NioSession>> processorClass,
int processorCount)
Constructor for
NioSocketConnector with default configuration which will use a built-in
thread pool executor to manage the given number of processor instances. |
NioSocketConnector(java.util.concurrent.Executor executor,
IoProcessor<NioSession> processor)
Constructor for
NioSocketConnector 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. |
NioSocketConnector(IoProcessor<NioSession> processor)
Constructor for
NioSocketConnector with default configuration but a
specific IoProcessor , useful for sharing the same processor over multiple
IoService of the same type. |