cmppparam.java

java支持的短信平台

package com.khan.sms.cmpp2control;

import com.khan.file.LoadResourceIni;
import java.io.*;
import com.khan.db.DBConPool;
import com.khan.file.Log;


/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public final class CmppParam {
  private static CmppParam _instance; //本类实例

  public  String SMSC_ADDRESS        = "";
  public  int    SMSC_PORT           = 7890;
  public  int    SMSC_VERSION        = 32;

  public  String ENTERPRISE_CODE     = "";
  public  String USER                = "";
  public  String PASSWORD            = "";

  public  int    TRANSCEIVER_MODE    = 0;
  public  int    MAX_TRANSMIT        = 0;
  public  int    MAX_RECVQUEUE_SIZE  = 0;
  public  int    ACTIVE_INTERVAL     = 0;

  public  int    TRANSCEIVER_THREADS = 0;
  public  int    MAX_ACK_TIMEOUT     = 0;
  public  int    WAIT_REPORT_TIMEOUT = 0;
  public  int    SEND_SLEEP          = 0;
  public  int    SOCKET_TIMEOUT      = 0;

  public  int    RESEND_IDLE         = 0;
  public  int    ORIGINATOR          = 0;
  public  int    RECONNECT_IDLE_TIME = 0;

  public  String AREA_CODE           = "86";

  public  String DB_HOST             = "";
  public  String DB_PORT             = "";
  public  String DB_NAME             = "";
  public  String DB_USER             = "";
  public  String DB_PASSWORD         = "";


  private String LogFile;                   //系统日志文件
  private String ErrFile;                   //系统出错文件
  public Cmpp2SocketConPool Cmpp_Socket   = null;
  public DBConPool Cmpp_DB               = null;

  //public String MO_SQL;
  public String MT_SQL;

  public Log LogMain ;
  public Log ErrMain ;

  private CmppParam() {
    LoadResourceIni lri = new LoadResourceIni("62626019.properties");
    try {
      SMSC_ADDRESS        = lri.readINI("smsc_address");
      SMSC_PORT           = Integer.parseInt( lri.readINI("smsc_port") );
      SMSC_VERSION        = Integer.parseInt( lri.readINI("smsc_version") );

      ENTERPRISE_CODE     = lri.readINI("enterprise_code");
      USER                = lri.readINI("user_name");
      PASSWORD            = lri.readINI("password");

      TRANSCEIVER_MODE    = Integer.parseInt( lri.readINI("transceiver_mode") );
      MAX_TRANSMIT        = Integer.parseInt( lri.readINI("max_transmit") );
      MAX_RECVQUEUE_SIZE  = Integer.parseInt( lri.readINI("max_recvQueue_size") );

      ACTIVE_INTERVAL     = Integer.parseInt( lri.readINI("active_interval") );

      TRANSCEIVER_THREADS = Integer.parseInt( lri.readINI("transceiver_threads") );
      MAX_ACK_TIMEOUT     = Integer.parseInt( lri.readINI("max_ack_timeout") );
      WAIT_REPORT_TIMEOUT = Integer.parseInt( lri.readINI("wait_report_timeout") );
      SEND_SLEEP          = Integer.parseInt( lri.readINI("send_sleep") );
      SOCKET_TIMEOUT      = Integer.parseInt( lri.readINI("socket_timeout") );

      RESEND_IDLE         = Integer.parseInt( lri.readINI("resend_idle") );
      ORIGINATOR          = Integer.parseInt( lri.readINI("originator") );
      RECONNECT_IDLE_TIME = Integer.parseInt( lri.readINI("reconnect_idle_time") );

      AREA_CODE           = lri.readINI("area_code");

      DB_HOST             = lri.readINI("db_host");
      DB_PORT             = lri.readINI("db_port");
      DB_NAME             = lri.readINI("db_name");
      DB_USER             = lri.readINI("db_user");
      DB_PASSWORD         = lri.readINI("db_password");

      LogFile             = lri.readINI("log_out");
      ErrFile             = lri.readINI("log_err");
      LogMain             = new Log(LogFile);
      ErrMain             = new Log(ErrFile);
      //MO_SQL              = lri.readINI("mo_sql");
      MT_SQL              = lri.readINI("mt_sql");

      Cmpp_DB             = new DBConPool(DBConPool.MYSQL_DRIVER,
                                          "jdbc:mysql://"+DB_HOST+":"+DB_PORT+"/"+DB_NAME+"?useUnicode=true&characterEncoding=GBK",
                                          DB_USER,
                                          DB_PASSWORD,
                                          5,
                                          60);

      Cmpp_Socket         = new Cmpp2SocketConPool(SMSC_ADDRESS,
                                              SMSC_PORT,
                                              SOCKET_TIMEOUT,
                                              TRANSCEIVER_THREADS,
                                              USER,PASSWORD,
                                              (byte)SMSC_VERSION,
                                              ORIGINATOR);
    } catch (IOException e) {
        e.printStackTrace();
    } catch (Exception e) {
        e.printStackTrace();
    }
  }



    /**
     * 取得本类的唯一实例
     * @return CmppParam
     */
  public static synchronized CmppParam getInstance() {
    if (_instance == null) {
      _instance = new CmppParam();
    }
    return _instance;
  }

}