| | |
| | | import com.alibaba.fastjson2.JSONObject; |
| | | import com.genersoft.iot.vmp.common.VideoManagerConstants; |
| | | import com.genersoft.iot.vmp.conf.DynamicTask; |
| | | import com.genersoft.iot.vmp.conf.SipConfig; |
| | | import com.genersoft.iot.vmp.conf.UserSetting; |
| | | import com.genersoft.iot.vmp.conf.VersionInfo; |
| | | import com.genersoft.iot.vmp.conf.exception.ControllerException; |
| | | import com.genersoft.iot.vmp.media.zlm.SendRtpPortManager; |
| | | import com.genersoft.iot.vmp.media.zlm.ZLMServerFactory; |
| | | import com.genersoft.iot.vmp.media.zlm.SendRtpPortManager; |
| | | import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory; |
| | | import com.genersoft.iot.vmp.media.zlm.ZlmHttpHookSubscribe; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeFactory; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeForRtpServerTimeout; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.HookSubscribeForStreamChange; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.hook.OnRtpServerTimeoutHookParam; |
| | | import com.genersoft.iot.vmp.service.IDeviceChannelService; |
| | | import com.genersoft.iot.vmp.service.IDeviceService; |
| | | import com.genersoft.iot.vmp.service.IMediaServerService; |
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
| | | import com.genersoft.iot.vmp.utils.redis.RedisUtil; |
| | | import com.genersoft.iot.vmp.vmanager.bean.ErrorCode; |
| | | import com.genersoft.iot.vmp.vmanager.bean.OtherRtpSendInfo; |
| | | import io.swagger.v3.oas.annotations.Operation; |
| | |
| | | import org.slf4j.Logger; |
| | | import org.slf4j.LoggerFactory; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.data.redis.core.RedisTemplate; |
| | | import org.springframework.util.ObjectUtils; |
| | | import org.springframework.web.bind.annotation.*; |
| | | |
| | | import java.io.IOException; |
| | | import java.util.HashMap; |
| | | import java.util.List; |
| | | import java.util.Map; |
| | | import java.util.UUID; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.concurrent.TimeUnit; |
| | | |
| | | @SuppressWarnings("rawtypes") |
| | |
| | | private IMediaServerService mediaServerService; |
| | | |
| | | @Autowired |
| | | private VersionInfo versionInfo; |
| | | |
| | | @Autowired |
| | | private SipConfig sipConfig; |
| | | private SendRtpPortManager sendRtpPortManager; |
| | | |
| | | @Autowired |
| | | private UserSetting userSetting; |
| | | |
| | | @Autowired |
| | | private IDeviceService deviceService; |
| | | |
| | | @Autowired |
| | | private IDeviceChannelService channelService; |
| | | |
| | | @Autowired |
| | | private DynamicTask dynamicTask; |
| | |
| | | |
| | | @Autowired |
| | | private RedisTemplate<Object, Object> redisTemplate; |
| | | |
| | | |
| | | @Value("${server.port}") |
| | | private int serverPort; |
| | | |
| | | |
| | | @Autowired |
| | | private IRedisCatchStorage redisCatchStorage; |
| | | |
| | | |
| | | @GetMapping(value = "/receive/open") |
| | |
| | | }catch (NumberFormatException e) { |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(),"ssrcæ ¼å¼é误"); |
| | | } |
| | | |
| | | } |
| | | int localPort = zlmServerFactory.createRTPServer(mediaServerItem, stream, ssrcInt, null, false, tcpMode); |
| | | String receiveKey = VideoManagerConstants.WVP_OTHER_RECEIVE_RTP_INFO + userSetting.getServerId() + "_" + callId + "_" + stream; |
| | | int localPortForVideo = zlmServerFactory.createRTPServer(mediaServerItem, stream, ssrcInt, null, false, tcpMode); |
| | | int localPortForAudio = zlmServerFactory.createRTPServer(mediaServerItem, stream + "_a" , ssrcInt, null, false, tcpMode); |
| | | if (localPortForVideo == 0 || localPortForAudio == 0) { |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "è·å端å£å¤±è´¥"); |
| | | } |
| | | // 注ååè°å¦ærtpæ¶æµè¶
æ¶åéè¿åè°åééç¥ |
| | | if (callBack != null) { |
| | | HookSubscribeForRtpServerTimeout hookSubscribeForRtpServerTimeout = HookSubscribeFactory.on_rtp_server_timeout(ssrc, null, mediaServerItem.getId()); |
| | | HookSubscribeForRtpServerTimeout hookSubscribeForRtpServerTimeout = HookSubscribeFactory.on_rtp_server_timeout(stream, String.valueOf(ssrcInt), mediaServerItem.getId()); |
| | | // 订é
zlmå¯å¨äºä»¶, æ°çzlmä¹ä¼ä»è¿éè¿å
¥ç³»ç» |
| | | hookSubscribe.addSubscribe(hookSubscribeForRtpServerTimeout, |
| | | (mediaServerItemInUse, hookParam)->{ |
| | |
| | | try { |
| | | client.newCall(request).execute(); |
| | | } catch (IOException e) { |
| | | logger.error("[å¼å¯æ¶æµåè·ååæµä¿¡æ¯] çå¾
æ¶æµè¶
æ¶ callId->{}, åéåè°å¤±è´¥", callId, e); |
| | | logger.error("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->å¼å¯æ¶æµåè·ååæµä¿¡æ¯] çå¾
æ¶æµè¶
æ¶ callId->{}, åéåè°å¤±è´¥", callId, e); |
| | | } |
| | | hookSubscribe.removeSubscribe(hookSubscribeForRtpServerTimeout); |
| | | } |
| | | }); |
| | | } |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + callId; |
| | | OtherRtpSendInfo otherRtpSendInfo = new OtherRtpSendInfo(); |
| | | otherRtpSendInfo.setReceiveIp(mediaServerItem.getSdpIp()); |
| | | otherRtpSendInfo.setReceivePort(localPort); |
| | | otherRtpSendInfo.setReceivePortForVideo(localPortForVideo); |
| | | otherRtpSendInfo.setReceivePortForAudio(localPortForAudio); |
| | | otherRtpSendInfo.setCallId(callId); |
| | | otherRtpSendInfo.setStream(stream); |
| | | |
| | | // å°ä¿¡æ¯åå
¥redisä¸ï¼ä»¥å¤åç¨ |
| | | redisTemplate.opsForValue().set(receiveKey, otherRtpSendInfo); |
| | | if (isSend != null && isSend) { |
| | | int port = sendRtpPortManager.getNextPort(mediaServerItem.getId()); |
| | | otherRtpSendInfo.setIp(mediaServerItem.getSdpIp()); |
| | | otherRtpSendInfo.setPort(port); |
| | | logger.info("[å¼å¯æ¶æµåè·ååæµä¿¡æ¯] ç»æï¼callId->{}ï¼ {}", callId, otherRtpSendInfo); |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + "_" + callId; |
| | | // é¢åå»ºåæµä¿¡æ¯ |
| | | int portForVideo = sendRtpPortManager.getNextPort(mediaServerItem.getId()); |
| | | int portForAudio = sendRtpPortManager.getNextPort(mediaServerItem.getId()); |
| | | // å°ä¿¡æ¯åå
¥redisä¸ï¼ä»¥å¤åç¨ |
| | | redisTemplate.opsForValue().set(key, otherRtpSendInfo, 300, TimeUnit.SECONDS); |
| | | otherRtpSendInfo.setSendLocalIp(mediaServerItem.getSdpIp()); |
| | | otherRtpSendInfo.setSendLocalPortForVideo(portForVideo); |
| | | otherRtpSendInfo.setSendLocalPortForAudio(portForAudio); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->å¼å¯æ¶æµåè·ååæµä¿¡æ¯] ç»æï¼callId->{}ï¼ {}", callId, otherRtpSendInfo); |
| | | } |
| | | // å°ä¿¡æ¯åå
¥redisä¸ï¼ä»¥å¤åç¨ |
| | | redisTemplate.opsForValue().set(key, otherRtpSendInfo, 300, TimeUnit.SECONDS); |
| | |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->å
³éæ¶æµ] stream->{}", stream); |
| | | MediaServerItem mediaServerItem = mediaServerService.getDefaultMediaServer(); |
| | | zlmServerFactory.closeRtpServer(mediaServerItem,stream); |
| | | zlmServerFactory.closeRtpServer(mediaServerItem,stream + "_a"); |
| | | String receiveKey = VideoManagerConstants.WVP_OTHER_RECEIVE_RTP_INFO + userSetting.getServerId() + "_*_" + stream; |
| | | List<Object> scan = RedisUtil.scan(redisTemplate, receiveKey); |
| | | if (scan.size() > 0) { |
| | | for (Object key : scan) { |
| | | // å°ä¿¡æ¯åå
¥redisä¸ï¼ä»¥å¤åç¨ |
| | | redisTemplate.delete(key); |
| | | } |
| | | } |
| | | } |
| | | |
| | | @GetMapping(value = "/send/start") |
| | | @ResponseBody |
| | | @Operation(summary = "åéæµ") |
| | | @Parameter(name = "ssrc", description = "åéæµçSSRC", required = true) |
| | | @Parameter(name = "ip", description = "ç®æ IP", required = true) |
| | | @Parameter(name = "port", description = "ç®æ 端å£", required = true) |
| | | @Parameter(name = "dstIpForAudio", description = "ç®æ é³é¢æ¶æµIP", required = false) |
| | | @Parameter(name = "dstIpForVideo", description = "ç®æ è§é¢æ¶æµIP", required = false) |
| | | @Parameter(name = "dstPortForAudio", description = "ç®æ é³é¢æ¶æµç«¯å£", required = false) |
| | | @Parameter(name = "dstPortForVideo", description = "ç®æ è§é¢æ¶æµç«¯å£", required = false) |
| | | @Parameter(name = "app", description = "å¾
åéåºç¨å", required = true) |
| | | @Parameter(name = "stream", description = "å¾
åéæµId", required = true) |
| | | @Parameter(name = "callId", description = "æ´ä¸ªè¿ç¨çå¯ä¸æ è¯ï¼ä¸ä¼ å使ç¨éæºç«¯å£åæµ", required = true) |
| | | @Parameter(name = "onlyAudio", description = "æ¯å¦åªæé³é¢", required = true) |
| | | @Parameter(name = "isUdp", description = "æ¯å¦ä¸ºUDP", required = true) |
| | | @Parameter(name = "streamType", description = "æµç±»åï¼1为esæµï¼2为psæµï¼ é»è®¤esæµ", required = false) |
| | | public void sendRTP(String ssrc, String ip, Integer port, String app, String stream, String callId, Boolean onlyAudio, Boolean isUdp, @RequestParam(required = false)Integer streamType) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] ssrc->{}, ip->{}, port->{}, app->{}, stream->{}, callId->{}, onlyAudio->{}, streamType->{}", |
| | | ssrc, ip, port, app, stream, callId, onlyAudio, streamType == 1? "ES":"PS"); |
| | | if (ObjectUtils.isEmpty(streamType)) { |
| | | streamType = 1; |
| | | @Parameter(name = "ptForAudio", description = "rtpçé³é¢pt", required = false) |
| | | @Parameter(name = "ptForVideo", description = "rtpçè§é¢pt", required = false) |
| | | public void sendRTP(String ssrc, |
| | | @RequestParam(required = false)String dstIpForAudio, |
| | | @RequestParam(required = false)String dstIpForVideo, |
| | | @RequestParam(required = false)Integer dstPortForAudio, |
| | | @RequestParam(required = false)Integer dstPortForVideo, |
| | | String app, |
| | | String stream, |
| | | String callId, |
| | | Boolean isUdp, |
| | | @RequestParam(required = false)Integer ptForAudio, |
| | | @RequestParam(required = false)Integer ptForVideo |
| | | ) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] " + |
| | | "ssrc->{}, \r\n" + |
| | | "dstIpForAudio->{}, \n" + |
| | | "dstIpForAudio->{}, \n" + |
| | | "dstPortForAudio->{}, \n" + |
| | | "dstPortForVideo->{}, \n" + |
| | | "app->{}, \n" + |
| | | "stream->{}, \n" + |
| | | "callId->{}, \n" + |
| | | "ptForAudio->{}, \n" + |
| | | "ptForVideo->{}", |
| | | ssrc, |
| | | dstIpForAudio, |
| | | dstIpForVideo, |
| | | dstPortForAudio, |
| | | dstPortForVideo, |
| | | app, |
| | | stream, |
| | | callId, |
| | | ptForAudio, |
| | | ptForVideo); |
| | | if (!((dstPortForAudio > 0 && !ObjectUtils.isEmpty(dstPortForAudio) || (dstPortForVideo > 0 && !ObjectUtils.isEmpty(dstIpForVideo))))) { |
| | | throw new ControllerException(ErrorCode.ERROR400.getCode(), "è³å°åºè¯¥åå¨ä¸ç»é³é¢æè§é¢åéåæ°"); |
| | | } |
| | | MediaServerItem mediaServerItem = mediaServerService.getDefaultMediaServer(); |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + callId; |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + "_" + callId; |
| | | OtherRtpSendInfo sendInfo = (OtherRtpSendInfo)redisTemplate.opsForValue().get(key); |
| | | if (sendInfo == null) { |
| | | sendInfo = new OtherRtpSendInfo(); |
| | |
| | | sendInfo.setPushStream(stream); |
| | | sendInfo.setPushSSRC(ssrc); |
| | | |
| | | Map<String, Object> param = new HashMap<>(12); |
| | | param.put("vhost","__defaultVhost__"); |
| | | param.put("app",app); |
| | | param.put("stream",stream); |
| | | param.put("ssrc", ssrc); |
| | | Map<String, Object> paramForAudio; |
| | | Map<String, Object> paramForVideo; |
| | | if (!ObjectUtils.isEmpty(dstIpForAudio) && dstPortForAudio > 0) { |
| | | paramForAudio = new HashMap<>(); |
| | | paramForAudio.put("vhost","__defaultVhost__"); |
| | | paramForAudio.put("app",app); |
| | | paramForAudio.put("stream",stream); |
| | | paramForAudio.put("ssrc", ssrc); |
| | | |
| | | param.put("dst_url",ip); |
| | | param.put("dst_port", port); |
| | | paramForAudio.put("dst_url", dstIpForAudio); |
| | | paramForAudio.put("dst_port", dstPortForAudio); |
| | | String is_Udp = isUdp ? "1" : "0"; |
| | | param.put("is_udp", is_Udp); |
| | | param.put("src_port", sendInfo.getPort()); |
| | | param.put("use_ps", streamType==2 ? "1" : "0"); |
| | | param.put("only_audio", onlyAudio ? "1" : "0"); |
| | | paramForAudio.put("is_udp", is_Udp); |
| | | paramForAudio.put("src_port", sendInfo.getSendLocalPortForAudio()); |
| | | paramForAudio.put("use_ps", "0"); |
| | | paramForAudio.put("only_audio", "1"); |
| | | if (ptForAudio != null) { |
| | | paramForAudio.put("pt", ptForAudio); |
| | | } |
| | | |
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaServerItem, param); |
| | | } else { |
| | | paramForAudio = null; |
| | | } |
| | | if (!ObjectUtils.isEmpty(dstIpForVideo) && dstPortForVideo > 0) { |
| | | paramForVideo = new HashMap<>(); |
| | | paramForVideo.put("vhost","__defaultVhost__"); |
| | | paramForVideo.put("app",app); |
| | | paramForVideo.put("stream",stream); |
| | | paramForVideo.put("ssrc", ssrc); |
| | | |
| | | paramForVideo.put("dst_url", dstIpForVideo); |
| | | paramForVideo.put("dst_port", dstPortForVideo); |
| | | String is_Udp = isUdp ? "1" : "0"; |
| | | paramForVideo.put("is_udp", is_Udp); |
| | | paramForVideo.put("src_port", sendInfo.getSendLocalPortForVideo()); |
| | | paramForVideo.put("use_ps", "0"); |
| | | paramForVideo.put("only_audio", "0"); |
| | | if (ptForVideo != null) { |
| | | paramForVideo.put("pt", ptForVideo); |
| | | } |
| | | |
| | | } else { |
| | | paramForVideo = null; |
| | | } |
| | | |
| | | Boolean streamReady = zlmServerFactory.isStreamReady(mediaServerItem, app, stream); |
| | | if (streamReady) { |
| | | if (paramForVideo != null) { |
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaServerItem, paramForVideo); |
| | | if (jsonObject.getInteger("code") == 0) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] åæµæåï¼callId->{}", callId); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] è§é¢æµåæµæåï¼callId->{}ï¼param->{}", callId, paramForVideo); |
| | | redisTemplate.opsForValue().set(key, sendInfo); |
| | | }else { |
| | | redisTemplate.delete(key); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] åæµå¤±è´¥ï¼callId->{}, {}", callId, jsonObject.getString("msg")); |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "[åæµå¤±è´¥] " + jsonObject.getString("msg")); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] è§é¢æµåæµå¤±è´¥ï¼callId->{}, {}", callId, jsonObject.getString("msg")); |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "[è§é¢æµåæµå¤±è´¥] " + jsonObject.getString("msg")); |
| | | } |
| | | } |
| | | if(paramForAudio != null) { |
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaServerItem, paramForAudio); |
| | | if (jsonObject.getInteger("code") == 0) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] é³é¢æµåæµæåï¼callId->{}ï¼param->{}", callId, paramForAudio); |
| | | redisTemplate.opsForValue().set(key, sendInfo); |
| | | }else { |
| | | redisTemplate.delete(key); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] é³é¢æµåæµå¤±è´¥ï¼callId->{}, {}", callId, jsonObject.getString("msg")); |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "[é³é¢æµåæµå¤±è´¥] " + jsonObject.getString("msg")); |
| | | } |
| | | } |
| | | }else { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] æµä¸åå¨ï¼çå¾
æµä¸çº¿ï¼callId->{}", callId); |
| | | String uuid = UUID.randomUUID().toString(); |
| | | HookSubscribeForStreamChange hookSubscribeForStreamChange = HookSubscribeFactory.on_stream_changed(app, stream, true, "rtsp", mediaServerItem.getId()); |
| | | dynamicTask.startDelay(uuid, ()->{ |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] çå¾
æµä¸çº¿è¶
æ¶ callId->{}", callId); |
| | | redisTemplate.delete(key); |
| | | hookSubscribe.removeSubscribe(hookSubscribeForStreamChange); |
| | | }, 10000); |
| | | |
| | | |
| | | // 订é
zlmå¯å¨äºä»¶, æ°çzlmä¹ä¼ä»è¿éè¿å
¥ç³»ç» |
| | | OtherRtpSendInfo finalSendInfo = sendInfo; |
| | | hookSubscribe.removeSubscribe(hookSubscribeForStreamChange); |
| | | hookSubscribe.addSubscribe(hookSubscribeForStreamChange, |
| | | (mediaServerItemInUse, response)->{ |
| | | dynamicTask.stop(uuid); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] æµä¸çº¿ï¼å¼å§åæµ callId->{}", callId); |
| | | try { |
| | | Thread.sleep(400); |
| | | } catch (InterruptedException e) { |
| | | throw new RuntimeException(e); |
| | | } |
| | | if (paramForVideo != null) { |
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaServerItem, paramForVideo); |
| | | if (jsonObject.getInteger("code") == 0) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] è§é¢æµåæµæåï¼callId->{}ï¼param->{}", callId, paramForVideo); |
| | | redisTemplate.opsForValue().set(key, finalSendInfo); |
| | | }else { |
| | | redisTemplate.delete(key); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] è§é¢æµåæµå¤±è´¥ï¼callId->{}, {}", callId, jsonObject.getString("msg")); |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "[è§é¢æµåæµå¤±è´¥] " + jsonObject.getString("msg")); |
| | | } |
| | | } |
| | | if(paramForAudio != null) { |
| | | JSONObject jsonObject = zlmServerFactory.startSendRtpStream(mediaServerItem, paramForAudio); |
| | | if (jsonObject.getInteger("code") == 0) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] é³é¢æµåæµæåï¼callId->{}ï¼param->{}", callId, paramForAudio); |
| | | redisTemplate.opsForValue().set(key, finalSendInfo); |
| | | }else { |
| | | redisTemplate.delete(key); |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->åéæµ] é³é¢æµåæµå¤±è´¥ï¼callId->{}, {}", callId, jsonObject.getString("msg")); |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "[é³é¢æµåæµå¤±è´¥] " + jsonObject.getString("msg")); |
| | | } |
| | | } |
| | | hookSubscribe.removeSubscribe(hookSubscribeForStreamChange); |
| | | }); |
| | | } |
| | | } |
| | | |
| | | @GetMapping(value = "/send/stop") |
| | | @ResponseBody |
| | |
| | | @Parameter(name = "callId", description = "æ´ä¸ªè¿ç¨çå¯ä¸æ è¯ï¼ä¸ä¼ å使ç¨éæºç«¯å£åæµ", required = true) |
| | | public void closeSendRTP(String callId) { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->å
³éåéæµ] callId->{}", callId); |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + callId; |
| | | String key = VideoManagerConstants.WVP_OTHER_SEND_RTP_INFO + userSetting.getServerId() + "_" + callId; |
| | | OtherRtpSendInfo sendInfo = (OtherRtpSendInfo)redisTemplate.opsForValue().get(key); |
| | | if (sendInfo == null){ |
| | | throw new ControllerException(ErrorCode.ERROR100.getCode(), "æªå¼å¯åæµ"); |
| | |
| | | }else { |
| | | logger.info("[ç¬¬ä¸æ¹æå¡å¯¹æ¥->å
³éåéæµ] æå callId->{}", callId); |
| | | } |
| | | redisTemplate.delete(key); |
| | | } |
| | | |
| | | } |