mmsmaster.java

移动彩信网关

package com.mengzhong.mms;

import java.io.*;
import java.util.*;
import com.mengzhong.mms.publics.*;
/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author unascribed
 * @version 1.0
 */

public class MMSMaster {

  public MMSMaster() {
  }
  public MMSMaster(String name) {
  myname = name;
  }

/**
 *
 * mymms系统执行入口
 * 1、系统初始化
 * 2、构造Cmpp连接管理器
 * @param args main
 */
  public static void main(String[] args) {
    MMSMaster mymms = new MMSMaster("mymms");
    if( ! mymms.init() ) {
      //若初始化失败，系统退出
      PublicConstants.writeLog.info("mymms system exit ...Because of init fault",0);
      System.exit(-1) ;
    } else {
      PublicConstants.writeLog.info("mymms init OK! ",0);
    }
      mymms.startSaveDataThread();
      mymms.operationStart();
    System.out.println("\nmymms System started ! ");
  }
  /**
   * 启动写数据库线程
   */
 public  void startSaveDataThread() {
   saveData = new SaveDataBase();
   saveData.start();
  }
  /**
 * 启动业务处理模块
 */
private void operationStart() {
     com.mengzhong.mms.SendFromDB.getInstance().start();

//    com.my.mysp.operation.OperManager.getInstance().startAllBusiModule();

}


/**
 * 系统初始化
 * 1、从文件读出配置参数<br>
 * 2、从数据库读出配置参数<br>
 * @return
 *    true :初始化成功
 *    false:初始化失败
 */
public  boolean init() {


  if(! loadCfgFile() )
    return false;

  return true;
}

private  boolean loadCfgFile() {
  System.out.println("Reading Cfg from file ...");
  try {

    PublicConstants.ConfigFile=System.getProperties().getProperty("CONFIG_FILE");
    System.out.println("cfgFile: \t\t\t"+PublicConstants.ConfigFile);
    InputStream is = new FileInputStream(PublicConstants.ConfigFile) ;
    Properties pt = new Properties() ;
    pt.load(is) ;
    PublicConstants.LogPath = pt.getProperty("public.LogPath", "logs/") ;
    System.out.println("public.logPath: \t\t"+PublicConstants.LogPath);
    PublicConstants.DEBUGLevel =
        Integer.parseInt( pt.getProperty("public.DebugLevel","0") );
    System.out.println("public.DebugLevel: \t\t"+PublicConstants.DEBUGLevel);

    try {
      PublicConstants.writeLog = new WriteLog(PublicConstants.LogPath,PublicConstants.DEBUGLevel);
    } catch (IOException ioe) {
      System.out.println("Build log object: "+ioe);
      System.exit(-1);
    }
    PublicConstants.writeLog.info("\n\nmymms SYSTEM STARTING ...",0);

    PublicConstants.PackDEBUGLevel =
        Integer.parseInt( pt.getProperty("public.PackDebugLevel","0") );

    PublicConstants.DB_DRIVER=pt.getProperty("public.DBDriver").trim();
    System.out.println("PublicConstants.DB_DRIVER:\t" + PublicConstants.DB_DRIVER);
    PublicConstants.CONNECTION_URL =
        pt.getProperty("public.DBConnectString", "ERROR !").trim();
    System.out.println("DBConnectString:\t\t" + PublicConstants.CONNECTION_URL);
    PublicConstants.DB_USER = pt.getProperty("public.DBUser").trim();
    System.out.println("DB_USER: \t\t\t" + PublicConstants.DB_USER);
    PublicConstants.DB_PASS = pt.getProperty("public.DBPasswd").trim();
    System.out.println("DB_PASS: \t\t\t"+PublicConstants.DB_PASS);


    PublicConstants.RECONNECTDB_INTERVAL=Integer.parseInt(pt.getProperty("public.RECONNECTDB_INTERVAL").trim());
    System.out.println("RECONNECTDB_INTERVAL: "+PublicConstants.RECONNECTDB_INTERVAL);

    PublicConstants.SectionNum=pt.getProperty("public.SectionNum").trim();
    System.out.println("PublicConstants.SectionNum: "+PublicConstants.SectionNum);

    PublicConstants.DealerType=Byte.parseByte(pt.getProperty("public.DealerType").trim());
    System.out.println("PublicConstants.DealerType: "+PublicConstants.DealerType);

    PublicConstants.TotalHelpMsg=pt.getProperty("operation.TotalHelpMsg","您发送的信息代码不正确").trim();
          PublicConstants.TotalHelpMsg=new String(PublicConstants.TotalHelpMsg.getBytes("iso-8859-1"),"GB2312");
    System.out.println("PublicConstants.TotalHelpMsg: "+PublicConstants.TotalHelpMsg);

    PublicConstants.TotalHelpServieceType=pt.getProperty("operation.TotalHelpServieceType").trim();
    System.out.println("PublicConstants.TotalHelpServieceType: "+PublicConstants.TotalHelpServieceType);

    is.close() ;
  } catch (Exception e) {
    System.out.println("mymms loadCfgFile: "+e.toString() );
    PublicConstants.writeLog.info("mymms loadCfgFile: "+e,0);
    return false;
  }
  return true;
}


/**
 *
 * 重新读mymms参数（暂未使用)
 * type = 0 ：增一个短信中心参数;
 * type = 1 ：增一个SP参数;
 * type = 2 ：刷新系统参数（Tlp_Sys_config表）参数;
 * @param type 类型
 * @return boolean
 */
public static boolean reReadParam( int type ) {
  PublicConstants.writeLog.info("mymms reRead parameter("+type+") ... ",0);
  return  true;
  }
  private String myname;
  private static SaveDataBase saveData;
}