| | |
|---|
| | | |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public SSRCInfo play(MediaServerItem mediaServerItem, String deviceId, String channelId, ErrorCallback<Object> callback) { |
|---|
| | | public SSRCInfo play(MediaServerItem mediaServerItem, String deviceId, String channelId, String ssrc, ErrorCallback<Object> callback) { |
|---|
| | | if (mediaServerItem == null) { |
|---|
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "未找到可用的zlm"); |
|---|
| | | } |
|---|
| | |
|---|
| | | if (mediaServerItem.isRtpEnable()) { |
|---|
| | | streamId = String.format("%s_%s", device.getDeviceId(), channelId); |
|---|
| | | } |
|---|
| | | SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, streamId, null, device.isSsrcCheck(), false, 0, false, device.getStreamModeForParam()); |
|---|
| | | SSRCInfo ssrcInfo = mediaServerService.openRTPServer(mediaServerItem, streamId, ssrc, device.isSsrcCheck(), false, 0, false, device.getStreamModeForParam()); |
|---|
| | | if (ssrcInfo == null) { |
|---|
| | | callback.run(InviteErrorCode.ERROR_FOR_RESOURCE_EXHAUSTION.getCode(), InviteErrorCode.ERROR_FOR_RESOURCE_EXHAUSTION.getMsg(), null); |
|---|
| | | inviteStreamService.call(InviteSessionType.PLAY, device.getDeviceId(), channelId, null, |
|---|
| | |
|---|
| | | InviteErrorCode.SUCCESS.getCode(), |
|---|
| | | InviteErrorCode.SUCCESS.getMsg(), |
|---|
| | | streamInfo); |
|---|
| | | logger.info("[点播成功] deviceId: {}, channelId:{}, 码流类型：{}", device.getDeviceId(), |
|---|
| | | logger.info("[点播成功] deviceId: {}, channelId:{}, 码流类型：{}", device.getDeviceId(), channelId, |
|---|
| | | device.isSwitchPrimarySubStream() ? "辅码流" : "主码流"); |
|---|
| | | snapOnPlay(mediaServerItemInuse, device.getDeviceId(), channelId, ssrcInfo.getStream()); |
|---|
| | | }, (event) -> { |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | MediaServerItem newMediaServerItem = getNewMediaServerItem(device); |
|---|
| | | play(newMediaServerItem, deviceId, channelId, (code, msg, data)->{ |
|---|
| | | play(newMediaServerItem, deviceId, channelId, null, (code, msg, data)->{ |
|---|
| | | if (code == InviteErrorCode.SUCCESS.getCode()) { |
|---|
| | | InviteInfo inviteInfoForPlay = inviteStreamService.getInviteInfoByDeviceAndChannel(InviteSessionType.PLAY, deviceId, channelId); |
|---|
| | | if (inviteInfoForPlay != null && inviteInfoForPlay.getStreamInfo() != null) { |
|---|
