更新文档

648540858

2023-05-12 b498e2fcf21ee4f612dfaf0b45a945c52da37c60

 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.conf.UserSetting;

import com.genersoft.iot.vmp.gb28181.conf.DefaultProperties;

import com.genersoft.iot.vmp.gb28181.transmit.ISIPProcessorObserver;

import gov.nist.javax.sip.SipProviderImpl;

@@ -18,7 +19,7 @@
import java.util.concurrent.ConcurrentHashMap;



@Component

@Order(value=1)

@Order(value=10)

public class SipLayer implements CommandLineRunner {



   private final static Logger logger = LoggerFactory.getLogger(SipLayer.class);

@@ -29,10 +30,11 @@
   @Autowired

   private ISIPProcessorObserver sipProcessorObserver;



   @Autowired

   private UserSetting userSetting;



   private final Map<String, SipProviderImpl> tcpSipProviderMap = new ConcurrentHashMap<>();

   private final Map<String, SipProviderImpl> udpSipProviderMap = new ConcurrentHashMap<>();



   private SipFactory sipFactory;



   @Override

   public void run(String... args) {

@@ -46,8 +48,7 @@
         monitorIps.add(sipConfig.getIp());

      }



      sipFactory = SipFactory.getInstance();

      sipFactory.setPathName("gov.nist");

      SipFactory.getInstance().setPathName("gov.nist");

      if (monitorIps.size() > 0) {

         for (String monitorIp : monitorIps) {

            addListeningPoint(monitorIp, sipConfig.getPort());

@@ -61,7 +62,7 @@
   private void addListeningPoint(String monitorIp, int port){

      SipStackImpl sipStack;

      try {

         sipStack = (SipStackImpl)sipFactory.createSipStack(DefaultProperties.getProperties(monitorIp, false));

         sipStack = (SipStackImpl)SipFactory.getInstance().createSipStack(DefaultProperties.getProperties(monitorIp, userSetting.getSipLog()));

      } catch (PeerUnavailableException e) {

         logger.error("[Sip Server] SIP服务启动失败， 监听地址{}失败,请检查ip是否正确", monitorIp);

         return;

@@ -100,10 +101,6 @@
         logger.error("[Sip Server] udp://{}:{} SIP服务启动失败,请检查端口是否被占用或者ip是否正确"

               , monitorIp, port);

      }

   }



   public SipFactory getSipFactory() {

      return sipFactory;

   }



   public SipProviderImpl getUdpSipProvider(String ip) {