panlinlin
2021-05-08 e48fa711a3664bece9b3e58840a75fe7c05bc47c
src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
@@ -118,19 +118,21 @@
    */
   @Override
   public void processRequest(RequestEvent evt) {
      logger.debug(evt.getRequest().toString());
//      logger.debug(evt.getRequest().toString());
      // 由于jainsip是单线程程序,为提高性能并发处理
      processThreadPool.execute(() -> {
         processorFactory.createRequestProcessor(evt).process();
         if (processorFactory != null) {
            processorFactory.createRequestProcessor(evt).process();
         }
      });
   }
   @Override
   public void processResponse(ResponseEvent evt) {
      Response response = evt.getResponse();
      logger.debug(evt.getResponse().toString());
//      logger.debug(evt.getResponse().toString());
      int status = response.getStatusCode();
      if ((status >= 200) && (status < 300)) { // Success!
      if (((status >= 200) && (status < 300)) || status == 401) { // Success!
         ISIPResponseProcessor processor = processorFactory.createResponseProcessor(evt);
         try {
            processor.process(evt, this, sipConfig);
@@ -138,16 +140,23 @@
            // TODO Auto-generated catch block
            e.printStackTrace();
         }
      // } else if (status == Response.TRYING) {
         // trying不会回复
         if (evt.getResponse() != null && sipSubscribe.getOkSubscribesSize() > 0 ) {
            CallIdHeader callIdHeader = (CallIdHeader)evt.getResponse().getHeader(CallIdHeader.NAME);
            if (callIdHeader != null) {
               SipSubscribe.Event subscribe = sipSubscribe.getOkSubscribe(callIdHeader.getCallId());
               if (subscribe != null) {
                  subscribe.response(evt);
               }
            }
         }
      } else if ((status >= 100) && (status < 200)) {
         // 增加其它无需回复的响应,如101、180等
      } else {
         logger.warn("接收到失败的response响应!status:" + status + ",message:" + response.getReasonPhrase()/* .getContent().toString()*/);
         if (evt.getResponse() != null && sipSubscribe.getSize() > 0 ) {
         if (evt.getResponse() != null && sipSubscribe.getErrorSubscribesSize() > 0 ) {
            CallIdHeader callIdHeader = (CallIdHeader)evt.getResponse().getHeader(CallIdHeader.NAME);
            if (callIdHeader != null) {
               SipSubscribe.Event subscribe = sipSubscribe.getSubscribe(callIdHeader.getCallId());
               SipSubscribe.Event subscribe = sipSubscribe.getErrorSubscribe(callIdHeader.getCallId());
               if (subscribe != null) {
                  subscribe.response(evt);
               }