spring webflux 系列之 上传文件到七牛云篇（不用本地创建文件直接内存上传）
spring webflux上传单文件与多文件 至 七牛云
下载文件篇
本次我介绍springboot 下 webflux 上传文件到七牛云；
网上基本上全部教程都是创建本地文件 才去上传七牛云 又要删除本地文件；
所以我直接放在内存里面 上传
代码如下：
@PostMapping("/upload")
public Mono<Response> uploadFile(@RequestPart(value = "file", required = false) FilePart file) throws IOException, DataException {
if (file == null) {
throw new CustomException(HttpCodeEnum.filenoempty);
String fileName = file.filename();
String type = fileName.indexOf(".") != -1 ? fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length()) : null;
if (!"GIF".equals(type.toUpperCase()) &&
!"PNG".equals(type.toUpperCase()) &&
!"JPG".equals(type.toUpperCase()) &&
!"JPEG".equals(type.toUpperCase()) &&
!"MP4".equals(type.toUpperCase()) &&
!"MP3".equals(type.toUpperCase())) {
throw new CustomException(HttpCodeEnum.filesuffixnosupport);
Flux<DataBuffer> bufferFlux = file.content();
Mono<Response> mono = bufferFlux.map(dataBuffer->dataBuffer.asInputStream()).reduce(SequenceInputStream::new).flatMap(
inputStream -> {
String fileNames = "jiumi" + "/" + JodaTimeUtils.format(new Date(), "yyyyMMddHHmmss") + RandomUtils.get3Random() + "." + type;
String url = null;
try {
url = QiNiuUtils.uploadFile((ImageUtils.readInputStream(inputStream)), fileNames, "pingan");
} catch (QiniuException e) {
e.printStackTrace();
file.delete().subscribe();
return Mono.justOrEmpty(new Response().add("url", url).success());
return mono;
* 写法二：多文件 Flux<FilePart>
* spring webflux 实现可能有点麻烦 毕竟最大文件max 是9MB 推荐使用上面的单文件上传
@PostMapping("/uploads")
public Mono<Response> uploadFiles(@RequestPart(value = "files", required = false) Flux<FilePart> files) throws IOException, DataException {
files.map(filePart -> {
String fileName = filePart.filename();
String type = fileName.indexOf(".") != -1 ? fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length()) : null;
if (!"GIF".equals(type.toUpperCase()) &&
!"PNG".equals(type.toUpperCase()) &&
!"JPG".equals(type.toUpperCase()) &&
!"JPEG".equals(type.toUpperCase()) &&
!"MP4".equals(type.toUpperCase()) &
!"MP3".equals(type.toUpperCase())) {
throw new CustomException(HttpCodeEnum.filesuffixnosupport);
return filePart;
});
Mono<Response> mono=files.flatMap(filePart -> {
String fileName = filePart.filename();
String type = fileName.indexOf(".") != -1 ? fileName.substring(fileName.lastIndexOf(".") + 1, fileName.length()) : null;
return filePart.content().map(dataBuffer->dataBuffer.asInputStream()).reduce(SequenceInputStream::new).flatMap(
inputStream -> {
String fileNames = "jiumi" + "/" + JodaTimeUtils.format(new Date(), "yyyyMMddHHmmss") + RandomUtils.get3Random() + "." + type;
String url = null;
try {
url = QiNiuUtils.uploadFile((ImageUtils.readInputStream(inputStream)), fileNames, "pingan");
} catch (QiniuException e) {
e.printStackTrace();
filePart.delete().subscribe();
return Mono.just(url);
});
}).collect(Collectors.toList()).flatMap(
strings -> {
return Mono.just(new Response().add("list",strings).success());
return mono;
Response是我自定义返回体 整个项目是返回json的
这里可以改成你喜欢的返回方式
可能还会涉及到spring webflux 上传文件大小的限制
我的配置如下：
@Override
public void configureHttpMessageCodecs(ServerCodecConfigurer configurer) {
ObjectMapper mapper = mapper();
configurer.defaultCodecs().jackson2JsonEncoder(new Jackson2JsonEncoder(mapper));
configurer.defaultCodecs().jackson2JsonDecoder(new Jackson2JsonDecoder(mapper));
DefaultPartHttpMessageReader partReader = new DefaultPartHttpMessageReader();
partReader.setMaxParts(1);
partReader.setMaxDiskUsagePerPart(9L*1000L*1024L);
partReader.setEnableLoggingRequestDetails(true);
MultipartHttpMessageReader multipartReader = new MultipartHttpMessageReader(partReader);
multipartReader.setEnableLoggingRequestDetails(true);
configurer.defaultCodecs().multipartReader(multipartReader);
后续我会继续更新spring webflux 系列
并整合成项目开源 github开源地址
spring webflux 系列之 上传文件到七牛云篇（不用本地创建文件直接内存上传）本次我介绍springboot 下 webflux 上传文件到七牛云；网上基本上全部教程都是创建本地文件 才去上传七牛云 又要删除本地文件；所以我直接放在内存里面 上传代码如下： //写法一：Mono<FilePart> @PostMapping("/upload") public Mono<Response> uploadFile(@RequestPart(val
@PostMapping("addAttach")
public Mono<JsonResult> addAttach(@RequestPart("file") FilePart filePart,//获取文件参数
@RequestPart("dataId") String dataId,//获取其他参数...
implementation("org.springframework.boot:spring-boot-starter-webflux")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-core")
implementation("org.jetbrains.kotlinx:kotlinx-coroutines-reactor")
2. 从文件中获取数据并返回文件流
三、WebFlux上传、下载、展示
一、文件上传
一个真实案例中，文件传到服务器后，要继续上传到 OSS，经实测 transferTo 的方案更完美。DataBufferUtils 的方案，传到服务器没问题，但继续上传到 OSS 后，图片总是只有上半身。
* 文件上传
@ApiOperation("轮播图 - 上传")
@PostMapping("/admin/chart/upload", consumes = [MediaType.MULTIPART_FORM_DATA_
14:32:24.628 [61667d78915db10adaa025b4da32871f/daa025b4da32871f] [reactor-http-epoll-4] ERROR o.s.w.s.a.HttpWebHandlerAdapter - [7161d1a8-33] 500 Server Error for HTTP POST "/api/XXXXX/XXXXX"
org.springframework.core.io.buffer.Data
不久前, spring进行了较大的改动, 主要目的是为了增加对响应式编程的支持.
spring 默认是采用了reactor项目作为响应式编程(reactive programming)的支持, 我也以此作为基础来谈.
reactor项目地址: https://github.com/reactor/reactor
为什么要reactor
总的来说, r
@RunWith(SpringRunner.class)
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class TestMerchantRequire {
protected WebTestClient client;
@Autowired
原文链接：http://www.dubby.cn/detail.html?id=9030代码地址：https://github.com/dubby1994/
web-
flux-demo
已经迫不及待的要试试刚刚出炉的
WebFlux了？哈哈，那你就来对了
pom.xml：<parent>
<groupId>org.
springframework.
boot</groupId>
