| | |
|---|
| | | @EventListener |
|---|
| | | public void onApplicationEvent(MediaSendRtpStoppedEvent event) { |
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByStream(event.getStream()); |
|---|
| | | if (!sendRtpItems.isEmpty()) { |
|---|
| | | if (sendRtpItems != null && !sendRtpItems.isEmpty()) { |
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) { |
|---|
| | | ParentPlatform parentPlatform = platformMapper.getParentPlatByServerGBId(sendRtpItem.getPlatformId()); |
|---|
| | | ssrcFactory.releaseSsrc(sendRtpItem.getMediaServerId(), sendRtpItem.getSsrc()); |
|---|
| | |
|---|
| | | // 如果zlm不存在这个流，则删除数据即可 |
|---|
| | | MediaServer mediaServerItemForStreamInfo = mediaServerService.getOne(inviteInfoForOld.getStreamInfo().getMediaServerId()); |
|---|
| | | if (mediaServerItemForStreamInfo != null) { |
|---|
| | | Boolean ready = zlmServerFactory.isStreamReady(mediaServerItemForStreamInfo, inviteInfoForOld.getStreamInfo().getApp(), inviteInfoForOld.getStreamInfo().getStream()); |
|---|
| | | Boolean ready = mediaServerService.isStreamReady(mediaServerItemForStreamInfo, inviteInfoForOld.getStreamInfo().getApp(), inviteInfoForOld.getStreamInfo().getStream()); |
|---|
| | | if (!ready) { |
|---|
| | | // 错误存在于redis中的数据 |
|---|
| | | inviteStreamService.removeInviteInfo(inviteInfoForOld); |
|---|
