clientmtsessionhandler.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 ClientMtSessionHandler extends IoHandlerAdapter   //<------------------Client_mo端----------------------->
{
	Logger logger=Logger.getLogger(getClass());
	protected SendMsgThread sendMsg=null;
	private int idleTime = 10;
	public ClientMtSessionHandler() {}
	
	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);
    	sendMsg=new SendMsgThread(session);
    	sendMsg.start();
    }

    public void messageReceived(IoSession session, Object message)
    {
    	String receivemsg=String.valueOf(message);
    	if(receivemsg.equalsIgnoreCase("0"))
    	{
    		logger.info("message send success....................");
    	}
    }

    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("ClientMtSessionHandler socket connect@" + session.getRemoteAddress());
    }
    
    public void sessionClosed(IoSession session) throws Exception {}
}