cngpapi.java

采用JAVA开发

package com.gctech.cngpbj;

import java.util.Properties;
import java.io.FileInputStream;
import java.io.*;
import org.apache.log4j.Logger;
import com.gctech.cngpbj.msg.CNGPSubmitMessage;
import com.gctech.cngpbj.util.SequenceManager;
import com.gctech.cngpbj.msg.CNGPSubmitMessageResp;
import com.gctech.cngpbj.msg.CNGPDeliverMessage;


/**
 * <p>Title: CNGP API</p>
 * <p>Description: 固网短信SP API</p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: GCTECH</p>
 * @author 王红宝
 * @version $Id: CngpApi.java,v 1.3 2004/08/25 07:44:33 lijz Exp $
 */

public class CngpApi {
  public String getServiceNo(){
    return spSrcId;
  }
  public int getGateway()
  {
    return gateWay;
  }

  private String spSrcId;
  private int gateWay;
  CngpCommunicator commu;
  private static CngpApi singleton;
  public static CngpApi getInstance(){
    if ( singleton == null )
      singleton = new CngpApi();
    return singleton;
  }
  CngpApi() {
    //PropertyConfigurator.configureAndWatch("./conf/log4j.properties");
  }

  /**
   * 不等待回复的发送消息。
   * */
  public int cngpSendMsgNoRes(CNGPSubmitMessage msg) throws IOException {
    logger.debug(msg);
    //产生序列号
    msg.nSequenceID = SequenceManager.nextSeq();
    //设置真正的srcId
    if ( msg .sSrcId == null )
      msg.sSrcId = this.spSrcId;
      //test.lijz
//    else
//      msg.sSrcId = this.spSrcId + msg.sSrcId;
    return commu.submit(msg);
  }

  /**
   * 初试化连接。
   * 使用缺省文件名 "./conf/cngp.ini"
   * */
  public int initCngpApi(){
    return initCngpApi("./conf/cngp.ini");
  }
  /**
   * 初试化连接。
   * @param fileName 配置文件名。
   * */
  public int initCngpApi(String fileName){
    //读取配置参数
    Properties props = new Properties();
    try {
      props.load(new FileInputStream(fileName));
      String host = props.getProperty("com.gctech.cngp.ip");
      int port = Integer.parseInt(props.getProperty("com.gctech.cngp.port"));
      String clientId = props.getProperty("com.gctech.cngp.clientId");
      String auth = props.getProperty("com.gctech.cngp.sharedSecret");
      byte loginMode = Byte.parseByte(props.getProperty("com.gctech.cngp.loginMode"));
      byte version = 0x10;
      spSrcId = props.getProperty("com.gctech.cngp.spSrcId");
      //得到网关号,如果没有,则认为是中国网通一级网关(2);//update by lijz;
      gateWay = Integer.parseInt(props.getProperty("com.gctech.cngp.gateway","2"));

      //初试化通信对象
      commu = (CngpCommunicator)(Class.forName(props.getProperty("com.gctech.cngp.communicatorClass")).newInstance());
      //连接网关
      int rt = commu.login(host, port, clientId, auth, loginMode, version);
      //如果登录不成功,退出登录
      if ( rt != 0 ){
        commu.quit();
      }else{
        //启动消息接收线程
        ReceiveDataHandler receiver = (ReceiveDataHandler)(Class.forName(props.getProperty("com.gctech.cngp.receiverClass")).newInstance());
        receiver.setCommunicator(commu);
        Thread t = new Thread(receiver, "CNGP_RECEIVER");
        logger.debug("starting CNGP_RECEIVER!");
        t.start();
        //启动检测线程
        /*Thread active = new Thread(new ActiveTestController(commu), "ACTIVE_TESTER");
        logger.debug("starting ACTIVE_TESTER!");
        active.start();*/
      }
      return rt;
    }
    catch (Throwable ex) {
      logger.fatal(ex, ex);
      return -300;
    }
  }

  static final Logger logger = Logger.getLogger(CngpApi.class);
}