- 微信
- 微博
  
  分享文章到微博
- 复制链接
  
  复制链接到剪贴板

SpringCloudGateway网关服务实现文件上传功能

刘大猫发表于 2024/11/26 22:04:51 2024/11/26

【摘要】 SpringCloudGateway网关服务实现文件上传功能

@[toc]

说明

Gateway网关服务本想实现前后端的文件上传及下载功能，但是在实际开发过程中屡屡产生报错，导致一直报错“400 bad request: Required request part ‘file’ is not present”后端无法解析接收到文件数据，从而导致无法实现前端文件上传及后端接收解析过程，本文就是为了记录成功案例，以及描述本人尝试其他方案的感受，便于其他人吸取经验，排雷。

SpringBoot和SpringCloudGateway项目区别说明

Spring Boot是一套基于Spring框架的微服务框架。
SpringCloudGateway基于webFlux框架实现的
框架不同就导致，之前网上传统的那套controller层方法就不适用，现在分别举例说明

1.SpringBoot的成功案例文件上传代码

pom

<!--文件上传-->
 <dependency>
     <groupId>commons-fileupload</groupId>
     <artifactId>commons-fileupload</artifactId>
     <version>1.3.3</version>
 </dependency>

前端代吗

<p>单文件上传并保存</p>
<form method="post" action="/excel/uploadExcel" enctype="multipart/form-data">
    <p><input type="file" name="file00"></p>
    <p><span th:if="${msg}"></span></p>
    <input type="submit" value="提交">
</form>

Controller代码重点在：@RequestParam(“file00”) MultipartFile file

@PostMapping(value = "/uploadExcel")
    public String uploadExcel(@RequestParam("file00") MultipartFile file, Model model) throws IOException {
        try {
            if(file.isEmpty()){
                model.addAttribute("msg","上传失败，请选择文件！");
                return "excelIndex";
            }
            String filename = file.getOriginalFilename();
            //filePath获取的是编译后的路径，而不是项目看到的路径，filePath=/E:/WorkSpace/demo/target/classes/
            String filePath = ResourceUtils.getURL("classpath:").getPath()+"static/oneFile/";
            //避免文件重复覆盖
            String uuid= UUID.randomUUID().toString().replaceAll("-", "");
            //时间戳分类文件
            String time = new SimpleDateFormat("YYYY-MM").format(new Date());
            String realPath = filePath + time + "/" + uuid + "-" + filename;
            System.out.println("realPath:" + realPath);
            //最后保存的路径在这里：target/classes/static/oneFile/2022-02/548881060e3d417a91d87b0a10959077-sop.sql
            File dest = new File(realPath);
            //检测是否存在目录，无，则创建
            if(!dest.getParentFile().exists()){
                dest.getParentFile().mkdirs();//新建文件夹 多级目录
            }
            file.transferTo(dest);//文件写入
        } catch (IOException e) {
            e.printStackTrace();
        }
        model.addAttribute("msg","文件上传成功！");
        return "hello";
    }

2.SpringCloudGateway的成功案例文件上传代码

Controller代码

重点区别在：

1.注解中配置consumes = MediaType.MULTIPART_FORM_DATA_VALUE
2.形参采用@RequestPart(“file”) FilePart filePart，而不是传统的@RequestParam(“file00”) MultipartFile file，这是他两的区别

备注说明:

1.使用RequestPart来接收，得到的是FilePart
2.FilePart的content是Flux<DataBuffer>，可以使用DataBufferUtils写到文件或者直接使用transferTo写入到文件
详情可查看该文章了解 ->： SPRING WEBFLUX 前后端分离文件上传

import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.MediaType;
import org.springframework.http.codec.multipart.FilePart;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestPart;
import org.springframework.web.bind.annotation.RestController;
import reactor.core.publisher.Mono;

import java.io.IOException;
import java.nio.channels.AsynchronousFileChannel;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.nio.file.StandardOpenOption;

@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.createFile(Paths.get("D:\\tmp\\"+filePart.filename()));

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

		//方法二
		//filePart.transferTo(tempFile.toFile());

      System.out.println(tempFile.toString());
      return Mono.just(filePart.filename());
  }

网上其他方案

说明：
1.针对前端代码格式书写错误导致
2.针对后端代码编写Filter过滤器文件进行解析
3.注入Bean方式或者xml配置xxResolver解析器进行文件解析
下面方法直接拷贝可能会报错，里面某些类没有标注<dependency>引用，会报错找不到或者调用还是报 “400 bad request: Required request part ‘file’ is not present”