public abstract class StreamIoHandler extends IoHandlerAdapter
IoHandler that adapts asynchronous MINA events to stream I/O.
Please extend this class and implement
processStreamIo(IoSession, InputStream, OutputStream) to
execute your stream I/O logic; please note that you must forward
the process request to other thread or thread pool.
| 限定符 | 构造器和说明 |
|---|---|
protected |
StreamIoHandler() |
| 限定符和类型 | 方法和说明 |
|---|---|
void |
exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards caught exceptions to input stream.
|
int |
getReadTimeout()
Returns read timeout in seconds.
|
int |
getWriteTimeout()
Returns write timeout in seconds.
|
void |
messageReceived(IoSession session,
java.lang.Object buf)
Forwards read data to input stream.
|
protected abstract void |
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 |
sessionClosed(IoSession session)
Closes streams
|
void |
sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout.
|
void |
sessionOpened(IoSession session)
Initializes streams and timeout settings.
|
void |
setReadTimeout(int readTimeout)
Sets read timeout in seconds.
|
void |
setWriteTimeout(int writeTimeout)
Sets write timeout in seconds.
|
messageSent, sessionCreatedprotected abstract void processStreamIo(IoSession session, java.io.InputStream in, java.io.OutputStream out)
public int getReadTimeout()
public void setReadTimeout(int readTimeout)
public int getWriteTimeout()
public void setWriteTimeout(int writeTimeout)
public void sessionOpened(IoSession session)
sessionOpened 在接口中 IoHandlersessionOpened 在类中 IoHandlerAdapterpublic void sessionClosed(IoSession session) throws java.lang.Exception
sessionClosed 在接口中 IoHandlersessionClosed 在类中 IoHandlerAdapterjava.lang.Exceptionpublic void messageReceived(IoSession session, java.lang.Object buf)
messageReceived 在接口中 IoHandlermessageReceived 在类中 IoHandlerAdapterpublic void exceptionCaught(IoSession session, java.lang.Throwable cause)
exceptionCaught 在接口中 IoHandlerexceptionCaught 在类中 IoHandlerAdapterpublic void sessionIdle(IoSession session, IdleStatus status)
sessionIdle 在接口中 IoHandlersessionIdle 在类中 IoHandlerAdapter