648540858
2022-10-18 1af77ab5f7c11a4b3d59c1989b51b9fca29679ce
src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
@@ -1,6 +1,7 @@
package com.genersoft.iot.vmp.gb28181;
import com.genersoft.iot.vmp.conf.SipConfig;
import com.genersoft.iot.vmp.gb28181.conf.DefaultProperties;
import com.genersoft.iot.vmp.gb28181.transmit.ISIPProcessorObserver;
import gov.nist.javax.sip.SipProviderImpl;
import gov.nist.javax.sip.SipStackImpl;
@@ -40,44 +41,8 @@
   
   @Bean("sipStack")
   @DependsOn({"sipFactory"})
   SipStack createSipStack() throws PeerUnavailableException {
      Properties properties = new Properties();
      properties.setProperty("javax.sip.STACK_NAME", "GB28181_SIP");
      properties.setProperty("javax.sip.IP_ADDRESS", sipConfig.getMonitorIp());
      /**
       * 完整配置参考 gov.nist.javax.sip.SipStackImpl,需要下载源码
       * gov/nist/javax/sip/SipStackImpl.class
       * sip消息的解析在 gov.nist.javax.sip.stack.UDPMessageChannel的processIncomingDataPacket方法
       */
//       * gov/nist/javax/sip/SipStackImpl.class
      if (logger.isDebugEnabled()) {
         properties.setProperty("gov.nist.javax.sip.LOG_MESSAGE_CONTENT", "false");
      }
      // 接收所有notify请求,即使没有订阅
      properties.setProperty("gov.nist.javax.sip.DELIVER_UNSOLICITED_NOTIFY", "true");
      properties.setProperty("gov.nist.javax.sip.AUTOMATIC_DIALOG_ERROR_HANDLING", "false");
      properties.setProperty("gov.nist.javax.sip.CANCEL_CLIENT_TRANSACTION_CHECKED", "false");
      // 为_NULL _对话框传递_终止的_事件
      properties.setProperty("gov.nist.javax.sip.DELIVER_TERMINATED_EVENT_FOR_NULL_DIALOG", "true");
      // 会话清理策略
      properties.setProperty("gov.nist.javax.sip.RELEASE_REFERENCES_STRATEGY", "Normal");
      // 处理由该服务器处理的基于底层TCP的保持生存超时
      properties.setProperty("gov.nist.javax.sip.RELIABLE_CONNECTION_KEEP_ALIVE_TIMEOUT", "60");
      // 获取实际内容长度,不使用header中的长度信息
      properties.setProperty("gov.nist.javax.sip.COMPUTE_CONTENT_LENGTH_FROM_MESSAGE_BODY", "true");
      /**
       * sip_server_log.log 和 sip_debug_log.log ERROR, INFO, WARNING, OFF, DEBUG, TRACE
       */
      properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL", "ERROR");
//      properties.setProperty("gov.nist.javax.sip.SIP_MESSAGE_VALVE", "com.genersoft.iot.vmp.gb28181.session.SipMessagePreprocessing");
//      if (logger.isDebugEnabled()) {
//         properties.setProperty("gov.nist.javax.sip.TRACE_LEVEL", "DEBUG");
//      }
      sipStack = (SipStackImpl) sipFactory.createSipStack(properties);
   SipStackImpl createSipStack() throws PeerUnavailableException {
      sipStack = ( SipStackImpl )sipFactory.createSipStack(DefaultProperties.getProperties(sipConfig.getMonitorIp(), false));
      return sipStack;
   }
@@ -91,7 +56,6 @@
         tcpSipProvider = (SipProviderImpl)sipStack.createSipProvider(tcpListeningPoint);
         tcpSipProvider.setDialogErrorsAutomaticallyHandled();
         tcpSipProvider.addSipListener(sipProcessorObserver);
//         tcpSipProvider.setAutomaticDialogSupportEnabled(false);
         logger.info("[Sip Server] TCP 启动成功 {}:{}", sipConfig.getMonitorIp(), sipConfig.getPort());
      } catch (TransportNotSupportedException e) {
         e.printStackTrace();
@@ -115,7 +79,6 @@
         udpListeningPoint = sipStack.createListeningPoint(sipConfig.getMonitorIp(), sipConfig.getPort(), "UDP");
         udpSipProvider = (SipProviderImpl)sipStack.createSipProvider(udpListeningPoint);
         udpSipProvider.addSipListener(sipProcessorObserver);
//         udpSipProvider.setAutomaticDialogSupportEnabled(false);
      } catch (TransportNotSupportedException e) {
         e.printStackTrace();
      } catch (InvalidArgumentException e) {