| | |
|---|
| | | private RedisTemplate<Object, Object> redisTemplate; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private ZLMServerFactory ZLMServerFactory; |
|---|
| | | private ZLMServerFactory zlmServerFactory; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private IMediaServerService mediaServerService; |
|---|
| | |
|---|
| | | param.put("pt", requestPushStreamMsg.getPt()); |
|---|
| | | param.put("use_ps", requestPushStreamMsg.isPs() ? "1" : "0"); |
|---|
| | | param.put("only_audio", requestPushStreamMsg.isOnlyAudio() ? "1" : "0"); |
|---|
| | | JSONObject jsonObject = ZLMServerFactory.startSendRtpStream(mediaInfo, param); |
|---|
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaInfo, param); |
|---|
| | | // 回复消息 |
|---|
| | | responsePushStream(jsonObject, fromId, serial); |
|---|
| | | } |
|---|
| | |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // 确定流是否在线 |
|---|
| | | Boolean streamReady = ZLMServerFactory.isStreamReady(mediaServerItem, content.getApp(), content.getStream()); |
|---|
| | | Boolean streamReady = zlmServerFactory.isStreamReady(mediaServerItem, content.getApp(), content.getStream()); |
|---|
| | | if (streamReady != null && streamReady) { |
|---|
| | | logger.info("[回复推流信息] {}/{}", content.getApp(), content.getStream()); |
|---|
| | | responseSendItem(mediaServerItem, content, toId, serial); |
|---|
| | |
|---|
| | | * 将获取到的sendItem发送出去 |
|---|
| | | */ |
|---|
| | | private void responseSendItem(MediaServerItem mediaServerItem, RequestSendItemMsg content, String toId, String serial) { |
|---|
| | | SendRtpItem sendRtpItem = ZLMServerFactory.createSendRtpItem(mediaServerItem, content.getIp(), |
|---|
| | | SendRtpItem sendRtpItem = zlmServerFactory.createSendRtpItem(mediaServerItem, content.getIp(), |
|---|
| | | content.getPort(), content.getSsrc(), content.getPlatformId(), |
|---|
| | | content.getApp(), content.getStream(), content.getChannelId(), |
|---|
| | | content.getTcp(), content.getRtcp()); |
|---|
