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, sessionCreated
protected 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
在接口中 IoHandler
sessionOpened
在类中 IoHandlerAdapter
public void sessionClosed(IoSession session) throws java.lang.Exception
sessionClosed
在接口中 IoHandler
sessionClosed
在类中 IoHandlerAdapter
java.lang.Exception
public void messageReceived(IoSession session, java.lang.Object buf)
messageReceived
在接口中 IoHandler
messageReceived
在类中 IoHandlerAdapter
public void exceptionCaught(IoSession session, java.lang.Throwable cause)
exceptionCaught
在接口中 IoHandler
exceptionCaught
在类中 IoHandlerAdapter
public void sessionIdle(IoSession session, IdleStatus status)
sessionIdle
在接口中 IoHandler
sessionIdle
在类中 IoHandlerAdapter