cmppmosocketprocess.java

对于cmpp3.0 开发有一定的帮助,请大家下载下来进行研究.

package com.zhanghao.cmpp;
/**
 * <p>Title: CMPPMOSocketProcess 双连接方式-MO的Socket连接</p>
 * <p>Description: 湖南移动短信网关通讯程序</p>
 * <p>用于建立与移动短信网关的Socket连接,同时收发登陆包,登陆响应包</p>
 * 该SOCKET连接在单连接时候,用来收发数据(Submit,SubmitResp,Deliver,DeliverResp等)
 * 在双连接时候,仅用来做收数据(Deliver,DeliverResp等)
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: sunun tech ltd.</p>
 * @author zhanghao
 * @version 1.0
 */

import java.io.*;
import java.net.*;
import java.util.Vector;

import com.zhanghao.common.util.*;

public class CMPPMOSocketProcess {

  public Socket socket ;

  public DataInputStream  inputStream;

  public DataOutputStream outputStream;

  public boolean isAvail  = false;

  /** CMPPMOSocketProcess 的单例 **/
  private static CMPPMOSocketProcess moSocketProcess = null;

  /** 上行数据缓冲,当CMPPMOReceiveThread接受到上行数据后,将数据保存在该缓冲中,由
   *  CMPPMODataSaveThread线程将数据再保存到数据库中 **/
  public Vector vctMOData = new Vector(1,1);

  public CMPPMOSocketProcess() {
  }


  /**取得CMPPMOSocketProcess的唯一实例 **/
  public static CMPPMOSocketProcess getInstance(){
    if(moSocketProcess == null){
      moSocketProcess = new CMPPMOSocketProcess();
    }
    return moSocketProcess;
  }


  /**
   * 与短信网关建立连接
   * @throws java.lang.Exception
   */
  public void connectSMSG() throws Exception{
    try{
      Debug.outInfo("[CMPPMaster]"+PublicFunction.getFormatTime()+" "+CMPParameter.ServerIp +":"+ CMPParameter.MOServerPort);
      socket = new Socket(CMPParameter.ServerIp,CMPParameter.MOServerPort);
      inputStream  = new DataInputStream(socket.getInputStream());
      outputStream = new DataOutputStream(socket.getOutputStream());

      loginSMSG();
    }
    catch(Exception ex){
      disclose();
      throw ex;
    }
  }

  /**
   * 发送登陆包,接收响应包,登陆
   * @throws java.lang.Exception
   */
  public void loginSMSG() throws Exception{
    try{
      CMPP loginMsg = new CMPP(CMPP.CMPP_CONNECT);
      PublicFunction.send(outputStream,loginMsg.pack());
      byte[] loginRespByte = PublicFunction.recv(inputStream);
      CMPP loginRespMsg = new CMPP();
      loginRespMsg.parsePack(loginRespByte);

      if(loginRespMsg.Status == 0 ){
        Debug.outInfo("[CMPPMaster]"+PublicFunction.getFormatTime()+" MO线程连接ISMG成功");
        this.isAvail = true;
      }
      else{
        this.socket.close();
        this.socket = null;
        Debug.outInfo("[CMPPMaster]"+PublicFunction.getFormatTime()+" MO线程连接ISMG失败,失败状态:"+loginRespMsg.Status);
      }
    }
    catch(Exception ex){
      throw ex;
    }

  }

  /** 断开连接 **/
  public void disclose(){
    try{
      if(this.inputStream !=null){
        this.inputStream.close();
        this.inputStream = null;
      }
      if(this.outputStream !=null){
        this.outputStream.close();
        this.outputStream = null;
      }
      if(this.socket !=null){
        this.socket.close();
        this.socket = null;
      }
    }
    catch(Exception ex){
      Debug.outError(ex);
    }
    this.isAvail = false;
  }
}