client.java

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

package com.yidatone.sms.mina.mccenter;

import java.io.File;
import java.net.InetSocketAddress;
import java.util.ArrayList;
import java.util.List;
import org.apache.mina.common.ConnectFuture;
import org.apache.mina.common.IoConnector;
import org.apache.mina.transport.socket.nio.SocketConnector;



public class Client // <------------------Client端----------------------->
{
	//private static final int Port = 33333;
	private static final String HostName = "127.0.0.1";
	private static final int Port = 8006;
	
	public static List moDirs = new ArrayList();
	public static List mtDirs = new ArrayList();
	
//	private static File mopathfile=new File("/root/TEMPCenter/mccenter_mina_test/mo");
//	private static File mtpathfile=new File("/root/ICPCenter/admt/queue/admt");
	private static File mopathfile=new File("D:/workspace/minaStudy/queue/mo");
	private static File mtpathfile=new File("D:/workspace/minaStudy/queue/mt");
	
	private static File[] modirspath=mopathfile.listFiles();
	private static File[] mtdirspath=mtpathfile.listFiles();

	public static void main(String[] args) throws Throwable 
	{
		init();
		
		IoConnector connector = new SocketConnector();
		InetSocketAddress ServerPort = new InetSocketAddress(HostName, Port);
		
		ClientMoSessionHandler clientmosessionhandler = new ClientMoSessionHandler();
		ConnectFuture futuremo = connector.connect(ServerPort,clientmosessionhandler);
		
		ClientMtSessionHandler clientmtsessionhandler = new ClientMtSessionHandler();
		ConnectFuture futuremt = connector.connect(ServerPort,clientmtsessionhandler);
		
		futuremo.join();
		futuremt.join();
	}
	
	public static void init()
	{
		try
		{
			for(int i=0; i<modirspath.length; i++)
			{
				moDirs.add(modirspath[i]);
			}
			
			for(int j=0; j<mtdirspath.length; j++)
			{
				mtDirs.add(mtdirspath[j]);
			}
		}
		catch(Exception ex){}
	}
}