本文选自孙卫琴的《精通Spring:Java Web开发技术详解》清华大学出版社出版

技术支持网址为：​ ​ www.javathinker.net/spring.jsp​​

​本书对应的直播和录播课：​​ ​ www.javathinker.net/zhibo.jsp​​

孙卫琴的QQ学习答疑群：915851077

本文介绍在WebFlux框架中采用异步非阻塞的方式上传或下载文件。

以下例程1的FileController类的upload()方法和download()方法分别用于上传和下载文件。

​例程1 FileController.java

@RestController public class FileController { @PostMapping(value = "/upload", consumes = MediaType.MULTIPART_FORM_DATA_VALUE) publicMono upload( @RequestPart("file") FilePart filePart) throws IOException { System.out.println(filePart.filename()); FilenewFile = new File("C:\\helloapp", filePart.filename()); newFile.createNewFile(); PathdestFile = Paths.get("C:\\helloapp", filePart.filename()); //第一种上传方式 filePart.transferTo(destFile.toFile()); //第二种上传方式 /* AsynchronousFileChannel channel = AsynchronousFileChannel.open(destFile, StandardOpenOption.WRITE); DataBufferUtils.write(filePart.content(), channel, 0) .doOnComplete(() -> { System.out.println("finish"); }) .subscribe(); */ System.out.println(destFile); returnMono.just(filePart.filename()); } @GetMapping("/download") publicMono download ( ServerHttpResponse response) throws IOException { Stringfilename = "static\\book.png"; ZeroCopyHttpOutputMessage zeroCopyResponse = (ZeroCopyHttpOutputMessage) response; response.getHeaders().set(HttpHeaders.CONTENT_DISPOSITION, "attachment;filename=" + filename); response.getHeaders().setContentType(MediaType.IMAGE_PNG); Resourceresource = new ClassPathResource(filename); File file= resource.getFile(); returnzeroCopyResponse.writeWith(file, 0, file.length()); } }

1．上传文件

//upload()方法

public Monoupload(@RequestPart("file") FilePart filePart)

以上的upload()方法的filePart参数为org.springframework.http.codec.multipart.FilePart类型，FilePart类的transferTo()方法采用异步非阻塞的方式上传文件。这里所谓异步非阻塞，是指transferTo()方法仅仅向底层Spring框架提交了一个上传文件的任务，而执行transferTo()方法的当前线程不会在方法中阻塞，而是立即退出来，执行后续代码，向客户端返回响应数据。所以当客户端收到响应结果时，有可能服务器端还在后台继续执行上传文件的任务。

FilePart接口的transferTo()方法的返回类型为Mono：

reactor.core.publisher.MonotransferTo(File dest)

本文介绍的上传文件有两种方式，第一种方式是调用filePart参数的transferTo()方法：

filePart.transferTo(destFile.toFile());​

上传文件的第二种方式是通过异步文件通道java.nio.channels.AsynchronousFileChannel来上传文件：​

AsynchronousFileChannel channel = AsynchronousFileChannel.open( destFile, StandardOpenOption.WRITE); DataBufferUtils.write(filePart.content(), channel,0) .doOnComplete(() -> { System.out.println("finish"); }) .subscribe();

2．下载文件

FileController类的download()方法的response参数表示响应结果，它属于ServerHttpResponse类型。ServerHttpResponse接口来自于WebFlux API，能够按照异步非阻塞的方式输出响应数据，这意味着客户端在下载文件过程中不会被阻塞，还可以同时执行其他的操作。

3．运行程序

用Intellij IDEA运行本范例程序，再通过浏览器访问：

http://localhost:8080/fileio.html

会出现如图1所示的网页，在网页上执行上传文件的操作，FileController类会把文件上传到服务器端的helloapp根目录下。在网页上执行下载文件的操作，FileController类会把服务器端的helloapp\target\classes\static\book.png文件下载到客户端。

图1 fileio.html网页