会话线程安全吗？SMPP Logica库

我想问..目前我正在使用SMPP Logica Library..for开发SMSC客户端...并且我使用session.submit发送消息给smsc服务器，发送消息几乎50消息/秒，我想要使用线程多次发送，因为我需要从服务器获得每个响应报告...问题是..是session.submit线程安全吗？我应该先同步化使用线程发送消息之前的会话？我用它来发送短信代码会话线程安全吗？SMPP Logica库

{ 
     response = session.submit(sm); 
        SUBMIT_SM_RESP(response,mt); 
    ........ 

    } 
     private void SUBMIT_SM_RESP(SubmitSMResp pdu,MTData mtd) { 

       log.info("CommandID From PDU "+pdu.getCommandId()); 
       //SubmitSMResp submitSMResp = new SubmitSMResp(); 
       if (pdu.getCommandId() == Data.SUBMIT_SM_RESP){ 
       // submitSMResp.setData(pdu.getData()); 
        switch (pdu.getCommandStatus()) 
        { 
        case 0: 
        log.info("Berhasil kirim MT; SeqNo=" + pdu.getSequenceNumber() + ";" + pdu.debugString()); 
        break; 
        case 1031: 
        log.info("Error. Service not found; SeqNo=" + pdu.getSequenceNumber() + ";" +pdu.debugString()); 
        break; 
        case 1032: 
        log.info("Error. Invalid TX Id; SeqNo=" + pdu.getSequenceNumber() + ";" +pdu.debugString()); 
        break; 


case 1033: 
       log.info("Error. Push limit exceeded; SeqNo=" + pdu.getSequenceNumber() + ";" + pdu.debugString()); 
       break; 
       case 4107: 
       log.info("Error. Content Whitelisted (Testingmode); SeqNo=" + pdu.getSequenceNumber() + ";" +pdu.debugString()); 
       break; 
       case 1280: 
        log.info("Insuficient Balance(Charging); SeqNo=" + pdu.getSequenceNumber() + ";" +pdu.debugString()); 
       break; 
       } 

       log.debug("MT rec status: CommandID=SUBMIT_SM_RESP; SeqNo=" + pdu.getSequenceNumber() + "; CommandSts=" + pdu.getCommandStatus() + pdu.debugString()); 
       //MTData mt = (MTData)DataInstance.getInstance().getHmSeqMT().get(Integer.valueOf(pdu.getSequenceNumber())); 
       MTData mt =mtd; 
       String tid = null; 
       if (mt == null) { 
        log.info("MT null"); 
      // if (DataInstance.getInstance().getHmSeqTrxID().containsKey(Integer.valueOf(pdu.getSequenceNumber()))) { 
    //    tid = (String)DataInstance.getInstance().getHmSeqTrxID().get(Integer.valueOf(pdu.getSequenceNumber())); 
    //    mt = DataInstance.getInstance().getDbPrs().getMTTrxID(tid); 
    //    log.info("MT rec status: CommandID=SUBMIT_SM_RESP; SeqNo=" + pdu.getSequenceNumber() + "; CommandSts=" + pdu.getCommandStatus() + "; trxid=" + tid + "; " + pdu.debugString()); 
      //  if (mt == null) { 
        log.info("MT rec status: CommandID=SUBMIT_SM_RESP; SeqNo=" + pdu.getSequenceNumber() + "; CommandSts=" + pdu.getCommandStatus() + "; trxid=" + tid + " n/a; " + pdu.debugString()); 
        mt = DataInstance.getInstance().getDbPrs().getMTSeqNo(String.valueOf(pdu.getSequenceNumber())); 

      //  } 
       // } 
       } 
       else { 
        tid = mt.getTransid(); 
        } 
      // log.info(mt.getClass()); 
      log.info("Transaction ID >>> "+mt.getTransid()); 
       if (mt != null) { 
       DataInstance.getInstance().getDbPrs().deleteMT(mt, 
        String.valueOf(pdu.getCommandStatus()), DataInstance.getInstance().getTransX().operator); 
       DataInstance.getInstance().getHmSeqMT().remove(Integer.valueOf(pdu.getSequenceNumber())); 
       } else { 
       log.info("MT Null,,,Can't Send DR"); 
       log.info("MT n/a: SeqNo=" + pdu.getSequenceNumber() + "; CommandSts=" + pdu.getCommandStatus() + pdu.debugString()); 
       } 
      } 
      else 
      { 
       log.info("Nilai Enquiry Link "+Data.ENQUIRE_LINK_RESP); 
      } 
     }

问候

丹茨

来源

2013-02-25 dmh

在同步模式下，它始终是线程安全的（像你现在正在努力）。这是一个完全不同的故事去异步模式。

来源

2013-02-25 18:28:01

好的，谢谢我已经实现线程每次提交消息...并没有问题......谢谢:) .. – dmh 2013-02-26 01:13:54

会话线程安全吗？SMPP Logica库

回答

相关问题