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 2023-10-01 23:44:31 +08:00
parent 28d47f89b4
commit 69e9328392
2 changed files with 8 additions and 4 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/core/sip/message/processor/invite/request/InviteRequestProcessor.java
View File

@ -99,7 +99,9 @@ public class InviteRequestProcessor implements MessageProcessor {
if (StringUtils.equalsAnyIgnoreCase(type, "Play", "PlayBack")) {
log.info("点播/回放请求");
if (StringUtils.equalsIgnoreCase(type, "Play")) {
play(request, device, gb28181Description, (MediaDescription) item);
// 暂不支持实时
sender.sendResponse(senderIp, transport, unsupported(request));
// play(request, device, gb28181Description, (MediaDescription) item);
} else {
playback(request, device, gb28181Description, (MediaDescription) item);
}
@ -138,7 +140,7 @@ public class InviteRequestProcessor implements MessageProcessor {
@SneakyThrows
private void play(SIPRequest request, MockingDevice device, GB28181Description gb28181Description, MediaDescription mediaDescription) {
TimeField time = new TimeField();
time.setStart(DateUtil.offsetMinute(DateUtil.date(), -15));
time.setStart(DateUtil.offsetMinute(DateUtil.date(), -5));
time.setStop(DateUtil.date());
playback(request, device, gb28181Description, mediaDescription, time);
}

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

@ -79,7 +79,8 @@ public class DeviceProxyService {
});
Flow.Subscriber<SIPRequest> subscriber = byeSubscriber(key, device, callbackTask);
subscribe.getByeSubscribe().addSubscribe(key, subscriber);
taskNum.getAndIncrement();
int num = taskNum.getAndIncrement();
log.info("当前任务数 {}", num);
zlmStreamChangeHookService.handlerMap.put(key,()->{
StartSendRtp startSendRtp = new StartSendRtp();
startSendRtp.setApp("rtp");
@ -111,7 +112,8 @@ public class DeviceProxyService {
});
Flow.Subscriber<SIPRequest> subscriber = byeSubscriber(key, device, downloadTask);
subscribe.getByeSubscribe().addSubscribe(key, subscriber);
taskNum.getAndIncrement();
int num = taskNum.getAndIncrement();
log.info("当前任务数 {}", num);
zlmStreamChangeHookService.handlerMap.put(key,()->{
StartSendRtp startSendRtp = new StartSendRtp();
startSendRtp.setApp("rtp");