configgateway.java

彩信接入系统

/*
 * Created on 2005-2-7
 *
 * TODO To change the template for this generated file go to
 * Window - Preferences - Java - Code Style - Code Templates
 */
package com.rainbow.mms.gateway;

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Properties;

import org.apache.log4j.Logger;


/**
 * 读取网关的配置，从Properties文件读出
 * @author Rainbow MMS Group Leader —— TrWorks
 * 
 */
class ConfigGateWay {

	private String gwLinkUrl = null;

	private String gwLinkUser = null;

	private String gwLinkPasswd = null;

	private String gwSpID = null;

	private String gwSpServiceID = null;

	private int gateWayID = 10;

	private int gwThreadNum = 0;

	private int dbGetTimeInterval = 5000;

	private String gwContainClassName = null;
	
	private String gwSenderThreadClassName = null;
	
	private int gwWantReport = 0;
	
	private int gwOnceGetSubmitNum = 0;
	
	private int gwOnceGetFailedNum = 0;
	
	private Logger log = Logger.getLogger(ConfigGateWay.class);

	/**
	 * 加载配置文件，将发送型网关的配置读出
	 * 
	 * @param fileName
	 *            配置文件名称
	 * @return boolean 是否配置成功
	 */
	public boolean loadConfig(String fileName) {
		Properties pro = new Properties();
		InputStream in = null;

		try {
			in = new FileInputStream(fileName);
			//in =
			// this.getClass().getClassLoader().getResourceAsStream(fileName);
			pro.load(in);
			log.info("加载配置文件[" + fileName + "]");
		} catch (Exception e) {
			log.error("加载配置文件[" + fileName + "]失败", e);
			return false;
		} finally {
			if (in != null) {
				try {
					in.close();
				} catch (IOException e1) {
					return false;
				}
			}
		}

		// 读取 DB_URL
		String tmpString;

		// 读取 GW_URL
		tmpString = pro.getProperty("GW_URL");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 GW_URL 配置错误!");
			return false;
		}
		gwLinkUrl = tmpString;

		// 读取 GW_USER
		tmpString = pro.getProperty("GW_USER");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 GW_USER 配置错误!");
			return false;
		}
		gwLinkUser = tmpString;

		// 读取 GW_PASSWD
		tmpString = pro.getProperty("GW_PASSWD");
		gwLinkPasswd = tmpString;

		// 读取 GW_SPID
		tmpString = pro.getProperty("GW_SPID");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 GW_SPID 配置错误!");
			return false;
		}
		gwSpID = tmpString;

		// 读取 GW_SPSERVICEID
		tmpString = pro.getProperty("GW_SPSERVICEID");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 GW_SPSERVICEID 配置错误!");
			return false;
		}
		gwSpServiceID = tmpString;

		// 读取 GW_GATEWAYID
		tmpString = pro.getProperty("GW_GATEWAYID");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 GW_GATEWAYID 配置错误!");
			return false;
		}

		gateWayID = Integer.parseInt(tmpString);

		// 读取 THREAD_NUM
		tmpString = pro.getProperty("THREAD_NUM");
		if (tmpString.length() <= 0) {
			log.error("配置文件中 THREAD_NUM 配置错误!");
			return false;
		}

		gwThreadNum = Integer.parseInt(tmpString);

		// 读取 GETSUBMIT_TIME_INTERVAL
		tmpString = pro.getProperty("GETSUBMIT_TIME_INTERVAL");
		if (tmpString.length() <= 3) {
			log.error("配置文件中 GETSUBMIT_TIME_INTERVAL 配置错误!");
			return false;
		}

		dbGetTimeInterval = Integer.parseInt(tmpString);
		if (dbGetTimeInterval <= 1000) {
			log.error("配置文件中 GETSUBMIT_TIME_INTERVAL 配置错误!");
			return false;
		}

		// 读取 CONTAINER_CLASS_NAME
		tmpString = pro.getProperty("CONTAINER_CLASS_NAME");
		if (tmpString.length() <= 0){
			log.error("配置文件中 CONTAINER_CLASS_NAME 配置错误!");
			return false;
		}
		gwContainClassName = tmpString;
		
		// 读取 gwSenderThreadClassName
		tmpString = pro.getProperty("SENDERTHREAD_CLASS_NAME");
		if (tmpString.length() <= 0){
			log.error("配置文件中 SENDERTHREAD_CLASS_NAME 配置错误!");
			return false;
		}
		gwSenderThreadClassName = tmpString;
		
		tmpString = pro.getProperty("WANT_REPORT");
		if (tmpString.length() <= 0){
			log.error("配置文件中 WANT_REPORT 配置错误!");
			return false;
		}
		gwWantReport = Integer.parseInt(tmpString);
		
/*		tmpString = pro.getProperty("ONCE_GETSUBMIT_NUM");
		if (tmpString.length() <= 0){
			log.error("WANT_REPORT 配置错误!");
			return false;
		}
		gwOnceGetSubmitNum = Integer.parseInt(tmpString);
		
		tmpString = pro.getProperty("ONCE_GETFAILED_NUM");
		if (tmpString.length() <= 0){
			log.error("WANT_REPORT 配置错误!");
			return false;
		}
		gwOnceGetFailedNum = Integer.parseInt(tmpString);*/
		
		log.info("读取配置文件成功");

		return true;
	}

	
	/**
	 * @return Returns the dbGetTimeInterval.
	 */
	public final int getDbGetTimeInterval() {
		return dbGetTimeInterval;
	}
	/**
	 * @return Returns the gateWayID.
	 */
	public final int getGateWayID() {
		return gateWayID;
	}
	/**
	 * @return Returns the gwLinkPasswd.
	 */
	public final String getGwLinkPasswd() {
		return gwLinkPasswd;
	}
	/**
	 * @return Returns the gwLinkUrl.
	 */
	public final String getGwLinkUrl() {
		return gwLinkUrl;
	}
	/**
	 * @return Returns the gwLinkUser.
	 */
	public final String getGwLinkUser() {
		return gwLinkUser;
	}
	/**
	 * @return Returns the gwSpID.
	 */
	public final String getGwSpID() {
		return gwSpID;
	}
	/**
	 * @return Returns the gwSpServiceID.
	 */
	public final String getGwSpServiceID() {
		return gwSpServiceID;
	}
	/**
	 * @return Returns the gwThreadNum.
	 */
	public final int getGwThreadNum() {
		return gwThreadNum;
	}
	public static void main(String[] args) {
	}
	/**
	 * @return Returns the gwContainClassName.
	 */
	public final String getGwContainClassName() {
		return gwContainClassName;
	}
	/**
	 * @return Returns the gwSenderThreadClassName.
	 */
	public final String getGwSenderThreadClassName() {
		return gwSenderThreadClassName;
	}
	
	public final int getGwWantReport() {
		return gwWantReport;
	}
	
	public int getGwOnceGetFailedNum() {
		return gwOnceGetFailedNum;
	}
	public int getGwOnceGetSubmitNum() {
		return gwOnceGetSubmitNum;
	}
}