startswitch.java

短信开发用于文件交换处理转发的类模块

package com.sms.platform.switchcenter;

import java.util.Iterator;
import java.util.List;

import org.jdom.Element;

import com.pub.servlet.HttpServer;
import com.pub.util.ReaderXml;
import com.sms.platform.switchcenter.parameter.ReceiverParameter;
import com.sms.platform.switchcenter.parameter.SenderParameter;
import com.sms.platform.switchcenter.parameter.SwitchParameter;
import com.sms.platform.switchcenter.thread.DealThread;

public class StartSwitch {

//	static {
//		PatternLayout layout = null;
//		ConsoleAppender consoleAppender = null;
//		layout = new PatternLayout("%d %5p [%t] (%F:%L) - %m%n");
//		consoleAppender = new ConsoleAppender(layout, "System.out");
//		org.apache.log4j.BasicConfigurator.configure(consoleAppender);
//	}

	public StartSwitch() {
		
	    System.out.println(System.getProperty("SwitchParameter"));
	    System.out.println(System.getProperty("ReceiverParameter"));
	    System.out.println(System.getProperty("SenderParameter"));
	    System.out.println(System.getProperty("Log4jParameter"));
		
	    org.apache.log4j.xml.DOMConfigurator.configure("./conf/Log4jConfig.xml");
	    
		SwitchParameter.getInstance("./conf/SwitchParameter.xml");

		ReceiverParameter.getInstance("./conf/DeliverReceiverParameter.xml");

		SenderParameter.getInstance("./conf/DeliverSenderParameter.xml");

		DealThread dh = new DealThread();
		dh.startthread();

		try {
			HttpServer httpserver = null;
			List list = ReaderXml.loadListElement("./conf/WebServerConfig.xml",
					"//webserver");
			Iterator iter = list.iterator();
			while (iter.hasNext()) {
				Element item = (Element) iter.next();
				httpserver = new HttpServer(ReaderXml.getAttributeInteger(item,
						"webPort", 60606), ReaderXml.getAttributeInteger(item,
						"webSendSize", 1024), ReaderXml.getAttributeInteger(
						item, "webReceiverSize", 1024), ReaderXml
						.getAttributeInteger(item, "webPoolMin", 1), ReaderXml
						.getAttributeInteger(item, "webPoolMax", 10), ReaderXml
						.getAttributeInteger(item, "webReleaseDelay", 60));
				Thread thread = new Thread(httpserver);
				thread.start();
			}
		} catch (Exception ex) {
			ex.printStackTrace();
			System.exit(1);
			return;
		}
		
	}

	public static void main(String[] args) {
		new StartSwitch();
	}
}