| | |
|---|
| | | param.put("app",sendRtpItem.getApp()); |
|---|
| | | param.put("stream",streamId); |
|---|
| | | param.put("ssrc",sendRtpItem.getSsrc()); |
|---|
| | | logger.info("停止向上级推流：" + streamId); |
|---|
| | | logger.info("收到bye:停止向上级推流：" + streamId); |
|---|
| | | MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | zlmrtpServerFactory.stopSendRtpStream(mediaInfo, param); |
|---|
| | | redisCatchStorage.deleteSendRTPServer(platformGbId, channelId, callIdHeader.getCallId(), null); |
|---|
| | | int totalReaderCount = zlmrtpServerFactory.totalReaderCount(mediaInfo, sendRtpItem.getApp(), streamId); |
|---|
| | | if (totalReaderCount <= 0) { |
|---|
| | | logger.info(streamId + "无其它观看者，通知设备停止推流"); |
|---|
| | | cmder.streamByeCmd(sendRtpItem.getDeviceId(), channelId, streamId); |
|---|
| | | logger.info("收到bye: {}无其它观看者，通知设备停止推流", streamId); |
|---|
| | | if (sendRtpItem.isPlay()) { |
|---|
| | | cmder.streamByeCmd(sendRtpItem.getDeviceId(), channelId, streamId, null); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 可能是设备主动停止 |
|---|
