From be90751ca6a4dcfb3340402907eba679b6ccb531 Mon Sep 17 00:00:00 2001 From: shikong <919411476@qq.com> Date: Wed, 7 Feb 2024 11:46:23 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gb28181/mocking/service/device/DeviceProxyService.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java index 5278d92..92773f0 100644 --- a/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java +++ b/gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/service/device/DeviceProxyService.java @@ -201,9 +201,10 @@ public class DeviceProxyService { ScheduledFuture schedule = trying(request); Flow.Subscriber task = ffmpegTask(request, downloadTask, callId, key, device); try { - String zlmRtpUrl = getZlmRtmpUrl(DEFAULT_ZLM_APP, callId); + //String zlmRtpUrl = getZlmRtmpUrl(DEFAULT_ZLM_APP, callId); + String rtpUrl = "rtp://" + toAddr + ":" + toPort; FfmpegExecuteResultHandler executeResultHandler = mediaStatus(schedule, request, device, key); - Executor executor = pushDownload2RtpTask(fromUrl, zlmRtpUrl, time + 60, executeResultHandler); + Executor executor = pushDownload2RtpTask(fromUrl, rtpUrl, time + 60, executeResultHandler); requestZlmPushStream(schedule, sendOkResponse, request, callId, fromUrl, toAddr, toPort, device, key, time, ssrc); scheduledExecutorService.schedule(task::onComplete, time + 60, TimeUnit.SECONDS); downloadTask.put(device.getDeviceCode(), executor);