| | |
|---|
| | | if (sendRtpItem.isTcpActive()) { |
|---|
| | | MediaServer mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | try { |
|---|
| | | mediaServerService.startSendRtpPassive(mediaServer, platform, sendRtpItem, 5); |
|---|
| | | mediaServerService.startSendRtpPassive(mediaServer, sendRtpItem, 5); |
|---|
| | | redisCatchStorage.sendPlatformStartPlayMsg(sendRtpItem, platform); |
|---|
| | | }catch (ControllerException e) {} |
|---|
| | | } |
|---|
| | | } catch (SipException | InvalidArgumentException | ParseException e) { |
|---|
| | |
|---|
| | | } |
|---|
| | | } else if ("proxy".equals(gbStream.getStreamType())) { |
|---|
| | | if (null != proxyByAppAndStream) { |
|---|
| | | sendRtpItem.setServerId(userSetting.getServerId()); |
|---|
| | | if (sendRtpItem.getSsrc() == null) { |
|---|
| | | // 上级平台点播时不使用上级平台指定的ssrc，使用自定义的ssrc，参考国标文档-点播外域设备媒体流SSRC处理方式 |
|---|
| | | String ssrc = "Play".equalsIgnoreCase(sessionName) ? ssrcFactory.getPlaySsrc(mediaServerItem.getId()) : ssrcFactory.getPlayBackSsrc(mediaServerItem.getId()); |
|---|
| | | sendRtpItem.setSsrc(ssrc); |
|---|
| | | } |
|---|
| | | if (proxyByAppAndStream.isStatus()) { |
|---|
| | | MediaInfo mediaInfo = redisCatchStorage.getProxyStream(gbStream.getApp(), gbStream.getStream()); |
|---|
| | | if (mediaInfo != null) { |
|---|
| | | sendProxyStream(sendRtpItem, mediaServerItem, platform, request); |
|---|
| | | } else { |
|---|
| | | //开启代理拉流 |
|---|
