org.apache.mina.handler.stream

类 StreamIoHandler

java.lang.Object

org.apache.mina.core.service.IoHandlerAdapter

org.apache.mina.handler.stream.StreamIoHandler

所有已实现的接口:

IoHandler

public abstract class StreamIoHandler
extends IoHandlerAdapter

A 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.

作者:

Apache MINA Project

构造器概要

构造器

限定符	构造器和说明
protected	StreamIoHandler()

方法概要

方法

限定符和类型	方法和说明
void	exceptionCaught(IoSession session, java.lang.Throwable cause) Forwards caught exceptions to input stream.
int	getReadTimeout()
int	getWriteTimeout()
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.

从类继承的方法 org.apache.mina.core.service.IoHandlerAdapter

inputClosed, messageSent, sessionCreated

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

StreamIoHandler

protected StreamIoHandler()

方法详细资料

processStreamIo

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.

参数:

session - The current session

in - The input stream

out - The output stream

getReadTimeout

public int getReadTimeout()

返回:

read timeout in seconds. The default value is 0 (disabled).

setReadTimeout

public void setReadTimeout(int readTimeout)

Sets read timeout in seconds. The default value is 0 (disabled).

参数:

readTimeout - The Read timeout

getWriteTimeout

public int getWriteTimeout()

返回:

write timeout in seconds. The default value is 0 (disabled).

setWriteTimeout

public void setWriteTimeout(int writeTimeout)

Sets write timeout in seconds. The default value is 0 (disabled).

参数:

writeTimeout - The Write timeout

sessionOpened

public void sessionOpened(IoSession session)

Initializes streams and timeout settings.

指定者:

sessionOpened 在接口中 IoHandler

覆盖:

sessionOpened 在类中 IoHandlerAdapter

参数:

session - The session being opened

sessionClosed

public void sessionClosed(IoSession session)
                   throws java.lang.Exception

Closes streams

指定者:

sessionClosed 在接口中 IoHandler

覆盖:

sessionClosed 在类中 IoHandlerAdapter

参数:

session - The session being closed

抛出:

java.lang.Exception - If we get an exception while processing the close event

messageReceived

public void messageReceived(IoSession session,
                   java.lang.Object buf)

Forwards read data to input stream.

指定者:

messageReceived 在接口中 IoHandler

覆盖:

messageReceived 在类中 IoHandlerAdapter

参数:

session - The session that is receiving a message

buf - The received message

exceptionCaught

public void exceptionCaught(IoSession session,
                   java.lang.Throwable cause)

Forwards caught exceptions to input stream.

指定者:

exceptionCaught 在接口中 IoHandler

覆盖:

exceptionCaught 在类中 IoHandlerAdapter

参数:

session - The session for which we have got an exception

cause - The exception that has been caught

sessionIdle

public void sessionIdle(IoSession session,
               IdleStatus status)

Handles read timeout.

指定者:

sessionIdle 在接口中 IoHandler

覆盖:

sessionIdle 在类中 IoHandlerAdapter

参数:

session - The idling session

status - The session's status