| | |
|---|
| | | logger.info("[收到ACK]： 来自->{}", fromUserId); |
|---|
| | | SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(null, null, null, callIdHeader.getCallId()); |
|---|
| | | if (sendRtpItem == null) { |
|---|
| | | logger.warn("[收到ACK]：未找到来自{}，目标为({})的推流信息",fromUserId, toUserId); |
|---|
| | | logger.warn("[收到ACK]：未找到来自{}，callId: {}", fromUserId, callIdHeader.getCallId()); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | // tcp主动时，此时是级联下级平台，在回复200ok时，本地已经请求zlm开启监听，跳过下面步骤 |
|---|
| | |
|---|
| | | if (parentPlatform != null) { |
|---|
| | | Map<String, Object> param = getSendRtpParam(sendRtpItem); |
|---|
| | | if (!userSetting.getServerId().equals(sendRtpItem.getServerId())) { |
|---|
| | | WVPResult wvpResult = redisRpcService.startSendRtp(sendRtpItem); |
|---|
| | | WVPResult wvpResult = redisRpcService.startSendRtp(sendRtpItem.getRedisKey(), sendRtpItem); |
|---|
| | | if (wvpResult.getCode() == 0) { |
|---|
| | | MessageForPushChannel messageForPushChannel = MessageForPushChannel.getInstance(0, sendRtpItem.getApp(), sendRtpItem.getStream(), |
|---|
| | | sendRtpItem.getChannelId(), parentPlatform.getServerGBId(), parentPlatform.getName(), userSetting.getServerId(), |
|---|
