| | |
|---|
| | | param.put("ssrc",sendRtpItem.getSsrc()); |
|---|
| | | logger.info("收到bye:停止向上级推流：" + streamId); |
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param); |
|---|
| | | redisCatchStorage.deleteSendRTPServer(platformGbId, channelId, callIdHeader.getCallId(), null); |
|---|
| | | zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param); |
|---|
| | | int totalReaderCount = zlmrtpServerFactory.totalReaderCount(mediaInfo, sendRtpItem.getApp(), streamId); |
|---|
| | | if (totalReaderCount <= 0) { |
|---|
| | | logger.info("收到bye: {} 无其它观看者，通知设备停止推流", streamId); |
|---|
| | |
|---|
| | | StreamInfo streamInfo = redisCatchStorage.queryPlayByDevice(device.getDeviceId(), channelId); |
|---|
| | | if (streamInfo != null) { |
|---|
| | | redisCatchStorage.stopPlay(streamInfo); |
|---|
| | | mediaServerService.closeRTPServer(device.getDeviceId(), channelId, streamInfo.getStream()); |
|---|
| | | mediaServerService.closeRTPServer(streamInfo.getMediaServerId(), streamInfo.getStream()); |
|---|
| | | } |
|---|
| | | SsrcTransaction ssrcTransactionForPlay = streamSession.getSsrcTransaction(device.getDeviceId(), channelId, "play", null); |
|---|
| | | if (ssrcTransactionForPlay != null){ |
|---|
| | | SIPDialog dialogForPlay = (SIPDialog) SerializeUtils.deSerialize(ssrcTransactionForPlay.getDialog()); |
|---|
| | | if (dialogForPlay.getCallId().equals(callIdHeader.getCallId())){ |
|---|
| | | if (dialogForPlay.getCallId().getCallId().equals(callIdHeader.getCallId())){ |
|---|
| | | // 释放ssrc |
|---|
| | | MediaServerItem mediaServerItem = mediaServerService.getOne(ssrcTransactionForPlay.getMediaServerId()); |
|---|
| | | if (mediaServerItem != null) { |
|---|
