Исправление SocketTimeoutException при загрузке больших файлов в Vaadin

// Переменная таймаута из getWriteTimeout() больше 30 секунд (по умолчанию 60)
// Но фактический таймаут происходит до достижения этого значения

# Эти настройки могут потребовать дополнительной конфигурации
proxy_buffering off;  # Отключить буферизацию для больших файлов
proxy_request_buffering off;
chunked_transfer_encoding on;

location /download/ {
    proxy_buffering off;
    proxy_request_buffering off;
    proxy_set_header Transfer-Encoding chunked;
    proxy_set_header Connection "keep-alive";
    
    # Сохраните существующие настройки таймаута
    send_timeout 300;
    proxy_connect_timeout 600;
    proxy_send_timeout 600;
    proxy_read_timeout 600;
}

StreamResource resource = new StreamResource(() -> {
    try {
        return new FileInputStream(file);
    } catch (FileNotFoundException e) {
        throw new RuntimeException("Файл не найден", e);
    }
}, filename);

resource.setMIMEType(contentType);
resource.setCacheTime(0); // Отключить кэширование для загрузок

StreamRegistration registration = ui.getSession().getResourceRegistry().registerResource(resource);
String resourceUrl = registration.getResourceUri().toString();

DownloadHandler downloadHandler = DownloadHandler.fromInputStream(downloadEvent -> {
    try (InputStream inputStream = new FileInputStream(file);
         OutputStream outputStream = downloadEvent.getOutputStream()) {
        
        byte[] buffer = new byte[8192]; // Буфер 8 КБ
        int bytesRead;
        long totalBytesRead = 0;
        
        while ((bytesRead = inputStream.read(buffer)) != -1) {
            outputStream.write(buffer, 0, bytesRead);
            totalBytesRead += bytesRead;
            
            // Периодически сбрасывать буфер для поддержания соединения
            if (totalBytesRead % (1024 * 1024) == 0) { // Сброс каждые 1 МБ
                outputStream.flush();
            }
        }
        
        return new DownloadResponse(outputStream, filename, contentType, file.length());
    } catch (IOException e) {
        throw new RuntimeException("Ошибка загрузки", e);
    }
});

// В вашем обработчике загрузки
VaadinResponse response = downloadEvent.getResponse();
response.setHeader("X-Content-Transfer-Idle-Timeout", "300");

// Проверьте, поддерживает ли браузер запросы с диапазоном
String rangeHeader = downloadEvent.getRequest().getHeader("Range");
if (rangeHeader != null) {
    // Разберите заголовок диапазона и отправьте частичное содержимое
    response.setStatus(HttpServletResponse.SC_PARTIAL_CONTENT);
}

@WebServlet("/download/*")
public class LargeFileDownloadServlet extends HttpServlet {
    protected void doGet(HttpServletRequest request, HttpServletResponse response) 
            throws ServletException, IOException {
        
        String fileName = request.getPathInfo().substring(1);
        File file = new File("/path/to/files", fileName);
        
        if (file.exists()) {
            response.setContentType(getServletContext().getMimeType(fileName));
            response.setHeader("Content-Disposition", 
                "attachment; filename=\"" + fileName + "\"");
            response.setContentLength((int) file.length());
            
            Files.copy(file.toPath(), response.getOutputStream());
        } else {
            response.sendError(HttpServletResponse.SC_NOT_FOUND);
        }
    }
}

@Async
public CompletableFuture<Void> downloadLargeFile(File file, String filename, 
        String contentType, HttpServletResponse response) {
    try (InputStream inputStream = new FileInputStream(file);
         OutputStream outputStream = response.getOutputStream()) {
        
        byte[] buffer = new byte[16384]; // Буфер 16 КБ
        int bytesRead;
        
        while ((bytesRead = inputStream.read(buffer)) != -1) {
            outputStream.write(buffer, 0, bytesRead);
            outputStream.flush();
        }
        
        return CompletableFuture.completedFuture(null);
    } catch (IOException e) {
        throw new CompletionException(e);
    }
}

server:
  tomcat:
    threads:
      max: 200
      min-spare: 10
    connection-timeout: 900000
    max-connections: 8192
    accept-count: 100
    max-http-post-size: 0 # Неограниченный размер POST
    max-swallow-size: 0 # Неограниченный размер тела запроса

response.setHeader("Connection", "keep-alive");
response.setHeader("Cache-Control", "no-cache, no-store, must-revalidate");
response.setHeader("Pragma", "no-cache");
response.setHeader("Expires", "0");
response.setHeader("X-Content-Type-Options", "nosniff");

// Проверьте наличие заголовка Range
String rangeHeader = request.getHeader("Range");
if (rangeHeader != null && rangeHeader.startsWith("bytes=")) {
    String[] ranges = rangeHeader.substring(6).split("-");
    long start = Long.parseLong(ranges[0]);
    long end = ranges.length > 1 ? Long.parseLong(ranges[1]) : file.length() - 1;
    
    response.setStatus(HttpServletResponse.SC_PARTIAL_CONTENT);
    response.setHeader("Content-Range", 
        "bytes " + start + "-" + end + "/" + file.length());
    response.setContentLength((int) (end - start + 1));
    
    // Перейдите к начальной позиции
    try (RandomAccessFile raf = new RandomAccessFile(file, "r")) {
        raf.seek(start);
        byte[] buffer = new byte[8192];
        long remaining = end - start + 1;
        
        while (remaining > 0) {
            int read = raf.read(buffer, 0, 
                (int) Math.min(buffer.length, remaining));
            outputStream.write(buffer, 0, read);
            remaining -= read;
        }
    }
}