java 文件下载Resource和StreamingResponseBody的区别

首先，Resource在Spring框架中通常指的是org.springframework.core.io.Resource，它用于抽象文件资源，比如从类路径、文件系统或URL加载资源。而StreamingResponseBody是Spring MVC中的一个接口，用于流式传输响应体，允许分块发送数据，避免将整个内容加载到内存中。

Resource在下载大文件时，通常是一次性将整个文件内容加载到内存中，然后通过响应输出流发送。如果文件很大，比如超过200兆，但用户的网络请求最大设置为200兆，可能刚好在100兆左右出现问题，这可能是因为内存不足或者处理大文件时的一些限制。例如，当使用Resource作为响应体时，Spring可能会尝试将整个文件内容读入内存，导致内存溢出或请求超时，尤其是在处理接近200兆的文件时，可能刚好触发某些限制。

而StreamingResponseBody则是分块发送数据，逐块写入响应输出流，不需要一次性将整个文件加载到内存中。这样即使文件很大，也能逐步传输，减少内存压力，避免一次性加载导致的性能问题或内存溢出。因此，当文件超过一定大小时，使用StreamingResponseBody会更可靠，因为它避免了内存瓶颈。

另外，可能用户的网络请求设置虽然最大为200兆，但使用Resource时，在传输过程中可能因为某些配置（如Tomcat的max-swallow-size或连接超时设置）导致大文件传输失败。而StreamingResponseBody通过流式处理，可能更有效地管理这些限制，或者分块传输机制更符合服务器的处理能力。

总结来说，Resource适合小文件，一次性加载到内存处理；而StreamingResponseBody适合大文件，流式传输，减少内存占用。用户遇到的大文件下载失败问题，可能是因为Resource方式导致内存不足或请求超时，而流式处理解决了这个问题。

Resource示例

@GetMapping("/download-resource")
public ResponseEntity<Resource> downloadResource() throws IOException {
    Resource resource = new FileSystemResource("/path/to/file.zip");
    return ResponseEntity.ok()
        .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=file.zip")
        .body(resource);
}

StreamingResponseBody示例

@GetMapping("/download-stream")
public StreamingResponseBody downloadStream() {
    Path filePath = Paths.get("/path/to/large-file.zip");
    return outputStream -> {
        try (InputStream inputStream = Files.newInputStream(filePath)) {
            byte[] buffer = new byte[4096]; // 4KB缓冲区
            int bytesRead;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
            }
        }
    };
}

InputStreamStreamer工具类

import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class InputStreamStreamer implements StreamingResponseBody {

    private final InputStream inputStream;

    public InputStreamStreamer(InputStream inputStream) {
        this.inputStream = inputStream;
    }

    @Override
    public void writeTo(OutputStream outputStream) throws IOException {
        byte[] buffer = new byte[8192]; // 8KB 缓冲区
        int bytesRead;
        try {
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                outputStream.write(buffer, 0, bytesRead);
                outputStream.flush(); // 确保及时发送数据
            }
        } finally {
            try {
                inputStream.close(); // 确保流被关闭
            } catch (IOException e) {
                // 处理关闭异常（如记录日志）
            }
        }
    }
}

import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.io.InputStream;

@RestController
public class DataStreamController {

    @GetMapping("/stream-data")
    public ResponseEntity<StreamingResponseBody> streamData() throws IOException {
        // 示例：从数据库或网络资源获取 InputStream
        InputStream inputStream = getInputStreamFromSource(); 

        return ResponseEntity.ok()
                .contentType("application/octet-stream")
                .body(new InputStreamStreamer(inputStream));
    }

    private InputStream getInputStreamFromSource() {
        // 实际场景中替换为真实数据源（如 JDBC BLOB、HTTP 客户端响应等）
        return getClass().getResourceAsStream("/example.txt"); // 示例：从类路径加载
    }
}

扩展场景：从文件路径获取 InputStream

// 通用 Streamer 接口
public interface DataStreamer extends StreamingResponseBody {
    void writeTo(OutputStream outputStream) throws IOException;
}

// 文件路径实现
public class FilePathStreamer implements DataStreamer {
    private final Path filePath;

    public FilePathStreamer(Path filePath) {
        this.filePath = filePath;
    }

    @Override
    public void writeTo(OutputStream outputStream) throws IOException {
        try (InputStream is = Files.newInputStream(filePath)) {
            // 写入逻辑
        }
    }
}

// InputStream 实现
public class InputStreamStreamer implements DataStreamer {
    private final InputStream inputStream;

    public InputStreamStreamer(InputStream inputStream) {
        this.inputStream = inputStream;
    }

    @Override
    public void writeTo(OutputStream outputStream) throws IOException {
        // 写入逻辑（同上）
    }
}

// Controller 中根据场景选择
@GetMapping("/download-file")
public ResponseEntity<DataStreamer> downloadFile() {
    Path filePath = Paths.get("/path/to/file.zip");
    return ResponseEntity.ok()
            .body(new FilePathStreamer(filePath));
}

@GetMapping("/stream-db-data")
public ResponseEntity<DataStreamer> streamDatabaseData() throws IOException {
    InputStream dbStream = getDatabaseStream();
    return ResponseEntity.ok()
            .body(new InputStreamStreamer(dbStream));
}

java 文件下载Resource和StreamingResponseBody的区别

推荐阅读更多精彩内容