From 84cc6e092a4c0f4aba3ffbef71325b844e0a4bea Mon Sep 17 00:00:00 2001 From: swwheihei <swwheihei@163.com> Date: 星期六, 18 七月 2020 11:27:42 +0800 Subject: [PATCH] 解决低级编译问题 --- src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java | 28 ++++++++++++++++------------ 1 files changed, 16 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java index 133f6fc..aaf347d 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommander.java @@ -1,31 +1,30 @@ package com.genersoft.iot.vmp.gb28181.transmit.cmd.impl; import java.text.ParseException; +import java.util.regex.Matcher; +import java.util.regex.Pattern; import javax.sip.ClientTransaction; import javax.sip.Dialog; import javax.sip.InvalidArgumentException; import javax.sip.SipException; +import javax.sip.SipFactory; +import javax.sip.SipProvider; import javax.sip.TransactionDoesNotExistException; -import javax.sip.address.Address; import javax.sip.address.SipURI; import javax.sip.header.ViaHeader; import javax.sip.message.Request; import org.springframework.beans.factory.annotation.Autowired; -import org.springframework.boot.autoconfigure.security.SecurityProperties.Headers; +import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.stereotype.Component; import com.genersoft.iot.vmp.conf.SipConfig; -import com.genersoft.iot.vmp.gb28181.SipLayer; import com.genersoft.iot.vmp.gb28181.bean.Device; import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager; import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander; import com.genersoft.iot.vmp.gb28181.transmit.cmd.SIPRequestHeaderProvider; import com.genersoft.iot.vmp.gb28181.utils.DateUtil; - -import java.util.regex.Pattern; -import java.util.regex.Matcher; /** * @Description:璁惧鑳藉姏鎺ュ彛锛岀敤浜庡畾涔夎澶囩殑鎺у埗銆佹煡璇㈣兘鍔� @@ -42,10 +41,15 @@ private SIPRequestHeaderProvider headerProvider; @Autowired - private SipLayer sipLayer; + private VideoStreamSessionManager streamSession; @Autowired - private VideoStreamSessionManager streamSession; + @Qualifier(value="tcpSipProvider") + private SipProvider tcpSipProvider; + + @Autowired + @Qualifier(value="udpSipProvider") + private SipProvider udpSipProvider; /** * 浜戝彴鏂瑰悜鏀炬帶鍒讹紝浣跨敤閰嶇疆鏂囦欢涓殑榛樿闀滃ご绉诲姩閫熷害 @@ -305,9 +309,9 @@ String protocol = viaHeader.getTransport().toUpperCase(); ClientTransaction clientTransaction = null; if("TCP".equals(protocol)) { - clientTransaction = sipLayer.getTcpSipProvider().getNewClientTransaction(byeRequest); + clientTransaction = tcpSipProvider.getNewClientTransaction(byeRequest); } else if("UDP".equals(protocol)) { - clientTransaction = sipLayer.getUdpSipProvider().getNewClientTransaction(byeRequest); + clientTransaction = udpSipProvider.getNewClientTransaction(byeRequest); } dialog.sendRequest(clientTransaction); } catch (TransactionDoesNotExistException e) { @@ -541,9 +545,9 @@ private ClientTransaction transmitRequest(Device device, Request request) throws SipException { ClientTransaction clientTransaction = null; if("TCP".equals(device.getTransport())) { - clientTransaction = sipLayer.getTcpSipProvider().getNewClientTransaction(request); + clientTransaction = tcpSipProvider.getNewClientTransaction(request); } else if("UDP".equals(device.getTransport())) { - clientTransaction = sipLayer.getUdpSipProvider().getNewClientTransaction(request); + clientTransaction = udpSipProvider.getNewClientTransaction(request); } clientTransaction.sendRequest(); return clientTransaction; -- Gitblit v1.8.0