Lawrence
2020-10-19 5ab432856deb79c26a3b4ea05e8582acf9e80cdc
src/main/java/com/genersoft/iot/vmp/gb28181/SipLayer.java
@@ -2,22 +2,12 @@
import java.text.ParseException;
import java.util.Properties;
import java.util.TooManyListenersException;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.sip.DialogTerminatedEvent;
import javax.sip.IOExceptionEvent;
import javax.sip.ListeningPoint;
import javax.sip.PeerUnavailableException;
import javax.sip.RequestEvent;
import javax.sip.ResponseEvent;
import javax.sip.SipFactory;
import javax.sip.SipListener;
import javax.sip.SipProvider;
import javax.sip.SipStack;
import javax.sip.TimeoutEvent;
import javax.sip.TransactionTerminatedEvent;
import javax.sip.*;
import javax.sip.message.Response;
import org.slf4j.Logger;
@@ -93,11 +83,17 @@
   @Bean("tcpSipProvider")
   @DependsOn("sipStack")
   private SipProvider startTcpListener() throws Exception {
      ListeningPoint tcpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "TCP");
      SipProvider tcpSipProvider = sipStack.createSipProvider(tcpListeningPoint);
      tcpSipProvider.addSipListener(this);
      logger.info("Sip Server TCP 启动成功 port {" + sipConfig.getSipPort() + "}");
   private SipProvider startTcpListener() {
      ListeningPoint tcpListeningPoint = null;
      SipProvider tcpSipProvider  = null;
      try {
         tcpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "TCP");
         tcpSipProvider = sipStack.createSipProvider(tcpListeningPoint);
         tcpSipProvider.addSipListener(this);
         logger.info("Sip Server TCP 启动成功 port {" + sipConfig.getSipPort() + "}");
      } catch (TransportNotSupportedException | InvalidArgumentException | TooManyListenersException | ObjectInUseException e) {
         logger.error(String.format("创建SIP服务失败: %s", e.getMessage()));
      }
      return tcpSipProvider;
   }
   
@@ -107,7 +103,7 @@
      ListeningPoint udpListeningPoint = sipStack.createListeningPoint(sipConfig.getSipIp(), sipConfig.getSipPort(), "UDP");
      SipProvider udpSipProvider = sipStack.createSipProvider(udpListeningPoint);
      udpSipProvider.addSipListener(this);
      logger.info("Sip Server TCP 启动成功 port {" + sipConfig.getSipPort() + "}");
      logger.info("Sip Server UDP 启动成功 port {" + sipConfig.getSipPort() + "}");
      return udpSipProvider;
   }