spring springboot webflux 文件上传下载_spring-boot-starter-webflux框架实现文件上传

RestController架构

webflux直接提供了RequestPart注解，让我们拿到上传的文件数据
@PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE)
public Mono<String> requestBodyFlux(@RequestPart("file") FilePart filePart) throws IOException {
    System.out.println(filePart.filename());
    Path tempFile = Files.createTempFile("test", filePart.filename());
    //NOTE 方法一
    AsynchronousFileChannel channel =
            AsynchronousFileChannel.open(tempFile, StandardOpenOption.WRITE);
    DataBufferUtils.write(filePart.content(), channel, 0)
            .doOnComplete(() -> {
                System.out.println("finish");
        .subscribe();
    //NOTE 方法二
	//filePart.transferTo(tempFile.toFile());
    return Mono.just(filePart.filename());
说明：使用RequestPart来接收，得到的是FilePart
 FilePart的content是Flux，可以使用DataBufferUtils写到文件或者直接使用transferTo写入到文件 
Route Handler架构
 
很多时候，我们使用 router 如下指定接口访问入口 
@Bean
    RouterFunction<ServerResponse> myRouter(IndustryChainHandler icHandler) {
        return nest(
                path("/v2.0/mynetwork"),
                route(POST("/upload"), myHandler::upload));
此时不方便直接拿到RequestPart 数据，但是其实数据都还是在ServerRequest里面，变换一下就可以了。 
public Mono<ServerResponse> upload(ServerRequest request) {
        return ok().contentType(APPLICATION_JSON_UTF8).body(
                request.body(BodyExtractors.toMultipartData()).map(parts -> {
                    Map<String, Part> map = parts.toSingleValueMap();
                    // ‘files’ 为客户端上传文件key
                    FilePart filePart = (FilePart) map.get("files");
                    try {
                        // 第一个参数是上传文件的前缀，可以随便起名字
                        Path tempFile = Files.createTempFile("upload_file", filePart.filename());
                        File dest = tempFile.toFile();
                        filePart.transferTo(dest);
                        return filePart.filename();
                    } catch (IOException e) {
                        e.printStackTrace();
                    return "";
                }).map(filename -> {
                    if (!StringUtils.isEmpty(filename)) {
                        return "OK";
                    } else {
                        return "error";
                }), String.class
@GetMapping("/download")
public Mono<Void> downloadByWriteWith(ServerHttpResponse response) throws IOException {
	ZeroCopyHttpOutputMessage zeroCopyResponse = (ZeroCopyHttpOutputMessage) response;
	response.getHeaders().set(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=myimage.png");
	response.getHeaders().setContentType(MediaType.IMAGE_PNG);
	Resource resource = new ClassPathResource("parallel.png");
	File file = resource.getFile();
	return zeroCopyResponse.writeWith(file, 0, file.length());
@GetMapping("/download")
public Mono<ServerResponse> downloadByWriteWith(ServerRequest request) throws IOException {
	Resource resource = new ClassPathResource("myimage.png");
	return ok().header("Content-Disposition", "attachment; filename=myimage.png")
	.body(BodyInserters.fromResource(resource)).switchIfEmpty(Mono.empty());
说明：两种方法都是将数据写入ServerHttpResponse，方法2可以在配合path.route使用
                                    赠送jar包：spring-webflux-5.3.15.jar；
赠送原API文档：spring-webflux-5.3.15-javadoc.jar；
赠送源代码：spring-webflux-5.3.15-sources.jar；
赠送Maven依赖信息文件：spring-webflux-5.3.15.pom；
包含翻译后的API文档：spring-webflux-5.3.15-javadoc-API文档-中文(简体)版.zip；
Maven坐标：org.springframework:spring-webflux:5.3.15；
标签：spring、webflux、springframework、jar包、java、中文文档；
使用方法：解压翻译后的API文档，用浏览器打开“index.html”文件，即可纵览文档内容。
人性化翻译，文档中的代码和结构保持不变，注释和说明精准翻译，请放心使用。
                                    文件下载是Web应用程序中常见的功能之一，特别是在需要向用户提供生成的报告、用户上传的文件或其他动态生成的内容时。Spring Boot提供了简单而强大的方式来处理文件下载，同时提供了安全性和性能的保证。大家好，我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编，也是冬天不穿秋裤，天冷也要风度的程序猿！今天我们来探讨一下在Spring Boot中如何实现文件下载的技术细节和最佳实践。系统将返回一个包含文件内容的响应，并自动提示下载。方法处理下载请求，根据请求的文件名构建文件路径，并创建一个。
                                    这应该是使用springCloud上传文件的最可用文章；在springCould框架里上传文件时，发现以往的MultipartFile不可用，这是因为之前的springboot框架使用的是spring-boot-starter-web 启动；而springCould使用的是 spring-boot-starter-webflux 完全非阻塞模的流式。
                                    三、WebFlux上传、下载、展示
一、文件上传
 　　一个真实案例中，文件传到服务器后，要继续上传到 OSS，经实测 transferTo 的方案更完美。DataBufferUtils 的方案，传到服务器没问题，但继续上传到 OSS 后，图片总是只有上半身。
 * 文件上传
@ApiOperation("轮播图 - 上传")
@PostMapping("/admin/chart/upload", consumes = [MediaType.MULTIPART_FORM_DATA_
                                    spring webflux 系列之 上传文件到七牛云篇（不用本地创建文件直接内存上传）
本次我介绍springboot 下 webflux 上传文件到七牛云；
网上基本上全部教程都是创建本地文件 才去上传七牛云  又要删除本地文件；
所以我直接放在内存里面 上传
代码如下：
  //写法一：Mono<FilePart>
    @PostMapping("/upload") 
    public Mono<Response> uploadFile(@RequestPart(val
                                    从 Spring 5 开始，Spring 中全面引入了 Reactive 响应式编程。而 WebClient 则是 Spring WebFlux 模块提供的一个非阻塞的基于响应式编程的进行 Http 请求的客户端工具。由于 WebClient 的请求模式属于异步非阻塞，能够以少量固定的线程处理高并发的 HTTP 请求。因此，从 Spring 5 开始，HTTP 服务之间的通信我们就可以考虑使用 WebClient 来取代之前的 RestTemplate。
@PostMapping("addAttach")
public Mono<JsonResult> addAttach(@RequestPart("file") FilePart filePart,//获取文件参数
                                  @RequestPart("dataId") String dataId,//获取其他参数...
                                    我们可以将FileOutputStream和BufferedOutputStream结合使用来保存文件到本地。我们可以使用它来创建一个文件输出流，并将数据写入到文件中。通过上述的三种方法，我们可以在Java中实现将文件保存到本地。根据具体的需求和场景，选择适合的方法来进行文件保存操作。在Java中，我们可以使用各种方法来保存文件到本地。下面我将介绍几种常见的实现方式，并附上相应的源代码示例。方法，该方法接受文件的字节数组数据和文件路径作为参数。包中提供了Files类，它提供了一组用于操作文件的静态方法。
File(String pathname)：通过将给定的路径名字符串转换为抽象路径名来创建新的File实例
File(String parent, String child)：从父路径名字符串和子路径名字符串创建新的File实例
File(File parent, String child)：从父