cmpp.java

中国移动CMPP3.0短消息通信程序

  }


  /**取得CMPP CMPP_ACTIVE_TEST的消息包
   * 7.4.7	链路检测（CMPP_ACTIVE_TEST）操作
   **/
  private byte[] makeActiveMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度
      this.Total_Length = 12;

      //打包MT消息报头
      packHead(dataOutStream);

      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP] makeActiveMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }


  /**取得CMPP CMPP_ACTIVE_TEST_RESP的消息包
   * 7.4.7.1 CMPP_ACTIVE_TEST_RESP定义（SP -> ISMG或ISMG->SP）
   **/
  private byte[] makeActiveRespMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度
      this.Total_Length = 12 + 1;

      //打包MT消息报头
      packHead(dataOutStream);

      //打包消息体
      dataOutStream.writeByte(ActiveReserved);

      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP] makeActiveRespMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }


  /**取得CMPP CMPP_CONNECT的消息包
   * 7.4.1.1 CMPP_CONNECT消息定义（SP->ISMG）
   **/
  private byte[] makeConnectMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度
      this.Total_Length = 12 + 27;

      this.Source_Addr  = CMPParameter.SP_Id;
      String strTimestamp      = PublicFunction.getTimeStamp();
      this.Timestamp           = Integer.parseInt(strTimestamp);
      this.AuthenticatorSource = Source_Addr +"\0\0\0\0\0\0\0\0\0"+CMPParameter.SP_Pwd+strTimestamp;
      MD5 md5 = new MD5();
      this.AuthenticatorSource = md5.encrypt(this.AuthenticatorSource);

      //打包MT消息报头
      packHead(dataOutStream);

      //打包消息体
      writeString(dataOutStream,Source_Addr,6);  //写入源地址
      writeString(dataOutStream,AuthenticatorSource,16); //写入用于鉴别源地址的数据
      dataOutStream.writeByte(Version);  //写入双方协商的版本号
      dataOutStream.writeInt(Timestamp); //写入时间戳的明文

      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP] makeConnectMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }


  /**取得CMPP CMPP_CONNECT_RESP的消息包
   * 7.4.1.2 CMPP_CONNECT_RESP消息定义（ISMG -> SP）
   **/
  private byte[] makeConnectRespMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度
      this.Total_Length = 12 + 27;

      //打包MT消息报头
      packHead(dataOutStream);

      //打包消息体
      dataOutStream.writeByte(Status);  //写入连接状态
      writeString(dataOutStream,AuthenticatorISMG,16); //写入用于鉴别源地址的数据
      dataOutStream.writeByte(Version);  //写入双方协商的版本号

      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP] makeConnectRespMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }


  /**取得CMPP CMPP_CONNECT_RESP的消息包
   * 7.4.1.2 CMPP_CONNECT_RESP消息定义（ISMG -> SP）
   **/
  private byte[] makeDeliverRespMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度

      if(Version == 48) this.Total_Length = 12 + 12;
      if(Version == 32) this.Total_Length = 12 + 9;

      //打包MT消息报头
      packHead(dataOutStream);

      //打包消息体
      dataOutStream.writeLong(this.Msg_Id); //写入信息标识
      if(Version == 48) dataOutStream.writeInt(this.Result); //写入结果
      if(Version == 32) dataOutStream.writeByte(this.Result); //写入结果


      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP]makeDeliverRespMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }




  /** 打包CMPP_SUBMIT 消息
   * 8.4.3.1	CMPP_SUBMIT消息定义（SP->ISMG）
   **/
  private byte[] makeSubmitMsgPack(){
    ByteArrayOutputStream byteArrayOutStream = new ByteArrayOutputStream();
    DataOutputStream dataOutStream = new DataOutputStream(byteArrayOutStream);

    try{
      //MT消息长度

      String str = Msg_Content;
      int i = 0;
      if(this.Msg_Fmt == 15){
        i = new String(str.getBytes("gb2312"),-4).getBytes().length;
        while(i>126){
          str = str.substring(0,str.length() -1);
          i = new String(str.getBytes("gb2312"),-4).getBytes().length;
        }
        Msg_Content = new String(str.getBytes("gb2312"), -4);
      }
      else
      if(this.Msg_Fmt == 24){
        i = new String(str.getBytes("UnicodeBigUnmarked"),-4).getBytes().length;
        while(i>126){
          str = str.substring(0,str.length() -1);
          i = new String(str.getBytes("UnicodeBigUnmarked"),-4).getBytes().length;
        }
        Msg_Content = new String(str.getBytes("UnicodeBigUnmarked"), -4);
      }

      int iLength = Msg_Content.getBytes().length ;                //Msg_Content.getBytes().length;
      if(Version == 48) this.Total_Length = 12 + 183  + iLength;
      if(Version == 32) this.Total_Length = 12 + 147  + iLength;
      this.Sequence_Id = (int)Msg_Id;

      //打包MT消息报头
      packHead(dataOutStream);

      //打包消息体
      Debug.outDebug("Msg_Id = " + Msg_Id + ",this.Total_Length ="+this.Total_Length);
      dataOutStream.writeLong(Msg_Id);
      dataOutStream.writeByte(Pk_total);
      dataOutStream.writeByte(Pk_number);
      dataOutStream.writeByte(Registered_Delivery);
      dataOutStream.writeByte(Msg_level);

      writeString(dataOutStream,Service_Id,10);

      dataOutStream.writeByte(Fee_UserType);

      if(Version == 48) {
        writeString(dataOutStream, Fee_terminal_Id, 32);
        dataOutStream.writeByte(Fee_terminal_type);
      }
      else
      if(Version == 32) writeString(dataOutStream,Fee_terminal_Id,21);

      dataOutStream.writeByte(TP_pid);
      dataOutStream.writeByte(TP_udhi);
      dataOutStream.writeByte(Msg_Fmt);

      writeString(dataOutStream,Msg_src,6);
      writeString(dataOutStream,FeeType,2);
      writeString(dataOutStream,FeeCode,6);
      writeString(dataOutStream,ValId_Time,17);
      writeString(dataOutStream,At_Time,17);
      writeString(dataOutStream,Src_terminal_Id,21);

      dataOutStream.writeByte(DestUsr_tl);
      if(Version == 48) {
        writeString(dataOutStream, Dest_terminal_Id, 32);
        dataOutStream.writeByte(Dest_terminal_type);
      }
      else
      if(Version == 32) {
        writeString(dataOutStream, Dest_terminal_Id, 21);
      }

      dataOutStream.writeByte(iLength);

      dataOutStream.writeBytes(Msg_Content);
      if(Version == 48) writeString(dataOutStream,LinkID,20); //写入结果
      if(Version == 32) writeString(dataOutStream,Reserved,8);
      //返回消息的字节流
      dataPack = byteArrayOutStream.toByteArray();
      return this.dataPack;
    }catch(Exception e){
      e.printStackTrace();
      System.out.println("[CMPP]makeSubmitMsgPack.pack() error : "+e.getMessage());
      return null;
    }
  }


  /**
   * 打包消息头
   * @param dataOutStream 由调用者传送来的数据输出流
   */
  private void packHead( DataOutputStream dataOutStream ) throws Exception
  {
    try {
      dataOutStream.writeInt(Total_Length);  //写入包长度
      dataOutStream.writeInt(Command_Id);    //写入命令或响应类型
      dataOutStream.writeInt(Sequence_Id);   //写入消息流水号
    } catch(IOException e) {
      System.out.println("[CMPP] CMPP.packHead() thrown IOException"+e);
      throw e;
    }
  }


  /**
   * 解吸接受到的数据包，转换成CMPP MSG
   * @param recvPack
   * @return
   */
  public void parsePack(byte[] recvPack) throws Exception{

    ByteArrayInputStream byteStream = new ByteArrayInputStream(recvPack);
    DataInputStream dataInStream = new DataInputStream(byteStream);

    //读取消息头
    try {
      this.Command_Id  =   dataInStream.readInt();             //消息类型
      this.Sequence_Id =   dataInStream.readInt();             //消息流水号(可以用来完成消息的确认)
    } catch(IOException e) {
      System.out.println("[CMPP] CMPP.parseHead()  error : "+e);
      throw e;
    }

    //读取消息体
    try{
      switch(Command_Id){
        case CMPP.CMPP_CONNECT:
          break;
        case CMPP.CMPP_CONNECT_RESP:
          this.parseConnectRespPack(dataInStream);
          break;

        case CMPP.CMPP_DELIVER:
          this.parseDeliverPack(dataInStream);
          break;
        case CMPP.CMPP_DELIVER_RESP:
          break;

        case CMPP.CMPP_SUBMIT:
          break;
        case CMPP.CMPP_SUBMIT_RESP: