From 74714711aa87dcd1259f5aebe55d362be732ffa2 Mon Sep 17 00:00:00 2001 From: 648540858 <648540858@qq.com> Date: 星期二, 18 十月 2022 17:35:42 +0800 Subject: [PATCH] 优化sip消息构建,去除ServerTransaction的使用 --- src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java | 17 +++-------------- 1 files changed, 3 insertions(+), 14 deletions(-) diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java index 3cca115..8b8613d 100644 --- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java +++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/response/impl/InviteResponseProcessor.java @@ -5,6 +5,7 @@ import com.genersoft.iot.vmp.gb28181.bean.SsrcTransaction; import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager; import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver; +import com.genersoft.iot.vmp.gb28181.transmit.SIPSender; import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander; import com.genersoft.iot.vmp.gb28181.transmit.cmd.SIPRequestHeaderProvider; import com.genersoft.iot.vmp.gb28181.transmit.event.response.SIPResponseProcessorAbstract; @@ -49,25 +50,14 @@ private final String method = "INVITE"; @Autowired - private VideoStreamSessionManager streamSession; - - @Autowired private SIPProcessorObserver sipProcessorObserver; - @Autowired - private SipConfig sipConfig; @Autowired private SipFactory sipFactory; @Autowired - private GitUtil gitUtil; - - @Autowired - private ISIPCommander commander; - - @Autowired - private IDeviceService deviceService; + private SIPSender sipSender; @Autowired private SIPRequestHeaderProvider headerProvider; @@ -121,8 +111,7 @@ Request reqAck = headerProvider.createAckRequest(requestUri, response); logger.info("[鍥炲ack] {}-> {}:{} ", sdp.getOrigin().getUsername(), event.getRemoteIpAddress(), event.getRemotePort()); - commander.transmitRequest(response.getTopmostViaHeader().getTransport(), reqAck, null, null); - + sipSender.transmitRequest(reqAck); } } catch (InvalidArgumentException | ParseException | SipException | SdpParseException e) { logger.info("[鐐规挱鍥炲ACK]锛屽紓甯革細", e ); -- Gitblit v1.8.0