wvp-pro.git - Gitblit

			@@ -6,6 +6,7 @@
			import com.genersoft.iot.vmp.gb28181.bean.InviteStreamType;
			import com.genersoft.iot.vmp.gb28181.bean.SendRtpItem;
			import com.genersoft.iot.vmp.gb28181.bean.SsrcTransaction;
			import com.genersoft.iot.vmp.gb28181.session.SSRCFactory;
			import com.genersoft.iot.vmp.gb28181.session.VideoStreamSessionManager;
			import com.genersoft.iot.vmp.gb28181.transmit.SIPProcessorObserver;
			import com.genersoft.iot.vmp.gb28181.transmit.cmd.ISIPCommander;
			@@ -18,6 +19,7 @@
			import com.genersoft.iot.vmp.service.bean.MessageForPushChannel;
			import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
			import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
			import gov.nist.javax.sip.message.SIPRequest;
			import org.slf4j.Logger;
			import org.slf4j.LoggerFactory;
			import org.springframework.beans.factory.InitializingBean;
			@@ -60,6 +62,9 @@
			private ZLMRTPServerFactory zlmrtpServerFactory;

			@Autowired
			private SSRCFactory ssrcFactory;

			@Autowired
			private IMediaServerService mediaServerService;

			@Autowired
			@@ -82,7 +87,7 @@
			public void process(RequestEvent evt) {

			try {
			responseAck(getServerTransaction(evt), Response.OK);
			responseAck((SIPRequest) evt.getRequest(), Response.OK);
			} catch (SipException \| InvalidArgumentException \| ParseException e) {
			logger.error("[回复BYE信息失败]，{}", e.getMessage());
			}
			@@ -101,12 +106,13 @@
			logger.info("[收到bye] 停止向上级推流：{}", streamId);
			MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());
			redisCatchStorage.deleteSendRTPServer(platformGbId, channelId, callIdHeader.getCallId(), null);
			ssrcFactory.releaseSsrc(sendRtpItem.getMediaServerId(), sendRtpItem.getSsrc());
			zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param);
			int totalReaderCount = zlmrtpServerFactory.totalReaderCount(mediaInfo, sendRtpItem.getApp(), streamId);
			if (totalReaderCount <= 0) {
			logger.info("[收到bye] {} 无其它观看者，通知设备停止推流", streamId);
			if (sendRtpItem.getPlayType().equals(InviteStreamType.PLAY)) {
			Device device = deviceService.queryDevice(sendRtpItem.getDeviceId());
			Device device = deviceService.getDevice(sendRtpItem.getDeviceId());
			if (device == null) {
			logger.info("[收到bye] {} 通知设备停止推流时未找到设备信息", streamId);
			}