clientmosessionhandler.java

apache.mina网络开源框架的例子

package com.yidatone.sms.mina.mccenter;

import org.apache.log4j.Logger;
import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoHandlerAdapter;
import org.apache.mina.common.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolCodecFilter;

import com.yidatone.sms.mina.mccenter.codec.MsgProtocolCodecFactory;

public class ClientMoSessionHandler extends IoHandlerAdapter  //<------------------Client_mo端----------------------->
{
	Logger logger=Logger.getLogger(getClass());
	protected FetchMsgThread fetchMsg=null;
	protected ReceiveMsg recevieMsg=new ReceiveMsg();
	private int idleTime = 10;
    public ClientMoSessionHandler(){}

    public void sessionCreated( IoSession session ) throws Exception
    {
        ProtocolCodecFactory codec= new MsgProtocolCodecFactory();
        session.getFilterChain().addLast("protocolFilter", new ProtocolCodecFilter( codec ) );
    }

    public void sessionOpened( IoSession session ) throws Exception
    {
    	session.setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
    	fetchMsg=new FetchMsgThread(session);
    	fetchMsg.start();
    }

    public void messageReceived( IoSession session, Object message )
    {
    	logger.info("messageReceived::"+String.valueOf(message));
    	recevieMsg.GetFileContent(message);
    }

    public void messageSent( IoSession session, Object message ) throws Exception {}
    
    public void exceptionCaught( IoSession session, Throwable cause )
    {
       logger.error("catch Caught！",cause);
    	session.close();
    }

    public void sessionIdle( IoSession session, IdleStatus status )
    {
    	session.write("get 0 0 \n");
    	logger.info("ClientMoSessionHandler socket connect@" + session.getRemoteAddress());
    }
    
    public void sessionClosed( IoSession session ) throws Exception {}
}