fetchmsgthread.java

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

package com.yidatone.sms.mina.mccenter;

import org.apache.log4j.Logger;
import org.apache.mina.common.IoSession;
public class FetchMsgThread extends Thread
{
	Logger logger=Logger.getLogger(getClass());
	private IoSession session;
	public FetchMsgThread(IoSession session)
	{
		this.session = session;
	}

	public void run()
	{
		while(true)
		{
			if(session.isConnected())
			{
				String Msg="get 0 0 \n";
				session.write(Msg);
				try
				{
					sleep(1000);
				}
				catch(Exception ex)
				{
					ex.printStackTrace();
				}
			}
			else
			{
				logger.error("连接失效！");
				break;
			}
		}
	}
}