serversessionhandler.java

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

package com.yidatone.sms.mina.mccenter.test;

import org.apache.log4j.Logger;
import org.apache.mina.common.IdleStatus;
import org.apache.mina.common.IoHandler;
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 ServerSessionHandler implements IoHandler    //<------------------Server端----------------------->
{
    private Logger log = Logger.getLogger(getClass());
    private int idleTime = 10;
    public ServerSessionHandler(){}

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

    public void sessionOpened( IoSession session ) 
    {
    	session.setIdleTime(IdleStatus.BOTH_IDLE, idleTime);
    }

    public void sessionClosed( IoSession session ) {}

    public void messageReceived( IoSession session, Object message )
    {
    	if(String.valueOf(message).substring(0,3).equalsIgnoreCase("get"))
    	{
        	log.debug("[客户端需求]:"+String.valueOf(message));
        	String Msgs="0 0 0 0 \"\" \"\" \"-HYCHZX\" \"\" 0 0 \"02345\" \"\" \"\" 1155525125 0 299 -1218873793 \"13897946069\" 0 \"02345\" 0 \"\"";
        	Msgs=Msgs+"\n"+"\"CH\"";
        	session.write(Msgs);
    	}
    	else
    	{
    		log.debug("[客户端MO消息体]:"+String.valueOf(message));
    		session.write("0");
    	}
    }

    public void messageSent( IoSession session, Object message ) {}

    public void sessionIdle( IoSession session, IdleStatus status ) 
    {
    	session.write("0");
    	//log.debug("发送防超时消息@" + session.getRemoteAddress());
    }

    public void exceptionCaught( IoSession session, Throwable cause )
    {
    	log.error("session Exception is caught .",cause);
        session.close();
    }
}