mm7receiver.java

中国移动彩信中心MM7接口统一API mm7api

      }catch(ParseException pe){
        pe.printStackTrace();
      }
      if((timeNow-timeFile) > (long)LogInterval * 60 * 1000)
      {
        N = 1;
        this.deleteFile(LogPath, LogNum,MMSCID);
        logFileName = LogPath + "/" + MMSCID + "_" + temptime + "." +df.format(N) + ".log";
        try{
          fos = new FileOutputStream(logFileName);
        }catch(FileNotFoundException fnfe){
          fnfe.printStackTrace();
        }
      }
      else
      {
       if (logFile.length() >= LogSize * 1024) {
          if (N < LogNum)
            N++;
          else
            N = 1;
          this.deleteFile(LogPath, LogNum, MMSCID);
          logFileName = LogPath + "/" + MMSCID + "_" + temptime + "." +
              df.format(N) + ".log";
          try {
            fos = new FileOutputStream(logFileName);
          }
          catch (FileNotFoundException fnfe) {
            fnfe.printStackTrace();
          }
        }
      }
    }
    else
    {
      N = 1;
      this.deleteFile(LogPath, LogNum,MMSCID);
      logFileName = LogPath + "/" + MMSCID + "_" + temptime + "." +df.format(N) + ".log";
      try{
        File logFile = new File(logFileName);
        fos = new FileOutputStream(logFile);
      }catch(FileNotFoundException fnfe){
        fnfe.printStackTrace();
      }
    }
    try{
      switch (LogLevel) {
        case 1: {
          if(SevereBuffer != null && SevereBuffer.length() > 0)
            if(fos != null)
            {
              try {
                 FileOutputStream fos = new FileOutputStream(logFileName, true);
                 fos.write(Severebaos.toByteArray());
                 fos.close();
                 SevereBuffer = new StringBuffer();
               }catch(Exception e){}
            }
          break;
        }
        case 2:
          break;
        case 3: {
          if(fos != null)
          {
            if (SevereBuffer != null && SevereBuffer.length() > 0)
              fos.write(SevereBuffer.toString().getBytes());
            if (InfoBuffer != null && InfoBuffer.length() > 0)
              fos.write(InfoBuffer.toString().getBytes());
            fos.close();
          }
          break;
        }
        case 4:
          break;
        case 5:
          break;
        case 6: {
          if(fos != null){
            if (SevereBuffer != null && SevereBuffer.length() > 0)
              fos.write(SevereBuffer.toString().getBytes());
            if (InfoBuffer != null && InfoBuffer.length() > 0)
              fos.write(InfoBuffer.toString().getBytes());
            if (Finerbaos != null && Finerbaos.size() > 0)
              fos.write(Finerbaos.toByteArray());
            fos.close();
          }
          break;
        }
        case 7:
          break;
        default:
          break;
      }
    }
    catch (IOException ioe) {
      ioe.printStackTrace();
    }*/
  }

  private void deleteFile(String logpath,int lognum,String MMSCID)
  {
    File parfile = new File(logpath);
    if(parfile.isDirectory())
    {
      File[] subfile = parfile.listFiles();
      List list = new ArrayList();
      for (int i = 0; i < subfile.length; i++) {
        String name = subfile[i].getName();
        if (name.indexOf(MMSCID) >= 0) {
          list.add(name);
        }
      }
      if(list.size() >= lognum)
      {
        int deleteLength = list.size()-lognum+1;
        Comparator comp = Collections.reverseOrder();
        Collections.sort(list, comp);
        for (int i = list.size()-deleteLength; i < list.size(); i++) {
          String strfile = (String) list.get(i);
          File ff = new File(logpath + "/" + strfile);
          ff.delete();
        }
      }
    }
  }

  private void ServiceConnect(Socket client,int nc) throws IOException
  {
    boolean longLink = false;
    longLink = this.getLongLink();
    DataInputStream in = null;
    SevereBuffer = new StringBuffer();
    InfoBuffer = new StringBuffer();
    FinerBuffer = new StringBuffer();
    Finerbaos = new ByteArrayOutputStream();
    boolean bHead = false;
    int index1 = 0,index2 = 0,index3 = 0;
    int length = 0;
    try
    {
      //client.setSoTimeout(Config.getTimeOut());

      //client.setSoTimeout(0);
      SevereBuffer.append("recv client="+client+"\r\n");
      in = new DataInputStream(new BufferedInputStream(client.getInputStream()));
      ByteArrayOutputStream baos = new ByteArrayOutputStream();
      byte[] b = new byte[1024];
      int readlen = 0;
      int totallen = 0;
      while(1>0)
      {
        //System.out.println("开始接收");
          readlen = in.read(b);
        if(readlen < 0)
          return;
        baos.write(b,0,readlen);
        totallen = totallen + readlen;
        if(bHead == false && baos.toString().indexOf("\r\n\r\n") < 0)
          continue;

        if(bHead == false){
          index1 = baos.toString().toLowerCase().indexOf(MMConstants.CONTENT_LENGTH);
          index2 = baos.toString().indexOf("\r",index1);
          if(index1 == -1 || index2 == -1)
          {
            baos.reset();
            totallen = 0;
            continue;
          }
          length = Integer.parseInt(baos.toString().substring(
              (index1+MMConstants.CONTENT_LENGTH.length()+1),index2).trim());
          index3 = baos.toString().indexOf("\r\n\r\n");
          bHead = true;
        }
        if(totallen < index3 + length + 4)
          continue;
        bHead = false;
        if(Config.getAuthenticationMode() == 1)
        {
          if(basicAuth(client,baos) == false)
          {
            baos.reset();
            totallen = 0;
            continue;
          }
        }
        else if(Config.getAuthenticationMode() == 2)
        {
          if(digestAuth(client,baos,nc) == false)
          {
            baos.reset();
            totallen = 0;
            continue;
          }
        }
//System.out.println("baos="+baos.toString());
        SOAPDecoder soapDecoder = new SOAPDecoder();
        soapDecoder.setMessage(baos);
        try{
          soapDecoder.decodeMessage();
          //System.out.println("xml处理结束");
          SevereBuffer.append("end dealing with xml!");
          MM7RSReq req = soapDecoder.getMessage();
          if(req == null)
          {
            baos.reset();
            totallen = 0;
            SevereBuffer.append("[Comments=解析后的消息为空！]");
            continue;
          }
          if(soapDecoder.getMessageName().equals(MMConstants.DELIVERREQ))
          {
            SevereBuffer.append("DeliverReq");
            MM7DeliverReq deliverReq = (MM7DeliverReq)req;
            InfoBuffer.append("\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][3]");
            TempBuffer.append("[TransactionID="+deliverReq.getTransactionID()+"]");
            TempBuffer.append("[Message_Type=MM7DeliverReq]");
            TempBuffer.append("[Sender_Address="+deliverReq.getSender()+"]");
            TempBuffer.append("[Recipient_Address={");
            if (deliverReq.isToExist()) {
              TempBuffer.append("To={");
              List to = new ArrayList();
              to = deliverReq.getTo();
              for (int i = 0; i < to.size(); i++)
              TempBuffer.append( (String) to.get(i) + ",");
              TempBuffer.append("}");
            }
            if (deliverReq.isCcExist()) {
              TempBuffer.append("Cc={");
              List cc = new ArrayList();
              cc = deliverReq.getCc();
              for (int i = 0; i < cc.size(); i++)
                TempBuffer.append( (String) cc.get(i) + ",");
              TempBuffer.append("}");
            }
            if (deliverReq.isBccExist()) {
              TempBuffer.append("Bcc={");
              List bcc = new ArrayList();
              bcc = deliverReq.getBcc();
              for (int i = 0; i < bcc.size(); i++)
                TempBuffer.append( (String) bcc.get(i) + ",");
              TempBuffer.append("}");
            }
            TempBuffer.append("}]");
            InfoBuffer.append(TempBuffer);
            InfoBuffer.append("\r\n"+soapDecoder.getEnvelope());  //Envelope消息
            String timelevel = "\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][6]";
            Finerbaos.write(timelevel.getBytes());
            Finerbaos.write(TempBuffer.toString().getBytes());
            Finerbaos.write("\r\n".getBytes());
            Finerbaos.write(soapDecoder.getSoapStream().toByteArray());
            TempBuffer = new StringBuffer();
            MM7DeliverRes deliverRes = (MM7DeliverRes)doDeliver(deliverReq);
            InfoBuffer.append("\r\n\r\n"+"["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"]"+"[3]");
            String tempres = "\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][6]";
            Finerbaos.write(tempres.getBytes());
            TempBuffer.append("[Message_Type=MM7DeliverRes]");
            TempBuffer.append("[Comments={" + deliverRes.getStatusCode() +
                      ";"+deliverRes.getStatusText()+"}]\r\n");
            InfoBuffer.append(TempBuffer);
            Finerbaos.write(TempBuffer.toString().getBytes());
            TempBuffer = new StringBuffer();
            Finerbaos.write("\r\n".getBytes());
            send(client,deliverRes,longLink);
          }else if(soapDecoder.getMessageName().equals(MMConstants.DELIVERYREPORTREQ)){
            //System.out.println("MMConstants.DELIVERYREPORTREQ");
            SevereBuffer.append("  DeliveryReportReq");
            MM7DeliveryReportReq deliverReportReq = (MM7DeliveryReportReq)req;
            InfoBuffer.append("\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][3]");
            TempBuffer.append("[TransactionID="+deliverReportReq.getTransactionID()+"]");
            TempBuffer.append("[Message_Type=MM7DeliveryReportReq]");
            TempBuffer.append("[Sender_Address="+deliverReportReq.getSender()+"]");
            InfoBuffer.append(TempBuffer);
            InfoBuffer.append("\r\n"+soapDecoder.getEnvelope());  //Envelope消息
            String timelevel = "\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][6]";
            Finerbaos.write(timelevel.getBytes());
            Finerbaos.write(TempBuffer.toString().getBytes());
            Finerbaos.write("\r\n".getBytes());
            Finerbaos.write(soapDecoder.getSoapStream().toByteArray());
            TempBuffer = new StringBuffer();
            MM7DeliveryReportRes deliverReportRes = (MM7DeliveryReportRes)doDeliveryReport(deliverReportReq);

            InfoBuffer.append("\r\n\r\n"+"["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"]"+"[3]");
            String tempres = "\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][6]";
            Finerbaos.write(tempres.getBytes());
            TempBuffer.append("[Message_Type=MM7DeliverRes]");
            TempBuffer.append("[Comments={" + deliverReportRes.getStatusCode() +
                      ";"+deliverReportRes.getStatusText()+"}]\r\n");
            InfoBuffer.append(TempBuffer);
            Finerbaos.write(TempBuffer.toString().getBytes());
            TempBuffer = new StringBuffer();
            Finerbaos.write("\r\n".getBytes());

            send(client,deliverReportRes,longLink);

          }else if(soapDecoder.getMessageName().equals(MMConstants.READREPLYREQ)){
            SevereBuffer.append("  ReadReplyReq");
            MM7ReadReplyReq readReplyReq = (MM7ReadReplyReq)req;

            InfoBuffer.append("\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][3]");
            TempBuffer.append("[TransactionID="+readReplyReq.getTransactionID()+"]");
            TempBuffer.append("[Message_Type=MM7ReadReplyReq]");
            TempBuffer.append("[Sender_Address="+readReplyReq.getSender()+"]");
            InfoBuffer.append(TempBuffer);
            InfoBuffer.append("\r\n"+soapDecoder.getEnvelope());  //Envelope消息
            String timelevel = "\r\n\r\n["+Recordsdf.format(new Date(
                System.currentTimeMillis()))+"][6]";
            Finerbaos.write(timelevel.getBytes());
            Finerbaos.write(TempBuffer.toString().getBytes());
            Finerbaos.write("\r\n".getBytes());
            Finerbaos.write(soapDecoder.getSoapStream().toByteArray());
            TempBuffer = new StringBuffer();
            MM7ReadReplyRes readReplyRes = (MM7ReadReplyRes)doReadReply(readReplyReq);
            InfoBuffer.append("\r\n\r\n"+"["+Recordsdf.format(new Date(
               System.currentTimeMillis()))+"]"+"[3]");
           String tempres = "\r\n\r\n[" + Recordsdf.format(new Date(
               System.currentTimeMillis())) + "][6]";
           Finerbaos.write(tempres.getBytes());
           TempBuffer.append("[Message_Type=MM7DeliverRes]");
           TempBuffer.append("[Comments={" + readReplyRes.getStatusCode() +
                             ";" + readReplyRes.getStatusText() + "}]\r\n");
           InfoBuffer.append(TempBuffer);
           Finerbaos.write(TempBuffer.toString().getBytes());
           TempBuffer = new StringBuffer();
           Finerbaos.write("\r\n".getBytes());
            send(client,readReplyRes,longLink);
          }
          InfoBuffer.append(strEnvelope);
          Finerbaos.write(strEnvelope.getBytes());
          String time = "[" + Recordsdf.format(new Date(System.currentTimeMillis())) + "]";
          SevereBuffer.insert(0, "\r\n\r\n" +time + "[1]");  //
          MMSCID = Config.getMmscId();
          if(Config.getLogLevel()>0)
          {
            SevereBuffer.append("manager count="+(receiveNumber++));
            WriteLog(MMSCID);
          }
        }catch (SOAPDecodeException e){
          System.err.println("decode exception:"+e);
          SevereBuffer.append("[SOAPDecodeException="+e+"]");
        }
        //System.out.println("处理数目="+(receiveNumber++));
        if(totallen > index3 + length + 4){
          baos.write(b,(MMConstants.ARRAYLIMIT-(totallen-index3-length-4)),totallen-index3-length-4);
          baos.reset();
          totallen = totallen - index3 - length - 4;
          baos.write(b,0,totallen);
        }else{
          baos.reset();
          totallen = 0;
        }
        bHead = false;
        if(longLink == false)
          break;
      }
    }
    catch (IOException ioe){
      SevereBuffer.append("[Error in SimpleWebServer: "+ioe+"]");
    }
    finally
    {
      // 清除
      if(in != null)
        in.close();
      if(client != null)
        client.close();
    }
  }

  public void send(Socket socket,MM7VASPRes mm7VASPRes,boolean longLink)
  {
    StringBuffer beforAuth = new StringBuffer();
    StringBuffer afterAuth = new StringBuffer();
    StringBuffer sb = new StringBuffer();
    StringBuffer entityBody = new StringBuffer();
    BufferedOutputStream sender = null;

    try
    {
      SevereBuffer.append("  send ack socket is "+socket+"\r\n");
      sender = new BufferedOutputStream(socket.getOutputStream());
      beforAuth.append("HTTP/1.1 200 OK\r\n");
      if(longLink == true)
        beforAuth.append("Connection: Keep-Alive\r\n");
      else
        beforAuth.append("Connection: close\r\n");
      //beforAuth.append("Content-Type: text/xml;charset=\""+Config.getCharSet()+"\""+"\r\n");
      beforAuth.append("Content-Type: text/xml;charset="+Config.getCharSet()+"\r\n");
      //设置鉴权
      byte[] bcontent = getContent(mm7VASPRes);
      //设置消息体长度
      afterAuth.append("Content-Length: "+bcontent.length+"\r\n");
      ///////////
      //afterAuth.append("Connection: close\r\n");
      //////////
      //afterAuth.append("Mime-Version:1.0"+"\r\n");
      //afterAuth.append("SOAPAction: \"\""+"\r\n");
      afterAuth.append("\r\n");
      sb.append(beforAuth);
      sb.append(afterAuth);
      entityBody.append(new String(bcontent));
      sb.append(entityBody);
      sender.write(sb.toString().getBytes());
      sender.flush();
      //System.out.println("发送完毕");
      SevereBuffer.append("end sending ack!");
      return;
    }
    catch(InterruptedIOException iioe)
    {
      SevereBuffer.append("[InterruptedIOException="+iioe+"]");
      return;