程序包 | 说明 |
---|---|
org.apache.mina.core |
Common types required for users to use MINA.
|
org.apache.mina.core.filterchain | |
org.apache.mina.core.future | |
org.apache.mina.core.polling |
Base class for implementing transport based on active polling strategies like NIO select call, or any API
based on I/O polling system calls (epoll, poll, select, kqueue, etc).
|
org.apache.mina.core.service | |
org.apache.mina.core.session | |
org.apache.mina.core.write | |
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.gettingstarted.timeserver | |
org.apache.mina.example.haiku | |
org.apache.mina.example.imagine.step1.client | |
org.apache.mina.example.imagine.step1.codec | |
org.apache.mina.example.imagine.step1.server | |
org.apache.mina.example.imagine.step3.server | |
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.tapedeck | |
org.apache.mina.example.tcp.perf | |
org.apache.mina.example.tennis |
Two tennis players play a game which demonstates in-VM pipes.
|
org.apache.mina.example.udp | |
org.apache.mina.example.udp.client | |
org.apache.mina.example.udp.perf | |
org.apache.mina.filter.buffer | |
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.prefixedstring | |
org.apache.mina.filter.codec.serialization |
Protocol codecs which uses Java object serilization and leads to rapid protocol
implementation.
|
org.apache.mina.filter.codec.statemachine | |
org.apache.mina.filter.codec.textline |
A protocol codec for text-based protocols.
|
org.apache.mina.filter.compression | |
org.apache.mina.filter.errorgenerating |
An IoFilter that provides flexible error generation facilities.
|
org.apache.mina.filter.executor |
IoFilters that provide flexible thread model and event queue
monitoring interface.
|
org.apache.mina.filter.firewall |
Classes that implement IoFilter and provide host blocking and throttling.
|
org.apache.mina.filter.keepalive |
IoFilter that provides the ability for connections to remain open when data is not being transferred.
|
org.apache.mina.filter.logging |
Classes that implement IoFilter and provide logging of the events and data that flows through a MINA-based system.
|
org.apache.mina.filter.ssl |
Classes that implement IoFilter and provide Secure Sockets Layer functionality.
|
org.apache.mina.filter.statistic |
Classes that implement IoFilter and provide the ability for filters to be timed on their performance.
|
org.apache.mina.filter.stream |
Stream based IoFilter implementation.
|
org.apache.mina.filter.util |
Utility classes for the MINA filtering portion of the library.
|
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.stream | |
org.apache.mina.http | |
org.apache.mina.integration.ognl | |
org.apache.mina.proxy | |
org.apache.mina.proxy.event | |
org.apache.mina.proxy.filter | |
org.apache.mina.proxy.handlers.http.digest | |
org.apache.mina.proxy.session | |
org.apache.mina.transport.serial | |
org.apache.mina.transport.socket.apr | |
org.apache.mina.transport.socket.nio |
Socket (TCP/IP) and Datagram (UDP/IP) support based on Java
NIO (New I/O) API.
|
org.apache.mina.transport.vmpipe |
In-VM pipe support which removes the overhead of local loopback communication.
|
限定符和类型 | 方法和说明 |
---|---|
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
IoSession... sessions)
Writes the specified
message to the specified sessions . |
限定符和类型 | 方法和说明 |
---|---|
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Collection<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.lang.Iterable<IoSession> sessions)
Writes the specified
message to the specified sessions . |
static java.util.List<WriteFuture> |
IoUtil.broadcast(java.lang.Object message,
java.util.Iterator<IoSession> sessions)
Writes the specified
message to the specified sessions . |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoFilterChain.getSession() |
IoSession |
DefaultIoFilterChain.getSession() |
限定符和类型 | 方法和说明 |
---|---|
void |
IoFilterAdapter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
IoFilter.NextFilter.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards exceptionCaught event to next filter.
|
void |
IoFilterAdapter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close(boolean) method invocation. |
void |
IoFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
close(boolean) method invocation. |
void |
IoFilter.NextFilter.filterClose(IoSession session)
Forwards filterClose event to next filter.
|
void |
IoFilterAdapter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
IoFilter.NextFilter.filterWrite(IoSession session,
WriteRequest writeRequest)
Forwards filterWrite event to next filter.
|
void |
IoFilterAdapter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.inputClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.inputClosed(IoSession) event. |
void |
IoFilter.NextFilter.inputClosed(IoSession session) |
void |
IoFilterAdapter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageReceived(IoSession session,
java.lang.Object message)
Forwards messageReceived event to next filter.
|
void |
IoFilterAdapter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
IoFilter.NextFilter.messageSent(IoSession session,
WriteRequest writeRequest)
Forwards messageSent event to next filter.
|
void |
IoFilterAdapter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
void |
IoFilter.NextFilter.sessionClosed(IoSession session)
Forwards sessionClosed event to next filter.
|
void |
IoFilterAdapter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionCreated(IoSession) event. |
void |
IoFilter.NextFilter.sessionCreated(IoSession session)
Forwards sessionCreated event to next filter.
|
void |
IoFilterAdapter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
void |
IoFilter.NextFilter.sessionIdle(IoSession session,
IdleStatus status)
Forwards sessionIdle event to next filter.
|
void |
IoFilterAdapter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionOpened(IoSession) event. |
void |
IoFilter.NextFilter.sessionOpened(IoSession session)
Forwards sessionOpened event to next filter.
|
构造器和说明 |
---|
IoFilterEvent(IoFilter.NextFilter nextFilter,
IoEventType type,
IoSession session,
java.lang.Object parameter) |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoFuture.getSession() |
IoSession |
DefaultIoFuture.getSession() |
IoSession |
DefaultConnectFuture.getSession() |
IoSession |
ConnectFuture.getSession()
Returns
IoSession which is the result of connect operation. |
限定符和类型 | 方法和说明 |
---|---|
static WriteFuture |
DefaultWriteFuture.newNotWrittenFuture(IoSession session,
java.lang.Throwable cause)
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)
Sets the newly connected session and notifies all threads waiting for
this future.
|
void |
ConnectFuture.setSession(IoSession session)
Sets the newly connected session and notifies all threads waiting for
this future.
|
构造器和说明 |
---|
DefaultCloseFuture(IoSession session)
Creates a new instance.
|
DefaultIoFuture(IoSession session)
Creates a new instance associated with an
IoSession . |
DefaultReadFuture(IoSession session)
Creates a new instance.
|
DefaultWriteFuture(IoSession session)
Creates a new instance.
|
限定符和类型 | 方法和说明 |
---|---|
IoSession |
AbstractPollingIoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
限定符和类型 | 接口和说明 |
---|---|
interface |
IoProcessor<S extends IoSession>
An internal interface to represent an 'I/O processor' that performs
actual I/O operations for
IoSession s. |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
限定符和类型 | 方法和说明 |
---|---|
java.util.Map<java.lang.Long,IoSession> |
IoServiceListenerSupport.getManagedSessions() |
java.util.Map<java.lang.Long,IoSession> |
IoService.getManagedSessions() |
java.util.Map<java.lang.Long,IoSession> |
AbstractIoService.getManagedSessions() |
限定符和类型 | 方法和说明 |
---|---|
void |
IoHandlerAdapter.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
IoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
protected void |
AbstractIoService.finishSessionInitialization0(IoSession session,
IoFuture future)
Implement this method to perform additional tasks required for session
initialization.
|
protected void |
AbstractIoConnector.finishSessionInitialization0(IoSession session,
IoFuture future)
Adds required internal attributes and
IoFutureListener s
related with event notifications to the specified session
and future . |
void |
IoServiceListenerSupport.fireSessionCreated(IoSession session)
Calls
IoServiceListener.sessionCreated(IoSession) for all registered listeners. |
void |
IoServiceListenerSupport.fireSessionDestroyed(IoSession session)
Calls
IoServiceListener.sessionDestroyed(IoSession) for all registered listeners. |
protected void |
AbstractIoService.initSession(IoSession session,
IoFuture future,
IoSessionInitializer sessionInitializer) |
void |
IoHandlerAdapter.inputClosed(IoSession session)
Handle the closure of an half-duplex TCP channel
|
void |
IoHandler.inputClosed(IoSession session)
Handle the closure of an half-duplex TCP channel
|
void |
IoHandlerAdapter.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
IoHandler.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
IoHandlerAdapter.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
IoServiceListener.sessionClosed(IoSession session)
Invoked when a new session is closed by an
IoService . |
void |
IoHandlerAdapter.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
IoServiceListener.sessionCreated(IoSession session)
Invoked when a new session is created by an
IoService . |
void |
IoHandlerAdapter.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
IoServiceListener.sessionDestroyed(IoSession session)
Invoked when a session is being destroyed by an
IoService . |
void |
IoHandlerAdapter.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandler.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
IoHandlerAdapter.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
IoHandler.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
限定符和类型 | 类和说明 |
---|---|
class |
AbstractIoSession
Base implementation of
IoSession . |
class |
DummySession
|
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoEvent.getSession() |
IoSession |
IoSessionRecycler.recycle(java.net.SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
IoSession |
ExpiringSessionRecycler.recycle(java.net.SocketAddress remoteAddress)
Attempts to retrieve a recycled
IoSession . |
限定符和类型 | 方法和说明 |
---|---|
IoProcessor<IoSession> |
DummySession.getProcessor() |
限定符和类型 | 方法和说明 |
---|---|
boolean |
IoSessionAttributeMap.containsAttribute(IoSession session,
java.lang.Object key) |
void |
IoSessionAttributeMap.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
java.lang.Object |
IoSessionAttributeMap.getAttribute(IoSession session,
java.lang.Object key,
java.lang.Object defaultValue) |
java.util.Set<java.lang.Object> |
IoSessionAttributeMap.getAttributeKeys(IoSession session) |
IoSessionAttributeMap |
IoSessionDataStructureFactory.getAttributeMap(IoSession session) |
IoSessionAttributeMap |
DefaultIoSessionDataStructureFactory.getAttributeMap(IoSession session) |
WriteRequestQueue |
IoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
WriteRequestQueue |
DefaultIoSessionDataStructureFactory.getWriteRequestQueue(IoSession session) |
void |
IoSessionInitializer.initializeSession(IoSession session,
T future) |
static void |
AbstractIoSession.notifyIdleSession(IoSession session,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event if applicable for the
specified session . |
void |
IoSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
ExpiringSessionRecycler.put(IoSession session)
Called when the underlying transport creates or writes a new
IoSession . |
void |
IoSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
void |
ExpiringSessionRecycler.remove(IoSession session)
Called when an
IoSession is explicitly closed. |
java.lang.Object |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key)
Removes a user-defined attribute with the specified key.
|
boolean |
IoSessionAttributeMap.removeAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Removes a user defined attribute with the specified key if the current
attribute value is equal to the specified value.
|
boolean |
IoSessionAttributeMap.replaceAttribute(IoSession session,
java.lang.Object key,
java.lang.Object oldValue,
java.lang.Object newValue)
Replaces a user defined attribute with the specified key if the
value of the attribute is equals to the specified old value.
|
java.lang.Object |
IoSessionAttributeMap.setAttribute(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user-defined attribute.
|
java.lang.Object |
IoSessionAttributeMap.setAttributeIfAbsent(IoSession session,
java.lang.Object key,
java.lang.Object value)
Sets a user defined attribute if the attribute with the specified key
is not set yet.
|
限定符和类型 | 方法和说明 |
---|---|
static void |
AbstractIoSession.notifyIdleness(java.util.Iterator<? extends IoSession> sessions,
long currentTime)
Fires a
IoEventType.SESSION_IDLE event to any applicable sessions
in the specified collection. |
构造器和说明 |
---|
IoEvent(IoEventType type,
IoSession session,
java.lang.Object parameter) |
限定符和类型 | 方法和说明 |
---|---|
void |
WriteRequestQueue.clear(IoSession session)
Removes all the requests from this session's queue.
|
void |
WriteRequestQueue.dispose(IoSession session)
Disposes any releases associated with the specified session.
|
boolean |
WriteRequestQueue.isEmpty(IoSession session)
Tells if the WriteRequest queue is empty or not for a session
|
void |
WriteRequestQueue.offer(IoSession session,
WriteRequest writeRequest)
Add a new WriteRequest to the session write's queue
|
WriteRequest |
WriteRequestQueue.poll(IoSession session)
Get the first request available in the queue for a session.
|
限定符和类型 | 方法和说明 |
---|---|
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.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
EchoProtocolHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
EchoProtocolHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
EchoProtocolHandler.sessionClosed(IoSession session) |
void |
EchoProtocolHandler.sessionCreated(IoSession session) |
void |
EchoProtocolHandler.sessionIdle(IoSession session,
IdleStatus status) |
void |
EchoProtocolHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
TimeServerHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Trap exceptions.
|
void |
TimeServerHandler.messageReceived(IoSession session,
java.lang.Object message)
If the message is 'quit', we exit by closing the session.
|
void |
TimeServerHandler.sessionIdle(IoSession session,
IdleStatus status)
On idle, we just write a message on the console
|
限定符和类型 | 方法和说明 |
---|---|
void |
ToHaikuIoFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
HaikuValidatorIoHandler.messageReceived(IoSession session,
java.lang.Object message) |
限定符和类型 | 方法和说明 |
---|---|
void |
ImageClient.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
ImageClient.messageReceived(IoSession session,
java.lang.Object message) |
void |
ImageClient.sessionClosed(IoSession session) |
void |
ImageClient.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
ImageRequestEncoder.dispose(IoSession session) |
protected boolean |
ImageResponseDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
protected boolean |
ImageRequestDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
ImageResponseEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
ImageRequestEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
ImageCodecFactory.getDecoder(IoSession ioSession) |
ProtocolEncoder |
ImageCodecFactory.getEncoder(IoSession ioSession) |
限定符和类型 | 方法和说明 |
---|---|
void |
ImageServerIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
This method will be called whenever an exception occurs.
|
void |
ImageServerIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Handle incoming messages.
|
void |
ImageServerIoHandler.sessionOpened(IoSession session)
Called when the session is opened, which will come after the session created.
|
限定符和类型 | 方法和说明 |
---|---|
void |
ImageServerIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
This method will be called whenever an exception occurs.
|
void |
ImageServerIoHandler.messageReceived(IoSession session,
java.lang.Object message)
Handle incoming messages.
|
void |
ImageServerIoHandler.sessionCreated(IoSession session)
This method is called first when a new connection to the server is made.
|
void |
ImageServerIoHandler.sessionOpened(IoSession session)
Called when the session is opened, which will come after the session created.
|
限定符和类型 | 方法和说明 |
---|---|
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)
Invoked when a message is received.
|
void |
AbstractProxyIoHandler.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
AbstractProxyIoHandler.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
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,
IoBuffer in) |
MessageDecoderResult |
AbstractMessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
protected AbstractMessage |
ResultMessageDecoder.decodeBody(IoSession session,
IoBuffer in) |
protected AbstractMessage |
AddMessageDecoder.decodeBody(IoSession session,
IoBuffer in) |
protected abstract AbstractMessage |
AbstractMessageDecoder.decodeBody(IoSession session,
IoBuffer in) |
void |
AbstractMessageEncoder.encode(IoSession session,
T message,
ProtocolEncoderOutput out) |
protected void |
ResultMessageEncoder.encodeBody(IoSession session,
T message,
IoBuffer out) |
protected void |
AddMessageEncoder.encodeBody(IoSession session,
T message,
IoBuffer out) |
protected abstract void |
AbstractMessageEncoder.encodeBody(IoSession session,
T message,
IoBuffer out) |
void |
ResultMessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
AddMessageDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
限定符和类型 | 方法和说明 |
---|---|
void |
TapeDeckServer.commandSyntaxError(IoSession session,
CommandSyntaxException e) |
void |
AuthenticationHandler.commandSyntaxError(IoSession session,
CommandSyntaxException e) |
void |
TapeDeckServer.connect(IoSession session) |
void |
CommandDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
TapeDeckServer.ejectTape(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
EjectCommand cmd) |
void |
TapeDeckServer.error(Event event,
StateContext context,
IoSession session,
Command cmd) |
void |
AuthenticationHandler.errorWaitingForPassword(IoSession session,
Command cmd) |
void |
AuthenticationHandler.errorWaitingForUser(IoSession session,
Command cmd) |
void |
AuthenticationHandler.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
TapeDeckServer.exceptionCaught(IoSession session,
java.lang.Exception e) |
void |
AuthenticationHandler.exceptionCaught(IoSession session,
java.lang.Exception e) |
void |
AuthenticationHandler.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
AuthenticationHandler.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
TapeDeckServer.info(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
InfoCommand cmd) |
void |
TapeDeckServer.listTapes(IoSession session,
ListCommand cmd) |
void |
TapeDeckServer.loadTape(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
LoadCommand cmd) |
void |
AuthenticationHandler.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
AuthenticationHandler.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AuthenticationHandler.password(org.apache.mina.example.tapedeck.AuthenticationHandler.AuthenticationContext context,
IoFilter.NextFilter nextFilter,
IoSession session,
PasswordCommand cmd) |
void |
TapeDeckServer.pauseTape(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
PauseCommand cmd) |
void |
TapeDeckServer.playTape(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
PlayCommand cmd) |
void |
TapeDeckServer.quit(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
QuitCommand cmd) |
void |
AuthenticationHandler.quit(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
QuitCommand cmd) |
void |
AuthenticationHandler.sendAuthRequest(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
AuthenticationHandler.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
TapeDeckServer.stopTape(org.apache.mina.example.tapedeck.TapeDeckServer.TapeDeckContext context,
IoSession session,
StopCommand cmd) |
void |
AuthenticationHandler.user(org.apache.mina.example.tapedeck.AuthenticationHandler.AuthenticationContext context,
IoFilter.NextFilter nextFilter,
IoSession session,
UserCommand cmd) |
限定符和类型 | 方法和说明 |
---|---|
void |
TcpServer.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
TcpClient.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
TcpServer.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
TcpClient.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
TcpClient.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
TcpServer.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
TcpClient.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
TcpServer.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
TcpClient.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
TcpServer.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
TcpClient.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
TcpServer.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
TcpClient.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
限定符和类型 | 方法和说明 |
---|---|
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 |
MemoryMonitorHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
MemoryMonitorHandler.messageReceived(IoSession session,
java.lang.Object message) |
void |
MemoryMonitorHandler.sessionClosed(IoSession session) |
void |
MemoryMonitorHandler.sessionCreated(IoSession session) |
void |
MemoryMonitorHandler.sessionIdle(IoSession session,
IdleStatus status) |
void |
MemoryMonitorHandler.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
MemMonClient.exceptionCaught(IoSession session,
java.lang.Throwable cause) |
void |
MemMonClient.messageReceived(IoSession session,
java.lang.Object message) |
void |
MemMonClient.messageSent(IoSession session,
java.lang.Object message) |
void |
MemMonClient.sessionClosed(IoSession session) |
void |
MemMonClient.sessionCreated(IoSession session) |
void |
MemMonClient.sessionIdle(IoSession session,
IdleStatus status) |
void |
MemMonClient.sessionOpened(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
void |
UdpServer.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
UdpClient.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user
IoHandler
implementation or by MINA. |
void |
UdpServer.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
UdpClient.messageReceived(IoSession session,
java.lang.Object message)
Invoked when a message is received.
|
void |
UdpClient.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by
write(Object) is
sent out. |
void |
UdpServer.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
UdpClient.sessionClosed(IoSession session)
Invoked when a connection is closed.
|
void |
UdpServer.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
UdpClient.sessionCreated(IoSession session)
Invoked from an I/O processor thread when a new connection has been created.
|
void |
UdpServer.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
UdpClient.sessionIdle(IoSession session,
IdleStatus status)
Invoked with the related
IdleStatus when a connection becomes idle. |
void |
UdpServer.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
void |
UdpClient.sessionOpened(IoSession session)
Invoked when a connection has been opened.
|
限定符和类型 | 方法和说明 |
---|---|
void |
BufferedWriteFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Filters
IoHandler.exceptionCaught(IoSession,Throwable) event. |
void |
BufferedWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
write(Object) method invocation. |
void |
BufferedWriteFilter.flush(IoSession session)
Flushes the buffered data.
|
void |
BufferedWriteFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Filters
IoHandler.sessionClosed(IoSession) event. |
构造器和说明 |
---|
BufferedWriteFilter(int bufferSize,
LazyInitializedCacheMap<IoSession,IoBuffer> buffersMap)
Constructor which sets buffer size to
bufferSize . |
限定符和类型 | 类和说明 |
---|---|
class |
ProtocolCodecSession
|
限定符和类型 | 方法和说明 |
---|---|
void |
SynchronizedProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
ProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
CumulativeProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Cumulates content of in into internal buffer and forwards
decoding request to
CumulativeProtocolDecoder.doDecode(IoSession, IoBuffer, ProtocolDecoderOutput) . |
void |
SynchronizedProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
SynchronizedProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
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,
IoBuffer 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)
Encodes higher-level message objects into binary or protocol-specific data.
|
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,
WriteRequest writeRequest) |
void |
SynchronizedProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
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 |
ProtocolDecoderOutput.flush(IoFilter.NextFilter nextFilter,
IoSession session)
Flushes all messages you wrote via
ProtocolDecoderOutput.write(Object) to
the next filter. |
ProtocolDecoder |
ProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
ProtocolCodecFilter.getEncoder(IoSession session)
Get the encoder instance from a given session.
|
ProtocolEncoder |
ProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
void |
ProtocolCodecFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Process the incoming message, calling the session decoder.
|
void |
ProtocolCodecFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ProtocolCodecFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
MessageDecoderResult |
MessageDecoder.decodable(IoSession session,
IoBuffer in)
Checks the specified buffer is decodable by this decoder.
|
MessageDecoderResult |
MessageDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DemuxingProtocolEncoder.dispose(IoSession session)
Releases all resources related with this encoder.
|
void |
DemuxingProtocolDecoder.dispose(IoSession session)
Releases the cumulative buffer used by the specified session.
|
protected boolean |
DemuxingProtocolDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
DemuxingProtocolEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
MessageEncoder.encode(IoSession session,
T 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 |
DemuxingProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Override this method to deal with the closed connection.
|
ProtocolDecoder |
DemuxingProtocolCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
DemuxingProtocolCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
PrefixedStringDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out) |
void |
PrefixedStringEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
ProtocolDecoder |
PrefixedStringCodecFactory.getDecoder(IoSession session) |
ProtocolEncoder |
PrefixedStringCodecFactory.getEncoder(IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
ObjectSerializationDecoder.doDecode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Implement this method to consume the specified cumulative buffer and
decode its content into message(s).
|
void |
ObjectSerializationEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
ProtocolDecoder |
ObjectSerializationCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
ObjectSerializationCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
限定符和类型 | 方法和说明 |
---|---|
void |
DecodingStateProtocolDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
DecodingStateProtocolDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
DecodingStateProtocolDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
限定符和类型 | 方法和说明 |
---|---|
void |
TextLineDecoder.decode(IoSession session,
IoBuffer in,
ProtocolDecoderOutput out)
Decodes binary or protocol-specific content into higher-level message objects.
|
void |
TextLineDecoder.dispose(IoSession session)
Releases all resources related with this decoder.
|
void |
TextLineEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out)
Encodes higher-level message objects into binary or protocol-specific data.
|
void |
TextLineDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out)
Invoked when the specified session is closed.
|
ProtocolDecoder |
TextLineCodecFactory.getDecoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolDecoder which
decodes binary or protocol-specific data into message objects. |
ProtocolEncoder |
TextLineCodecFactory.getEncoder(IoSession session)
Returns a new (or reusable) instance of
ProtocolEncoder which
encodes message objects into binary or protocol-specific data. |
protected void |
TextLineDecoder.writeText(IoSession session,
java.lang.String text,
ProtocolDecoderOutput out)
By default, this method propagates the decoded line of text to
ProtocolDecoderOutput#write(Object) . |
限定符和类型 | 方法和说明 |
---|---|
protected java.lang.Object |
CompressionFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CompressionFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
限定符和类型 | 方法和说明 |
---|---|
void |
ErrorGeneratingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ErrorGeneratingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
限定符和类型 | 方法和说明 |
---|---|
protected boolean |
ConnectionThrottleFilter.isConnectionOk(IoSession session)
Method responsible for deciding if a connection is OK
to continue
|
void |
BlacklistFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
BlacklistFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
BlacklistFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ConnectionThrottleFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
BlacklistFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
BlacklistFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
java.lang.Object |
KeepAliveMessageFactory.getRequest(IoSession session) |
java.lang.Object |
KeepAliveMessageFactory.getResponse(IoSession session,
java.lang.Object request) |
boolean |
KeepAliveMessageFactory.isRequest(IoSession session,
java.lang.Object message) |
boolean |
KeepAliveMessageFactory.isResponse(IoSession session,
java.lang.Object message) |
void |
KeepAliveRequestTimeoutHandler.keepAliveRequestTimedOut(KeepAliveFilter filter,
IoSession session)
Invoked when
KeepAliveFilter couldn't receive the response for
the sent keep alive message. |
void |
KeepAliveFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Filters
IoHandler.messageReceived(IoSession,Object) event. |
void |
KeepAliveFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters
IoHandler.messageSent(IoSession,Object) event. |
void |
KeepAliveFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Filters
IoHandler.sessionIdle(IoSession,IdleStatus) event. |
限定符和类型 | 方法和说明 |
---|---|
void |
LoggingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
protected void |
MdcInjectionFilter.fillContext(IoSession session,
java.util.Map<java.lang.String,java.lang.String> context)
write key properties of the session to the Mapped Diagnostic Context
sub-classes could override this method to map more/other attributes
|
static java.lang.String |
MdcInjectionFilter.getProperty(IoSession session,
java.lang.String key) |
void |
LoggingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
LoggingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
static void |
MdcInjectionFilter.removeProperty(IoSession session,
java.lang.String key) |
void |
LoggingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
LoggingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
LoggingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
static void |
MdcInjectionFilter.setProperty(IoSession session,
java.lang.String key,
java.lang.String value)
Add a property to the context for the given session
This property will be added to the MDC for all subsequent events
|
限定符和类型 | 方法和说明 |
---|---|
void |
SslFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
SslFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SslFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
javax.net.ssl.SSLSession |
SslFilter.getSslSession(IoSession session)
Returns the underlying
SSLSession for the specified session. |
void |
SslFilter.initiateHandshake(IoSession session)
Initiate the SSL handshake.
|
boolean |
SslFilter.isSslStarted(IoSession session) |
void |
SslFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
SslFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
SslFilter.sessionClosed(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 |
ProfilerTimerFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Profile a MessageReceived event.
|
void |
ProfilerTimerFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Profile a MessageSent event.
|
void |
ProfilerTimerFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionClosed event.
|
void |
ProfilerTimerFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionCreated event.
|
void |
ProfilerTimerFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Profile a SessionIdle event.
|
void |
ProfilerTimerFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Profile a SessionOpened event.
|
限定符和类型 | 方法和说明 |
---|---|
void |
AbstractStreamWriteFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
AbstractStreamWriteFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
限定符和类型 | 方法和说明 |
---|---|
protected abstract java.lang.Object |
WriteRequestFilter.doFilterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
CommonEventFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause) |
void |
ReferenceCountingFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.filterClose(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
WriteRequestFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
CommonEventFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message) |
void |
WriteRequestFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
CommonEventFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest) |
void |
ReferenceCountingFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
SessionAttributeInitializingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Puts all pre-configured attributes into the actual session attribute
map and forward the event to the next filter.
|
void |
ReferenceCountingFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
ReferenceCountingFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
CommonEventFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status) |
void |
ReferenceCountingFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
CommonEventFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
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 |
ExceptionHandler.exceptionCaught(IoSession session,
E cause)
Invoked when the specific type of exception is caught from the
specified
session . |
void |
DemuxingIoHandler.exceptionCaught(IoSession session,
java.lang.Throwable cause)
Invoked when any exception is thrown by user IoHandler implementation
or by MINA.
|
void |
MessageHandler.handleMessage(IoSession session,
E message)
Invoked when the specific type of message is received from or sent to
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.addReceivedMessageHandler(Class, MessageHandler) . |
void |
DemuxingIoHandler.messageSent(IoSession session,
java.lang.Object message)
Invoked when a message written by IoSession.write(Object) is sent out.
|
限定符和类型 | 方法和说明 |
---|---|
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)
已过时。
|
void |
SingleSessionIoHandlerDelegate.inputClosed(IoSession session)
已过时。
Handle the closure of an half-duplex TCP channel
|
void |
SingleSessionIoHandlerAdapter.inputClosed(IoSession session)
已过时。
|
void |
SingleSessionIoHandler.inputClosed(IoSession session)
已过时。
Invoked when a half-duplex connection is closed
|
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.
|
限定符和类型 | 方法和说明 |
---|---|
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 |
HttpServerDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out) |
void |
HttpClientDecoder.decode(IoSession session,
IoBuffer msg,
ProtocolDecoderOutput out) |
void |
HttpServerEncoder.dispose(IoSession session) |
void |
HttpServerDecoder.dispose(IoSession session) |
void |
HttpClientEncoder.dispose(IoSession arg0) |
void |
HttpClientDecoder.dispose(IoSession session) |
void |
HttpServerEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
HttpClientEncoder.encode(IoSession session,
java.lang.Object message,
ProtocolEncoderOutput out) |
void |
HttpServerDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
HttpClientDecoder.finishDecode(IoSession session,
ProtocolDecoderOutput out) |
void |
HttpServerCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
void |
HttpClientCodec.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session) |
限定符和类型 | 方法和说明 |
---|---|
java.util.Set<IoSession> |
IoSessionFinder.find(java.lang.Iterable<IoSession> sessions)
Finds a
Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
限定符和类型 | 方法和说明 |
---|---|
java.util.Set<IoSession> |
IoSessionFinder.find(java.lang.Iterable<IoSession> sessions)
Finds a
Set of IoSession s that matches the query
from the specified sessions and returns the matches. |
限定符和类型 | 方法和说明 |
---|---|
protected IoSession |
AbstractProxyLogicHandler.getSession() |
限定符和类型 | 方法和说明 |
---|---|
protected ConnectFuture |
ProxyConnector.fireConnected(IoSession session)
Fires the connection event on the real future to notify the client.
|
abstract void |
AbstractProxyIoHandler.proxySessionOpened(IoSession session)
Method called only when handshake has completed.
|
void |
AbstractProxyIoHandler.sessionOpened(IoSession session)
Hooked session opened event.
|
限定符和类型 | 方法和说明 |
---|---|
IoSession |
IoSessionEvent.getSession() |
构造器和说明 |
---|
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Creates an instance of this class when event type is
IoSessionEventType.IDLE . |
IoSessionEvent(IoFilter.NextFilter nextFilter,
IoSession session,
IoSessionEventType type)
Creates an instance of this class when event type differs from
IoSessionEventType.IDLE . |
限定符和类型 | 方法和说明 |
---|---|
void |
ProxyFilter.exceptionCaught(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Throwable cause)
Called when an exception occurs in the chain.
|
void |
ProxyFilter.filterWrite(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filters outgoing writes, queueing them up if necessary while a handshake
is ongoing.
|
void |
ProxyFilter.messageReceived(IoFilter.NextFilter nextFilter,
IoSession session,
java.lang.Object message)
Receives data from the remote host, passes to the handler if a handshake is in progress,
otherwise passes on transparently.
|
void |
ProxyFilter.messageSent(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest)
Filter handshake related messages from reaching the messageSent callbacks of
downstream filters.
|
void |
ProxyFilter.sessionClosed(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionCreated(IoFilter.NextFilter nextFilter,
IoSession session)
Called when the session is created.
|
void |
ProxyFilter.sessionIdle(IoFilter.NextFilter nextFilter,
IoSession session,
IdleStatus status)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.sessionOpened(IoFilter.NextFilter nextFilter,
IoSession session)
Event is stored in an
IoSessionEventQueue for later delivery to the next filter
in the chain when the handshake would have succeed. |
void |
ProxyFilter.writeData(IoFilter.NextFilter nextFilter,
IoSession session,
WriteRequest writeRequest,
boolean isHandshakeData)
Actually write data.
|
限定符和类型 | 方法和说明 |
---|---|
static java.lang.String |
DigestUtilities.computeResponseValue(IoSession session,
java.util.HashMap<java.lang.String,java.lang.String> map,
java.lang.String method,
java.lang.String pwd,
java.lang.String charsetName,
java.lang.String body)
Computes the response to the DIGEST challenge.
|
限定符和类型 | 方法和说明 |
---|---|
IoSession |
ProxyIoSession.getSession() |
限定符和类型 | 方法和说明 |
---|---|
void |
ProxyIoSessionInitializer.initializeSession(IoSession session,
T future) |
void |
ProxyIoSession.setSession(IoSession session)
Sets the
IoSession in use. |
限定符和类型 | 接口和说明 |
---|---|
interface |
SerialSession
An
IoSession for serial communication transport. |
限定符和类型 | 类和说明 |
---|---|
class |
AprSession
An abstract
IoSession serving of base for APR based sessions. |
限定符和类型 | 类和说明 |
---|---|
class |
NioSession
An
IoSession which is managed by the NIO transport. |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
NioDatagramAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |
限定符和类型 | 方法和说明 |
---|---|
IoSession |
VmPipeAcceptor.newSession(java.net.SocketAddress remoteAddress,
java.net.SocketAddress localAddress)
(Optional) Returns an
IoSession that is bound to the specified
localAddress and the specified remoteAddress which
reuses the local address that is already bound by this service. |