如何在WebFlux中实现Java文件的上传功能？

在Spring WebFlux中实现Java文件的上传功能通常需要以下几个步骤：

1. 引入依赖：首先，在你的项目中引入Spring WebFlux和Spring-Multipart的相关依赖，例如`spring-webflux`和`spring-boot-starter-webflux-multipart`。

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

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

2. 配置MultipartResolver：在配置类中启用Multipart支持，并设置最大文件大小等限制。

@Configuration
public class WebConfig implements WebFluxConfigurer {
    @Override
    public void configureHttpMessageFormatters(MultipartHttpMessageConverterConfigurer configurer) {
        MultiValueMap<String, Part> parts = new LinkedMultiValueMap<>();
        for (Part part : configurer.getMessageConverters().get(0).getPartExtractors().extractParts(request)) {
            if (part instanceof SimplePart) {
                parts.add(part.getName(), ((SimplePart) part).getInputStream());
            }
        }

        // 设置响应头，允许下载文件
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.APPLICATION_OCTET_STREAM);
        return body -> Mono.just(body.withHeaders(headers));
    }

    @Bean
    public MultipartConfigElement multipartConfigElement() {
        CommonsMultipartConfig multipartConfig = new CommonsMultipartConfig();
        // 设置最大文件大小
       .multipartConfig.setMaxUploadSize(10 * 1024 * 1024); // 10MB
        return multipartConfig;
    }
}

3. 创建处理上传请求的Controller：创建一个接收文件的Controller，使用`ultipartFile`参数来处理上传的文件。

@PostMapping("/upload")
public Mono<String> handleFileUpload(@RequestParam("file") MultipartFile file) {
    try {
        if (file.isEmpty()) {
            throw new RuntimeException("No file selected");
        }
        
        // 进行文件处理，如保存到服务器、验证文件类型等
        String fileName = "uploaded-" + UUID.randomUUID() + "." + file.getOriginalFilename();
        saveFileToServer(file.getInputStream(), fileName);

        return Mono.just(fileName);
    } catch (Exception e) {
        return Mono.error(e);
    }
}

private void saveFileToServer(InputStream inputStream, String fileName) {
    // 实现将输入流保存到服务器的逻辑
}

4. 提交表单：前端通过HTML表单提交文件，表单通常包含一个`<input type="file">`元素，用户选择文件后点击“上传”按钮触发POST请求。

<form action="/upload" method="post" enctype="multipart/form-data">
    <input type="file" name="file">
    <button type="submit">上传</button>
</form>