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

实时流重复请求则关闭上一次请求的实时流

Browse Source
This commit is contained in:
shikong 2024-01-30 10:22:43 +08:00
parent 512617bdb2
commit d799f10420
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java
View File

@ -404,6 +404,10 @@ public class DeviceProxyService {
@SneakyThrows @SneakyThrows
public void pullLiveStream2Rtp(SIPRequest request,Runnable sendOkResponse,String callId, MockingDevice device, String rtpAddr, int rtpPort, String ssrc){ public void pullLiveStream2Rtp(SIPRequest request,Runnable sendOkResponse,String callId, MockingDevice device, String rtpAddr, int rtpPort, String ssrc){
String liveCache = CacheUtil.getKey("INVITE", "LIVE", device.getGbDeviceId());
// 关闭已存在的实时流 bye 订阅（如果存在）
subscribe.getByeSubscribe().delPublisher(liveCache);
ScheduledFuture<?> schedule = trying(request); ScheduledFuture<?> schedule = trying(request);
Retryer<ZlmResponse<AddStreamProxyResp>> retryer = RetryerBuilder.<ZlmResponse<AddStreamProxyResp>>newBuilder() Retryer<ZlmResponse<AddStreamProxyResp>> retryer = RetryerBuilder.<ZlmResponse<AddStreamProxyResp>>newBuilder()
.retryIfResult(resp -> { .retryIfResult(resp -> {
@ -474,6 +478,8 @@ public class DeviceProxyService {
}); });
Flow.Subscriber<SIPRequest> subscriber = zlmByeSubscriber(key,request,device); Flow.Subscriber<SIPRequest> subscriber = zlmByeSubscriber(key,request,device);
liveCache = CacheUtil.getKey("INVITE", "LIVE", device.getGbDeviceId());
RedisUtil.StringOps.set(liveCache, key);
subscribe.getByeSubscribe().addPublisher(key); subscribe.getByeSubscribe().addPublisher(key);
subscribe.getByeSubscribe().addSubscribe(key, subscriber); subscribe.getByeSubscribe().addSubscribe(key, subscriber);
} catch (Exception e) { } catch (Exception e) {