sendmsg.java

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

package com.yidatone.sms.mina.mccenter;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileReader;
import java.io.IOException;

import org.apache.log4j.Logger;
import org.apache.mina.common.IoSession;
public class SendMsg
{	
	Logger logger=Logger.getLogger(getClass());
	public void sendmessage(File msgFile,IoSession session)
	{
		try
		{
			String[] msgArray=this.ReadFile(msgFile);
	    	
			StringBuffer send=new StringBuffer();
			send.append("put ");
			send.append(msgArray[0]).append(" ");
			send.append(msgArray[1]).append(" "); 
			send.append(msgArray[2]).append(" "); 
			send.append(msgArray[3]).append(" \""); 
			send.append(msgArray[4]).append("\" \""); 
			send.append(msgArray[5]).append("\" \""); 
			send.append(msgArray[6]).append("\" \""); 
			send.append(msgArray[7]).append("\" "); 
			send.append(msgArray[8]).append(" "); 
			send.append(msgArray[9]).append(" \"");  
			send.append(msgArray[10]).append("\" \"");  
			send.append(msgArray[11]).append("\" \"");  
			send.append(msgArray[12]).append("\" "); 
			send.append(msgArray[13]).append( " "); 
			send.append(msgArray[14]).append(" "); 
			send.append(msgArray[15]).append(" "); 
			send.append(msgArray[16]).append(" \""); 
			send.append(msgArray[17]).append("\" "); 
			send.append(msgArray[18]).append(" \"");  
			send.append(msgArray[19]).append("\" "); 
			send.append(msgArray[20]).append(" \""); 
			send.append(msgArray[21]).append("\" "); 
			send.append(msgArray[22]).append("\n"); 
			send.append(msgArray[23]).append("\n");
		
			if (session.isConnected())  //验证SOCKET是否有效
			{
				logger.info("Sendmessage->"+send.toString());
				session.write(send.toString());
			}
			else
			{
				logger.error("[SendMsgThread->run error]");
			}
		}
		catch(Exception ex)
		{
			return;
		}
	}
	public String[] ReadFile(File msgFile) throws FileNotFoundException,IOException 
    {
    	String[] result = new String[24];
    	String temp = "";
    	FileReader fileReader = new FileReader(msgFile);
    	BufferedReader in = new BufferedReader(fileReader);
    	int index = 0;
    	while (true) 
    	{
    		if ( (temp = in.readLine()) != null) 
    		{
    			result[index] = temp;
    		}
    		else 
    		{
    			temp = "";
    			break;
    		}
    		index++;
    	}
    	fileReader.close();
    	in.close();
    	msgFile.delete();
    	return result;
    }
}