如何在控制器层Spring中进行流式处理

import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;

import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.OutputStream;
import java.nio.charset.StandardCharsets;
import java.util.stream.IntStream;

@RestController
public class StreamController {

    @GetMapping("/stream")
    public ResponseEntity<StreamingResponseBody> streamData(HttpServletResponse response) {
        response.setContentType(MediaType.TEXT_PLAIN_VALUE);
        response.setHeader("Content-Disposition", "attachment; filename=data.txt");

        StreamingResponseBody responseBody = outputStream -> {
            try (OutputStream out = outputStream) {
                IntStream.range(1, 100000)
                        .forEach(i -> {
                            try {
                                out.write(("Data " + i + "\n").getBytes(StandardCharsets.UTF_8));
                                out.flush();
                                Thread.sleep(100); // 模拟处理延迟
                            } catch (IOException | InterruptedException e) {
                                e.printStackTrace();
                            }
                        });
            }
        };

        return ResponseEntity.ok()
                .header("Cache-Control", "no-cache, no-store, must-revalidate")
                .header("Pragma", "no-cache")
                .header("Expires", "0")
                .body(responseBody);
    }
}