From 310ec451fbe377c4668c0e71d45fc09a265a5dec Mon Sep 17 00:00:00 2001
From: shikong <919411476@qq.com>
Date: Thu, 7 Sep 2023 09:52:11 +0800
Subject: [PATCH] =?UTF-8?q?AsyncContext=20=E8=B6=85=E6=97=B6=E8=B0=83?=
 =?UTF-8?q?=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../docking/gb28181/wvp/service/video/RecordService.java  | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/video/RecordService.java b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/video/RecordService.java
index 699117e..b55b25c 100644
--- a/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/video/RecordService.java
+++ b/gb28181-wvp-proxy-service/src/main/java/cn/skcks/docking/gb28181/wvp/service/video/RecordService.java
@@ -2,7 +2,6 @@ package cn.skcks.docking.gb28181.wvp.service.video;
 
 import cn.hutool.core.io.IoUtil;
 import cn.hutool.core.util.IdUtil;
-import cn.skcks.docking.gb28181.wvp.executor.DefaultVideoExecutor;
 import jakarta.servlet.AsyncContext;
 import jakarta.servlet.ServletResponse;
 import jakarta.servlet.http.HttpServletRequest;
@@ -11,8 +10,10 @@ import lombok.SneakyThrows;
 import lombok.extern.slf4j.Slf4j;
 import org.bytedeco.ffmpeg.global.avcodec;
 import org.bytedeco.ffmpeg.global.avutil;
-import org.bytedeco.javacv.*;
-import org.springframework.scheduling.annotation.Async;
+import org.bytedeco.javacv.FFmpegFrameGrabber;
+import org.bytedeco.javacv.FFmpegFrameRecorder;
+import org.bytedeco.javacv.Frame;
+import org.bytedeco.javacv.FrameGrabber;
 import org.springframework.stereotype.Service;
 
 import java.io.*;
@@ -34,6 +35,7 @@ public class RecordService {
     @SneakyThrows
     public void record(HttpServletRequest request, HttpServletResponse response, String url, long timeout) {
         AsyncContext asyncContext = request.startAsync();
+        asyncContext.setTimeout(0);
         asyncContext.start(() -> {
             header(response);
             record(asyncContext.getResponse(), url, timeout);