sendmsgthread.java

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

package com.yidatone.sms.mina.mccenter;

import java.io.File;

import org.apache.log4j.Logger;
import org.apache.mina.common.IoSession;

public class SendMsgThread extends Thread
{
	Logger logger=Logger.getLogger(getClass());
	private IoSession session;
	SendMsg sm=new SendMsg();
	public SendMsgThread(IoSession session)
	{
		this.session=session;
	}
	public void run() 
    {
    	try 
    	{
    		while (true) 
    		{
    			sleep(50);
    			for (int i = 0; i < Client.mtDirs.size(); i++) 
    			{
    				File mtDir = (File) Client.mtDirs.get(i);
    				File[] msgFiles = mtDir.listFiles();
    				if (msgFiles.length > 0) 
    				{
    					for (int j = 0; j < msgFiles.length; j++) 
    					{
    						if ( (msgFiles[j].length() == 0) && (System.currentTimeMillis() - msgFiles[j].lastModified() > 3000))  //空文件的消息删除
    						{
    							msgFiles[j].delete();
    							continue;
    						}
    						else 
    						{
    							if(msgFiles[j].canRead())
    							{
    								sm.sendmessage(msgFiles[j],session);	
    							}
    						}
    					}
    				}
    			}
    		}
    	}
    	catch (Exception e) 
    	{
    		logger.info("read file error"+e.getMessage(),e);
    	}
    }
}