通过Spring WebClient实现大文件的流式上传

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>

@RestController
public class FileUploadController {

    @PostMapping("/upload")
    public Mono<String> uploadFile(@RequestPart("file") Flux<DataBuffer> fileData) {
        // 处理上传文件逻辑
        // 这里可以使用fileData进行文件处理，如存储到本地或者云存储等操作
        return Mono.just("File uploaded successfully");
    }
}

public void uploadFile(File file) throws IOException {
    WebClient client = WebClient.create();
    client.post()
            .uri("http://localhost:8080/upload")
            .contentType(MediaType.MULTIPART_FORM_DATA)
            .body(BodyInserters.fromPublisher(getFileDataBuffer(file), DataBuffer.class))
            .retrieve()
            .bodyToMono(String.class)
            .subscribe(response -> System.out.println(response));
}

private Flux<DataBuffer> getFileDataBuffer(File file) throws IOException {
    return DataBufferUtils.read(new FileInputStream(file), new DefaultDataBufferFactory(), 1024);
}