Shikong/gb28181-docking-platform-proxy
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

调整

Browse Source
This commit is contained in:
shikong 2023-10-17 19:56:40 +08:00
parent c1655bdeb5
commit d7837a1975
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/gb28181/Gb28181DownloadService.java
View File

@ -189,7 +189,7 @@ public class Gb28181DownloadService {
String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId()); String cacheKey = CacheUtil.getKey(docking.getGbDeviceId(), device.getGbDeviceChannelId());
String existCallId = RedisUtil.StringOps.get(cacheKey); String existCallId = RedisUtil.StringOps.get(cacheKey);
scheduledExecutorService.schedule(()->{ scheduledExecutorService.schedule(()->{
log.info("到达结束时间 发送 bye 关闭"); log.info("到达结束时间 发送 bye 关闭 {} {}", videoInfo.getDevice(), videoInfo.getCallId());
String deviceIp = docking.getIp(); String deviceIp = docking.getIp();
int devicePort = Integer.parseInt(docking.getPort()); int devicePort = Integer.parseInt(docking.getPort());
sender.sendRequest((provider,localIp,localPort)-> sender.sendRequest((provider,localIp,localPort)->
@ -326,7 +326,7 @@ public class Gb28181DownloadService {
sender.sendRequest((provider,localIp,localPort)-> sender.sendRequest((provider,localIp,localPort)->
SipRequestBuilder.createByeRequest(deviceIp, devicePort, device.getGbDeviceChannelId(), SipUtil.generateFromTag(), null, existCallId)); SipRequestBuilder.createByeRequest(deviceIp, devicePort, device.getGbDeviceChannelId(), SipUtil.generateFromTag(), null, existCallId));
RedisUtil.KeyOps.delete(cacheKey); RedisUtil.KeyOps.delete(cacheKey);
log.info("关闭已存在的 点播请求 {} {}", cacheKey,existCallId); log.info("关闭已存在的 点播请求 {} {}", cacheKey, existCallId);
Thread.sleep(500); Thread.sleep(500);
} }