程序包 | 说明 |
---|---|
org.apache.mina.common |
Common types required for users to use MINA.
|
org.apache.mina.common.support |
Internal classes used by org.apache.mina.common package.
|
org.apache.mina.example.chat |
Chat server which demonstates using the text line codec and Spring integration.
|
org.apache.mina.example.chat.client |
Swing based chat client.
|
org.apache.mina.example.echoserver |
Echo server which demonstates low-level I/O layer and SSL support.
|
org.apache.mina.example.haiku | |
org.apache.mina.example.httpserver.codec |
A HTTP server implemented with protocol codec (needs more work).
|
org.apache.mina.example.httpserver.stream |
A simplistic HTTP server which demonstates stream-based I/O support.
|
org.apache.mina.example.netcat |
NetCat client (Network + Unix
cat command) which demonstates low-level I/O layer. |
org.apache.mina.example.proxy |
A TCP/IP tunneling proxy example.
|
org.apache.mina.example.reverser |
Reverser server which reverses all text lines demonstating high-level protocol layer.
|
org.apache.mina.example.sumup |
SumUp Server and Client which sums up all ADD requests.
|
org.apache.mina.example.sumup.codec |
Protocol codec implementation for SumUp protocol.
|
org.apache.mina.example.tennis |
Two tennis players play a game which demonstates in-VM pipes.
|
org.apache.mina.filter |
Useful IoFilter implementations.
|
org.apache.mina.filter.codec |
Filter implementations that helps you to implement complex protocols
via 'codec' concept.
|
org.apache.mina.filter.codec.demux |
Protocol codecs that helps you to implement even more complex protocols by
splitting a codec into multiple sub-codecs.
|
org.apache.mina.filter.codec.netty |
Protocol codec which provides the integration with Netty2 messages.
|
org.apache.mina.filter.codec.serialization |
Protocol codecs which uses Java object serilization and leads to rapid protocol
implementation.
|
org.apache.mina.filter.codec.support |
Internal classes used by org.apache.mina.filter.codec package.
|
org.apache.mina.filter.codec.textline |
A protocol codec for text-based protocols.
|
org.apache.mina.filter.executor |
An IoFilter that provides flexible thread models
|
org.apache.mina.filter.support |
Internal classes used by org.apache.mina.filter package.
|
org.apache.mina.handler |
Useful IoHandler implementations.
|
org.apache.mina.handler.chain |
A handler implementation that helps you implement sequentially layered protocols
using Chains of Responsibility pattern.
|
org.apache.mina.handler.demux |
A handler implementation that helps you implement complex protocols
by splitting messageReceived handlers into multiple sub-handlers.
|
org.apache.mina.handler.multiton |
Enables creating a handler per session instead of having one handler for many
sessions, using
Multiton pattern.
|
org.apache.mina.handler.support |
Internal classes used by org.apache.mina.handler package.
|
org.apache.mina.integration.jmx |
JMX (Java Management eXtension) integration.
|
org.apache.mina.transport.socket.nio.support |
Internal classes used by org.apache.mina.transport.socket.nio package.
|
org.apache.mina.transport.vmpipe.support |
Internal classes used by org.apache.mina.transport.vmpipe package.
|
org.apache.mina.util |
Miscellaneous utility classes
|
限定符和类型 | 接口和说明 |
---|---|
interface |
BroadcastIoSession
An
IoSession for broadcast transports. |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoFuture.getSession()
Returns the
IoSession which is associated with this future. |
IoSession |
IoFilterChain.getSession()
Returns the parent
IoSession of this chain. |
IoSession |
ConnectFuture.getSession()
Returns
IoSession which is the result of connect operation. |
IoSession |
IoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and remoteAddress which reuses
the localAddress that is already bound by IoAcceptor
via IoAcceptor.bind(SocketAddress, IoHandler) . |
IoSession |
IoSessionRecycler.recycle(java.net.SocketAddress localAddress,
java.net.SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
IoSession |
ExpiringSessionRecycler.recycle(java.net.SocketAddress localAddress,
java.net.SocketAddress remoteAddress) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Set<IoSession> |
IoService.getManagedSessions(java.net.SocketAddress serviceAddress)
Returns all sessions with the specified remote or local address,
which are currently managed by this service.
|
限定符和类型 | 方法和说明 |
---|---|
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable)
event. |
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
IoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards exceptionCaught event to next filter.
|
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close() method invocation. |
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards filterClose event to next filter.
|
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
IoFilter.WriteRequest writeRequest)
Forwards filterWrite event to next filter.
|
void |
IoFilterChain.fireExceptionCaught(IoSession session,
java.lang.Throwable cause)
Fires a
IoHandler.exceptionCaught(IoSession, Throwable) event. |
void |
IoFilterChain.fireFilterClose(IoSession session)
Fires a
close() event. |
void |
IoFilterChain.fireFilterWrite(IoSession session,
IoFilter.WriteRequest writeRequest)
Fires a
write(Object) event. |
void |
IoFilterChain.fireMessageReceived(IoSession session,
java.lang.Object message)
Fires a
IoFilterChain.fireMessageReceived(IoSession, Object) event. |
void |
IoFilterChain.fireMessageSent(IoSession session,
IoFilter.WriteRequest request)
Fires a
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilterChain.fireSessionClosed(IoSession session)
Fires a
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilterChain.fireSessionCreated(IoSession session)
Fires a
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilterChain.fireSessionIdle(IoSession session,
IdleStatus status)
Fires a
IoHandler.sessionIdle(IoSession, IdleStatus) event. |
void |
IoFilterChain.fireSessionOpened(IoSession session)
Fires a
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object)
event. |
void |
IoHandlerAdapter.messageReceived(IoSession session,
java.lang.Object message) |
void |
IoHandler.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
IoFilter.NextFilter.messageReceived(IoSession session,
java.lang.Object message)
Forwards messageReceived event to next filter.
|
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageSent(IoSession,Object)
event. |
void |
IoHandlerAdapter.messageSent(IoSession session,
java.lang.Object message) |
void |
IoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoFilter.NextFilter.messageSent(IoSession session,
java.lang.Object message)
Forwards messageSent event to next filter.
|
void |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
ExpiringSessionRecycler.put(IoSession session) |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
void |
ExpiringSessionRecycler.remove(IoSession session) |
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoHandlerAdapter.sessionClosed(IoSession session) |
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoFilter.NextFilter.sessionClosed(IoSession session)
Forwards sessionClosed event to next filter.
|
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an
IoService . |
void |
IoHandlerAdapter.sessionCreated(IoSession session) |
void |
IoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoFilter.NextFilter.sessionCreated(IoSession session)
Forwards sessionCreated event to next filter.
|
void |
IoServiceListener.sessionDestroyed(IoSession session)
Invoked when a session is being destroyed by an
IoService . |
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus)
event. |
void |
IoHandlerAdapter.sessionIdle(IoSession session,
IdleStatus status) |
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoFilter.NextFilter.sessionIdle(IoSession session,
IdleStatus status)
Forwards sessionIdle event to next filter.
|
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoHandlerAdapter.sessionOpened(IoSession session) |
void |
IoHandler.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
IoFilter.NextFilter.sessionOpened(IoSession session)
Forwards sessionOpened event to next filter.
|
void |
ConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
限定符和类型 | 类和说明 |
---|---|
class |
BaseIoSession
Base implementation of
IoSession . |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
DefaultIoFuture.getSession() |
IoSession |
DefaultConnectFuture.getSession() |
IoSession |
AbstractIoFilterChain.getSession() |
IoSession |
DelegatedIoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
IoSession |
BaseIoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Set<IoSession> |
IoServiceListenerSupport.getManagedSessions(java.net.SocketAddress serviceAddress) |
java.util.Set<IoSession> |
DelegatedIoConnector.getManagedSessions(java.net.SocketAddress serviceAddress) |
java.util.Set<IoSession> |
DelegatedIoAcceptor.getManagedSessions(java.net.SocketAddress serviceAddress) |
java.util.Set<IoSession> |
BaseIoService.getManagedSessions(java.net.SocketAddress serviceAddress) |
限定符和类型 | 方法和说明 |
---|---|
protected abstract void |
AbstractIoFilterChain.doClose(IoSession session) |
protected abstract void |
AbstractIoFilterChain.doWrite(IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
AbstractIoFilterChain.fireExceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
AbstractIoFilterChain.fireFilterClose(IoSession session) |
void |
AbstractIoFilterChain.fireFilterWrite(IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
AbstractIoFilterChain.fireMessageReceived(IoSession session,
java.lang.Object message) |
void |
AbstractIoFilterChain.fireMessageSent(IoSession session,
IoFilter.WriteRequest request) |
void |
AbstractIoFilterChain.fireSessionClosed(IoSession session) |
void |
IoServiceListenerSupport.fireSessionCreated(IoSession session)
Calls
IoServiceListener.sessionCreated(IoSession) for all registered listeners. |
void |
AbstractIoFilterChain.fireSessionCreated(IoSession session) |
void |
IoServiceListenerSupport.fireSessionDestroyed(IoSession session)
Calls
IoServiceListener.sessionDestroyed(IoSession) for all registered listeners. |
void |
AbstractIoFilterChain.fireSessionIdle(IoSession session,
IdleStatus status) |
void |
AbstractIoFilterChain.fireSessionOpened(IoSession session) |
static WriteFuture |
DefaultWriteFuture.newNotWrittenFuture(IoSession session)
Returns a new
DefaultWriteFuture which is already marked as 'not written'. |
static WriteFuture |
DefaultWriteFuture.newWrittenFuture(IoSession session)
Returns a new
DefaultWriteFuture which is already marked as 'written'. |
void |
DefaultConnectFuture.setSession(IoSession session) |
构造器和说明 |
---|
AbstractIoFilterChain(IoSession session) |
DefaultCloseFuture(IoSession session)
Creates a new instance.
|
DefaultCloseFuture(IoSession session,
java.lang.Object lock)
Creates a new instance which uses the specified object as a lock.
|
DefaultIoFuture(IoSession session)
Creates a new instance.
|
DefaultIoFuture(IoSession session,
java.lang.Object lock)
Creates a new instance.
|
DefaultWriteFuture(IoSession session)
Creates a new instance.
|
DefaultWriteFuture(IoSession session,
java.lang.Object lock)
Creates a new instance which uses the specified object as a lock.
|
限定符和类型 | 方法和说明 |
---|---|
void |
ChatProtocolHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ChatProtocolHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
ChatProtocolHandler.sessionClosed(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
SwingChatClientHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
SwingChatClientHandler.sessionClosed(IoSession session) |
void |
SwingChatClientHandler.sessionCreated(IoSession session) |
void |
SwingChatClientHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
EchoProtocolHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
EchoProtocolHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
EchoProtocolHandler.sessionCreated(IoSession session) |
void |
EchoProtocolHandler.sessionIdle(IoSession session,
IdleStatus status) |
限定符和类型 | 方法和说明 |
---|---|
void |
ToHaikuIoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
HaikuValidatorIoHandler.messageReceived(IoSession session,
java.lang.Object message) |
限定符和类型 | 方法和说明 |
---|---|
MessageDecoderResult |
HttpRequestDecoder.decodable(IoSession session,
ByteBuffer in) |
MessageDecoderResult |
HttpRequestDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
void |
HttpResponseEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
ServerHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ServerHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
ServerHandler.sessionIdle(IoSession session,
IdleStatus status) |
void |
ServerHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
protected void |
HttpProtocolHandler.processStreamIo(IoSession session,
java.io.InputStream in,
java.io.OutputStream out) |
限定符和类型 | 方法和说明 |
---|---|
void |
NetCatProtocolHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
NetCatProtocolHandler.sessionClosed(IoSession session) |
void |
NetCatProtocolHandler.sessionIdle(IoSession session,
IdleStatus status) |
void |
NetCatProtocolHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
AbstractProxyIoHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
AbstractProxyIoHandler.sessionClosed(IoSession session) |
void |
AbstractProxyIoHandler.sessionCreated(IoSession session) |
void |
ClientToProxyIoHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
ReverseProtocolHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ReverseProtocolHandler.messageReceived(IoSession session,
java.lang.Object message) |
限定符和类型 | 方法和说明 |
---|---|
void |
ServerSessionHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ClientSessionHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ServerSessionHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
ClientSessionHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
ServerSessionHandler.sessionIdle(IoSession session,
IdleStatus status) |
void |
ServerSessionHandler.sessionOpened(IoSession session) |
void |
ClientSessionHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
MessageDecoderResult |
AbstractMessageDecoder.decodable(IoSession session,
ByteBuffer in) |
MessageDecoderResult |
AbstractMessageDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
protected AbstractMessage |
ResultMessageDecoder.decodeBody(IoSession session,
ByteBuffer in) |
protected AbstractMessage |
AddMessageDecoder.decodeBody(IoSession session,
ByteBuffer in) |
protected abstract AbstractMessage |
AbstractMessageDecoder.decodeBody(IoSession session,
ByteBuffer in) |
void |
AbstractMessageEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
protected void |
ResultMessageEncoder.encodeBody(IoSession session,
AbstractMessage message,
ByteBuffer out) |
protected void |
AddMessageEncoder.encodeBody(IoSession session,
AbstractMessage message,
ByteBuffer out) |
protected abstract void |
AbstractMessageEncoder.encodeBody(IoSession session,
AbstractMessage message,
ByteBuffer out) |
void |
ResultMessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
AddMessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
限定符和类型 | 方法和说明 |
---|---|
void |
TennisPlayer.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
TennisPlayer.messageReceived(IoSession session,
java.lang.Object message) |
void |
TennisPlayer.messageSent(IoSession session,
java.lang.Object message) |
void |
TennisPlayer.sessionClosed(IoSession session) |
void |
TennisPlayer.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
ReferenceCountingIoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
SSLFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingIoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
StreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
SSLFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
ReferenceCountingIoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
LoggingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
CompressionFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
javax.net.ssl.SSLSession |
SSLFilter.getSSLSession(IoSession session)
Returns the underlying
SSLSession for the specified session. |
boolean |
SSLFilter.isSSLStarted(IoSession session)
Returns true if and only if the specified session is
encrypted/decrypted over SSL/TLS currently.
|
void |
SSLFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ReferenceCountingIoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
BlacklistFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
StreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
SSLFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ReferenceCountingIoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
SSLFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingIoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingIoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingIoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ReferenceCountingIoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
boolean |
SSLFilter.startSSL(IoSession session)
(Re)starts SSL session for the specified session if not started yet.
|
WriteFuture |
SSLFilter.stopSSL(IoSession session)
Stops the SSL session by sending TLS close_notify message to
initiate TLS closure.
|
限定符和类型 | 方法和说明 |
---|---|
void |
SynchronizedProtocolDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
void |
ProtocolDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
CumulativeProtocolDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Cumulates content of in into internal buffer and forwards
decoding request to
CumulativeProtocolDecoder.doDecode(IoSession, ByteBuffer, ProtocolDecoderOutput) . |
void |
SynchronizedProtocolEncoder.dispose(IoSession session) |
void |
SynchronizedProtocolDecoder.dispose(IoSession session) |
void |
ProtocolEncoderAdapter.dispose(IoSession session)
Override this method dispose all resources related with this encoder.
|
void |
ProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
ProtocolDecoderAdapter.dispose(IoSession session)
Override this method to dispose all resources related with this decoder.
|
void |
ProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
CumulativeProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
protected abstract boolean |
CumulativeProtocolDecoder.doDecode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
SynchronizedProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
ProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
ProtocolCodecFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
ProtocolDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
ProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
MessageDecoderResult |
MessageDecoder.decodable(IoSession session,
ByteBuffer in)
Checks the specified buffer is decodable by this decoder.
|
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
protected void |
DemuxingProtocolCodecFactory.disposeCodecResources(IoSession session)
Implement this method to release all resources acquired to perform
encoding and decoding messages for the specified session.
|
void |
MessageEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
MessageDecoderAdapter.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
void |
MessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed while this decoder was
parsing the data.
|
限定符和类型 | 方法和说明 |
---|---|
void |
NettyDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
void |
NettyEncoder.dispose(IoSession session) |
void |
NettyEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
void |
ObjectSerializationEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
构造器和说明 |
---|
SimpleProtocolDecoderOutput(IoSession session,
IoFilter.NextFilter nextFilter) |
限定符和类型 | 方法和说明 |
---|---|
void |
TextLineDecoder.decode(IoSession session,
ByteBuffer in,
ProtocolDecoderOutput out) |
void |
TextLineDecoder.dispose(IoSession session) |
void |
TextLineEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
限定符和类型 | 方法和说明 |
---|---|
void |
ExecutorFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ExecutorFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ExecutorFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
ExecutorFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
ExecutorFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
protected void |
ExecutorFilter.processEvent(IoFilter.NextFilter nextFilter,
IoSession session,
ExecutorFilter.EventType type,
java.lang.Object data) |
void |
ExecutorFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ExecutorFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ExecutorFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ExecutorFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
SSLHandler.getSession() |
构造器和说明 |
---|
SSLHandler(SSLFilter parent,
javax.net.ssl.SSLContext sslc,
IoSession session)
Constuctor.
|
限定符和类型 | 方法和说明 |
---|---|
void |
StreamIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards caught exceptions to input stream.
|
void |
StreamIoHandler.messageReceived(IoSession session,
java.lang.Object buf)
Forwards read data to input stream.
|
protected abstract void |
StreamIoHandler.processStreamIo(IoSession session,
java.io.InputStream in,
java.io.OutputStream out)
Implement this method to execute your stream I/O logic;
please note that you must forward the process request to other
thread or thread pool.
|
void |
StreamIoHandler.sessionClosed(IoSession session)
Closes streams
|
void |
StreamIoHandler.sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout.
|
void |
StreamIoHandler.sessionOpened(IoSession session)
Initializes streams and timeout settings.
|
限定符和类型 | 方法和说明 |
---|---|
void |
IoHandlerCommand.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message)
Execute a unit of processing work to be performed.
|
void |
IoHandlerChain.execute(IoHandlerCommand.NextCommand next,
IoSession session,
java.lang.Object message) |
void |
IoHandlerCommand.NextCommand.execute(IoSession session,
java.lang.Object message)
Forwards the request to the next
IoHandlerCommand in the
IoHandlerChain . |
void |
ChainedIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Handles the specified messageReceived event with the
IoHandlerCommand or IoHandlerChain you specified
in the constructor. |
限定符和类型 | 方法和说明 |
---|---|
void |
MessageHandler.messageReceived(IoSession session,
E message)
Invoked when the specific type of message is received from the
specified
session . |
void |
DemuxingIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Forwards the received events into the appropriate
MessageHandler
which is registered by DemuxingIoHandler.addMessageHandler(Class, MessageHandler) . |
限定符和类型 | 方法和说明 |
---|---|
protected IoSession |
SingleSessionIoHandlerAdapter.getSession()
Retrieves the session to which this handler is assigned.
|
限定符和类型 | 方法和说明 |
---|---|
void |
SingleSessionIoHandlerDelegate.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Delegates the method call to the
SingleSessionIoHandler.exceptionCaught(Throwable) method of the
handler assigned to this session. |
SingleSessionIoHandler |
SingleSessionIoHandlerFactory.getHandler(IoSession session)
Returns a
SingleSessionIoHandler for the given session. |
void |
SingleSessionIoHandlerDelegate.messageReceived(IoSession session,
java.lang.Object message)
Delegates the method call to the
SingleSessionIoHandler.messageReceived(Object) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.messageSent(IoSession session,
java.lang.Object message)
Delegates the method call to the
SingleSessionIoHandler.messageSent(Object) method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionClosed(IoSession session)
Delegates the method call to the
SingleSessionIoHandler.sessionClosed() method of the handler
assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionCreated(IoSession session)
Creates a new instance with the factory passed to the constructor of
this class.
|
void |
SingleSessionIoHandlerDelegate.sessionIdle(IoSession session,
IdleStatus status)
Delegates the method call to the
SingleSessionIoHandler.sessionIdle(IdleStatus) method of the
handler assigned to this session. |
void |
SingleSessionIoHandlerDelegate.sessionOpened(IoSession session)
Delegates the method call to the
SingleSessionIoHandler.sessionOpened() method of the handler
assigned to this session. |
构造器和说明 |
---|
SingleSessionIoHandlerAdapter(IoSession session)
Creates a new instance that is assigned to the passed in session.
|
构造器和说明 |
---|
IoSessionOutputStream(IoSession session) |
构造器和说明 |
---|
IoSessionManager(IoSession session)
create the session manager
|
限定符和类型 | 方法和说明 |
---|---|
IoSession |
DatagramAcceptorDelegate.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress) |
限定符和类型 | 类和说明 |
---|---|
class |
VmPipeSessionImpl
A
IoSession for in-VM transport (VM_PIPE). |
限定符和类型 | 方法和说明 |
---|---|
protected void |
VmPipeFilterChain.doClose(IoSession session) |
protected void |
VmPipeFilterChain.doWrite(IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
VmPipeFilterChain.fireExceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
VmPipeFilterChain.fireFilterClose(IoSession session) |
void |
VmPipeFilterChain.fireFilterWrite(IoSession session,
IoFilter.WriteRequest writeRequest) |
void |
VmPipeFilterChain.fireMessageReceived(IoSession session,
java.lang.Object message) |
void |
VmPipeFilterChain.fireMessageSent(IoSession session,
IoFilter.WriteRequest request) |
void |
VmPipeFilterChain.fireSessionClosed(IoSession session) |
void |
VmPipeFilterChain.fireSessionCreated(IoSession session) |
void |
VmPipeFilterChain.fireSessionIdle(IoSession session,
IdleStatus status) |
void |
VmPipeFilterChain.fireSessionOpened(IoSession session) |
构造器和说明 |
---|
VmPipeFilterChain(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
static void |
SessionLog.debug(IoSession session,
java.lang.String message) |
static void |
SessionLog.debug(IoSession session,
java.lang.String message,
java.lang.Throwable cause) |
static void |
SessionLog.error(IoSession session,
java.lang.String message) |
static void |
SessionLog.error(IoSession session,
java.lang.String message,
java.lang.Throwable cause) |
static void |
SessionLog.info(IoSession session,
java.lang.String message) |
static void |
SessionLog.info(IoSession session,
java.lang.String message,
java.lang.Throwable cause) |
static void |
SessionUtil.initialize(IoSession session) |
static boolean |
SessionLog.isDebugEnabled(IoSession session) |
static boolean |
SessionLog.isErrorEnabled(IoSession session) |
static boolean |
SessionLog.isInfoEnabled(IoSession session) |
static boolean |
SessionLog.isWarnEnabled(IoSession session) |
static void |
SessionLog.warn(IoSession session,
java.lang.String message) |
static void |
SessionLog.warn(IoSession session,
java.lang.String message,
java.lang.Throwable cause) |