两种方式上传，一种是Minio文件服务器，一种是Nginx下静态资源服务器(未完)

架构层次

image.png

yml

  1. server:
  2.   port: 8082
  3. spring:
  4.   servlet:
  5.     multipart:
  6.       max-file-size: 500MB
  7.       max-request-size: 500MB
  9. ## Mysql
  10. #  datasource:
  11. #    url: jdbc:mysql://192.168.10.223:3306/sjtc_bz_db?allowMultiQueries=true&useUnicode=true&characterEncoding=UTF8&zeroDateTimeBehavior=convertToNull
  12. #    username: root
  13. #    password: dca282e70e
  14. #    driver-class-name: com.mysql.jdbc.Driver
  16. # Oracle
  17.   datasource:
  18.     url: jdbc:oracle:thin:@192.168.10.223:1522/ORCLPDB1
  19.     username: SJTC_BZ_DB
  20.     password: 123456
  21.     type: com.alibaba.druid.pool.DruidDataSource
  22.     driver-class-name: oracle.jdbc.OracleDriver

pom

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
  4.     <modelVersion>4.0.0</modelVersion>
  5.     <parent>
  6.         <groupId>org.springframework.boot</groupId>
  7.         <artifactId>spring-boot-starter-parent</artifactId>
  8.         <version>2.5.1</version>
  9.         <relativePath/> <!-- lookup parent from repository -->
  10.     </parent>
  11.     <groupId>com.example</groupId>
  12.     <artifactId>demo</artifactId>
  13.     <version>0.0.1-SNAPSHOT</version>
  14.     <name>demo</name>
  15.     <description>Demo project for Spring Boot</description>
  16.     <properties>
  17.         <java.version>1.8</java.version>
  18.         <springfox.version>2.7.0</springfox.version>
  19.         <mysql.version>5.1.40</mysql.version>
  20.         <mybatisplus.version>2.1.0</mybatisplus.version>
  21.         <mybatisplus-spring-boot-starter.version>1.0.4</mybatisplus-spring-boot-starter.version>
  22.     </properties>
  23.     <dependencies>
  24.         <dependency>
  25.             <groupId>org.springframework.boot</groupId>
  26.             <artifactId>spring-boot-starter-web</artifactId>
  27.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-test</artifactId>
  32.             <scope>test</scope>
  33.         </dependency>
  34.         <dependency>
  35.             <groupId>io.minio</groupId>
  36.             <artifactId>minio</artifactId>
  37.             <version>8.2.2</version>
  38.         </dependency>
  39.         <dependency>
  40.             <groupId>org.projectlombok</groupId>
  41.             <artifactId>lombok</artifactId>
  42.             <version>1.18.12</version>
  43.             <scope>compile</scope>
  44.         </dependency>
  45.         <dependency>
  46.             <groupId>io.springfox</groupId>
  47.             <artifactId>springfox-swagger2</artifactId>
  48.             <version>${springfox.version}</version>
  49.             <exclusions>
  50.                 <exclusion>
  51.                     <groupId>org.mapstruct</groupId>
  52.                     <artifactId>mapstruct</artifactId>
  53.                 </exclusion>
  54.             </exclusions>
  55.         </dependency>
  56.         <dependency>
  57.             <groupId>io.springfox</groupId>
  58.             <artifactId>springfox-swagger2</artifactId>
  59.             <version>2.9.2</version>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>io.springfox</groupId>
  63.             <artifactId>springfox-swagger-ui</artifactId>
  64.             <version>2.9.2</version>
  65.         </dependency>
  66.         <dependency>
  67.             <groupId>mysql</groupId>
  68.             <artifactId>mysql-connector-java</artifactId>
  69.             <version>${mysql.version}</version>
  70.         </dependency>
  71.         <!-- mybatis-plus begin -->
  72.         <dependency>
  73.             <groupId>org.springframework.boot</groupId>
  74.             <artifactId>spring-boot-starter-jdbc</artifactId>
  75.         </dependency>
  76.         <dependency>
  77.             <groupId>com.baomidou</groupId>
  78.             <artifactId>mybatisplus-spring-boot-starter</artifactId>
  79.             <version>${mybatisplus-spring-boot-starter.version}</version>
  80.         </dependency>
  81.         <dependency>
  82.             <groupId>com.baomidou</groupId>
  83.             <artifactId>mybatis-plus</artifactId>
  84.             <version>${mybatisplus.version}</version>
  85.         </dependency>
  87.         <dependency>
  88.             <groupId>com.oracle.ojdbc</groupId>
  89.             <artifactId>ojdbc8</artifactId>
  90.         </dependency>
  92.         <dependency>
  93.             <groupId>com.alibaba</groupId>
  94.             <artifactId>fastjson</artifactId>
  95.             <version>1.2.9</version>
  96.         </dependency>
  98.         <!-- druid 连接池-->
  100.         <dependency>
  102.             <groupId>com.alibaba</groupId>
  104.             <artifactId>druid</artifactId>
  106.             <version>1.1.10</version>
  108.         </dependency>
  111.     </dependencies>
  113.     <build>
  114.         <plugins>
  115.             <plugin>
  116.                 <groupId>org.springframework.boot</groupId>
  117.                 <artifactId>spring-boot-maven-plugin</artifactId>
  118.             </plugin>
  119.         </plugins>
  120.     </build>
  122. </project>

config

MinioConfig

  1. public class MinioConfig {
  2.     /**
  3.      * ip+port
  4.      */
  5.     public static String Url = "http://192.168.10.223:9002";
  6.     public static String AccessKey = "orisdom";
  7.     public static String SecretKey = "orisdom123";
  8.     public static String BucketName = "sjtc";
  9. }

SimpleConfig

  1. public class SimpleConfig {
  2.     /**
  3.      * 本地文件保存根路径
  4.      */
  5.     /**
  6.      * ip+port
  7.      */
  8.     public static String Url = "";
  9.     public static String localPath = "";
  10. }

enums

FileType

  1. public enum FileType {
  2.     文本("0"),图片("1"),视频("2");
  3.     private final String type;
  4.     FileType(String type){
  5.         this.type = type;
  6.     }
  8.     public String getType() {
  9.         return type;
  10.     }
  11. }

UploadType

  1. public enum UploadType {
  2.     上传本地("normal"),上传Minio("minio");
  3.     private final String type;
  4.     UploadType(String type){
  5.         this.type = type;
  6.     }
  8.     public String getType() {
  9.         return type;
  10.     }
  11. }

entity

FileEntity

  1. /**
  2.  * @author: Jili
  3.  * @description: com.orisdom.modules.common.entity
  4.  * @date: Created on 2021/9/1 10:33
  5.  */
  6. @NoArgsConstructor
  7. @AllArgsConstructor
  8. @Builder
  9. @Data
  10. @ApiModel(description = "文件上传")
  11. @TableName("C_FILES")
  12. public class FileEntity implements Serializable{
  14.     private static final long serialVersionUID = 1L;
  16.     @ApiModelProperty(value = "文件ID")
  17.     @TableId(value = "FILE_ID", type = IdType.UUID)
  18.     private String fileId;
  19.     @ApiModelProperty(value = "文件名称")
  20.     @TableField("FILE_NAME")
  21.     private String fileName;
  22.     @ApiModelProperty(value = "类型")
  23.     @TableField("FILE_TYPE")
  24.     private String fileType;
  25.     @ApiModelProperty(value = "拓展名")
  26.     @TableField("EXT")
  27.     private String ext;
  28.     @ApiModelProperty(value = "文件在磁盘中的存储名称，不包含路径和扩展名")
  29.     @TableField("STORAGE_NAME")
  30.     private String storageName;
  31.     @ApiModelProperty(value = "文件大小")
  32.     @TableField("FILE_SIZE")
  33.     private Double fileSize;
  34.     @TableField("URI")
  35.     private String uri;
  36.     @TableField("URL")
  37.     private String url;
  38.     @TableField("INSERT_USER")
  39.     private String insertUser;
  40.     @TableField("LAST_UPDATE_USER")
  41.     private String lastUpdateUser;
  42.     @TableField("INSERT_DATETIME")
  43.     private Date insertDatetime;
  44.     @TableField("LAST_UPDATE_TIME")
  45.     private Date lastUpdateTime;
  46. }

service

IFileService

  1. public interface IFileService {
  2.     /**
  3.      * @return
  4.      */
  5. //    String upload(MultipartFile file, FileType fileType, UploadType uploadType);
  6.     /**
  7.      * MultipartFile
  8.      * @param file 上传文件
  9.      * @param bucketName 桶名
  10.      * @param fileName 文件保存新名字
  11.      * @param uploadType 上传方式
  12.      * @return
  13.      */
  14.     String upload(MultipartFile file, String bucketName, String fileName,UploadType uploadType);
  16.     /**
  17.      * File
  18.      * @param file 上传文件
  19.      * @param fileType 文件类型
  20.      * @param uploadType 上传方式
  21.      * @return
  22.      */
  23.     String upload(File file, FileType fileType, UploadType uploadType) throws Exception;
  24. }

FileService

  1. @Service
  2. public class FileService implements IFileService {
  4. //    @Override
  5. //    public String upload(MultipartFile file, FileType fileType, UploadType uploadType) {
  6. //        String url = null;
  7. //        switch (uploadType) {
  8. //            case 上传本地:
  9. //                url = SimpleFileUtil.getInstance().upload(file, fileType);
  10. //                break;
  11. //            case 上传Minio:
  12. //                url = MinioFileUtil.getInstance().upload(MinioConfig.BucketName, file);
  13. //                break;
  14. //            default:
  15. //                break;
  16. //        }
  17. //        return url;
  18. //    }
  20.     /*
  21.     改良版
  22.      */
  23.     @Override
  24.     public String upload(MultipartFile file, String bucketName, String fileName,UploadType uploadType) {
  25.         String url = null;
  26.         switch (uploadType) {
  27.             case 上传本地:
  28.                 url = SimpleFileUtil.getInstance().upload(file, fileName);
  29.                 break;
  30.             case 上传Minio:
  31.                 url = MinioFileUtil.getInstance().upload(file,bucketName,fileName);
  32.                 break;
  33.             default:
  34.                 break;
  35.         }
  36.         return url;
  37.     }
  39.     @Override
  40.     public String upload(File file, FileType fileType, UploadType uploadType) throws Exception {
  41.         FileInputStream inputStream = new FileInputStream(file);
  42.         String url = null;
  43.         switch (uploadType) {
  44.             case 上传本地:
  45.                 url = SimpleFileUtil.getInstance().upload(inputStream, file.getName(), fileType);
  46.                 break;
  47.             case 上传Minio:
  48.                 url = MinioFileUtil.getInstance().upload(fileType.getType(), file.getName(), inputStream);
  49.                 break;
  50.             default:
  51.                 break;
  52.         }
  53.         return url;
  54.     }
  55. }

util

MinioFileUtil

  1. @Service
  2. public class FileService implements IFileService {
  4. //    @Override
  5. //    public String upload(MultipartFile file, FileType fileType, UploadType uploadType) {
  6. //        String url = null;
  7. //        switch (uploadType) {
  8. //            case 上传本地:
  9. //                url = SimpleFileUtil.getInstance().upload(file, fileType);
  10. //                break;
  11. //            case 上传Minio:
  12. //                url = MinioFileUtil.getInstance().upload(MinioConfig.BucketName, file);
  13. //                break;
  14. //            default:
  15. //                break;
  16. //        }
  17. //        return url;
  18. //    }
  20.     /*
  21.     改良版
  22.      */
  23.     @Override
  24.     public String upload(MultipartFile file, String bucketName, String fileName,UploadType uploadType) {
  25.         String url = null;
  26.         switch (uploadType) {
  27.             case 上传本地:
  28.                 url = SimpleFileUtil.getInstance().upload(file, fileName);
  29.                 break;
  30.             case 上传Minio:
  31.                 url = MinioFileUtil.getInstance().upload(file,bucketName,fileName);
  32.                 break;
  33.             default:
  34.                 break;
  35.         }
  36.         return url;
  37.     }
  39.     @Override
  40.     public String upload(File file, FileType fileType, UploadType uploadType) throws Exception {
  41.         FileInputStream inputStream = new FileInputStream(file);
  42.         String url = null;
  43.         switch (uploadType) {
  44.             case 上传本地:
  45.                 url = SimpleFileUtil.getInstance().upload(inputStream, file.getName(), fileType);
  46.                 break;
  47.             case 上传Minio:
  48.                 url = MinioFileUtil.getInstance().upload(fileType.getType(), file.getName(), inputStream);
  49.                 break;
  50.             default:
  51.                 break;
  52.         }
  53.         return url;
  54.     }
  55. }

更多可以参考 https://blog.csdn.net/hzw2312/article/details/106078390

SimpleFileUtil

  1. public class SimpleFileUtil {
  2.     private static  SimpleFileUtil instance = new SimpleFileUtil();
  3.     private SimpleFileUtil(){};
  5.     public static SimpleFileUtil getInstance() {
  6.         return instance;
  7.     }
  9.     /**
  10.      * 上传文件
  11.      * @param multipartFile 文件
  12.      * @param fileFullName 文件相对路径 如：/images/demo.jpg
  13.      * @return
  14.      */
  15.     @SneakyThrows(Exception.class)
  16.     public String upload(MultipartFile multipartFile, String fileFullName){
  17. //        String dirPath;
  18. //        DateFormatter formatter = new DateFormatter();
  19. //        formatter.setPattern("yyyyMMdd");
  20. //        String dateSuffix = formatter.print(new Date(), Locale.CHINESE);
  21. //        dirPath = SimpleConfig.localPath+"/"+type.getType()+"/"+dateSuffix;
  22. //        String originalFilename = multipartFile.getOriginalFilename();
  23. //        String fileName = type.getType() + "_" +
  24. //                System.currentTimeMillis() +
  25. //                originalFilename.substring(originalFilename.lastIndexOf("."));
  26. //        Path path = Paths.get(dirPath,fileName);
  27. //        Set<PosixFilePermission> permissions = PosixFilePermissions.fromString("r-xr-----");
  28. //        FileAttribute<Set<PosixFilePermission>> fileAttributes = PosixFilePermissions.asFileAttribute(permissions);
  29.         String dirPath = fileFullName.substring(0,fileFullName.lastIndexOf("/"));
  30.         String fileName = fileFullName.substring(fileFullName.lastIndexOf("/")+1);
  31.         Path path = Paths.get(dirPath,fileName);
  32.         boolean dirExist = Files.exists(Paths.get(dirPath));
  33.         if (!dirExist){
  34.             Files.createDirectories(Paths.get(dirPath));
  35.         }
  36.         boolean fileExist = Files.exists(path);
  37.         if (!fileExist) {
  38.             Files.createFile(path);
  39.         }
  40.         Files.copy(multipartFile.getInputStream(),path, StandardCopyOption.REPLACE_EXISTING);
  41.         return SimpleConfig.Url+fileFullName;
  42.     }
  44.     /**
  45.      * 上传文件
  46.      * @param inputStream 文件输入流
  47.      * @param oriFileName 文件名称
  48.      * @param type 文件类型
  49.      * @return
  50.      */
  51.     @SneakyThrows(Exception.class)
  52.     public String upload(InputStream inputStream,String oriFileName, FileType type){
  53.         String dirPath;
  54.         DateFormatter formatter = new DateFormatter();
  55.         formatter.setPattern("yyyyMMdd");
  56.         String dateSuffix = formatter.print(new Date(), Locale.CHINESE);
  57.         dirPath = SimpleConfig.localPath+"/"+type.getType()+"/"+dateSuffix;
  58.         String fileName = type.getType() + "_" +
  59.                 System.currentTimeMillis() +
  60.                 oriFileName.substring(oriFileName.lastIndexOf("."));
  61.         Path path = Paths.get(dirPath,fileName);
  62. //        Set<PosixFilePermission> permissions = PosixFilePermissions.fromString("r-xr-----");
  63. //        FileAttribute<Set<PosixFilePermission>> fileAttributes = PosixFilePermissions.asFileAttribute(permissions);
  64.         boolean dirExist = Files.exists(Paths.get(dirPath));
  65.         if (!dirExist){
  66.             Files.createDirectories(Paths.get(dirPath));
  67.         }
  68.         boolean fileExist = Files.exists(path);
  69.         if (!fileExist) {
  70.             Files.createFile(path);
  71.         }
  72.         Files.copy(inputStream,path, StandardCopyOption.REPLACE_EXISTING);
  73.         return this.getFilePath(type, path.toString());
  74.     }
  76.     /**
  77.      * 获取相对路径
  78.      *
  79.      * @param absolutePath
  80.      * @return
  81.      */
  82.     private String getFilePath(FileType type, String absolutePath) {
  83.         absolutePath = absolutePath.replace("\\", "/");
  84.         int imagePathLength = SimpleConfig.localPath.length();
  85.         String path;
  86.         if (absolutePath.length() > imagePathLength) {
  87.             path = absolutePath.substring(imagePathLength + 1, absolutePath.length());
  88.         } else {
  89.             path = absolutePath.substring(imagePathLength, absolutePath.length());
  90.         }
  91.         return path;
  92.     }
  94. }

mapper
FileMapper

  1. public interface FileMapper extends BaseMapper<FileEntity> {
  3. }

Demo 接口测试

controller

  1. @RestController
  2. public class FileController {
  4.     @Autowired
  5.     IFileService fileService;
  7.     @Autowired
  8.     FileMapper fileMapper;
  10.     private static final Logger log = LoggerFactory.getLogger(FileController.class);
  12.     @PostMapping("/test")
  13.     @ApiOperation(value = "文件上传", response = String.class)
  14.     public void test(@RequestParam("file") MultipartFile file, HttpServletRequest req) {
  15.         if (file.isEmpty()) {
  16. //            return "请选择文件!";
  17.         } else {
  18.             SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
  19.             String date = sdf.format(new Date());
  20.             String path="/"+date+"/"+UUID.randomUUID().toString().replace("-","")+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
  21.             SimpleConfig.Url="116.62.41.96:8081";
  22.             SimpleConfig.localPath="/images";
  23.             String fileName = SimpleConfig.Url+SimpleConfig.localPath+path;
  24.             String url =fileService.upload(file,"",path,UploadType.上传本地);
  25.             System.out.println(url);
  26.         }
  27.     }
  29.     @PostMapping("/upload")
  30.     @ApiOperation(value = "文件上传", response = String.class)
  31.     public String upload(@RequestParam("file") MultipartFile file, HttpServletRequest req) {
  32.         if (file.isEmpty()) {
  33.             return "请选择文件!";
  34.         } else {
  35.             SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd");
  36.             String date = sdf.format(new Date());
  37.             String fileName=date+"/"+UUID.randomUUID().toString().replace("-","")+file.getOriginalFilename().substring(file.getOriginalFilename().lastIndexOf("."));
  38.             String url=fileService.upload(file, MinioConfig.BucketName,fileName, UploadType.上传Minio);
  39.             log.info(url);
  40.             String originalFilename = file.getOriginalFilename();
  41.             FileEntity fileEntity = FileEntity.builder()
  42.                     .fileId(UUID.randomUUID().toString())
  43.                     .fileName(url.substring(url.lastIndexOf("/")+1))
  44.                     .fileType("1")
  45.                     .ext(originalFilename.substring(originalFilename.lastIndexOf(".")+1))
  46.                     .storageName(originalFilename.substring(0,originalFilename.lastIndexOf(".")))
  47.                     .fileSize((double)file.getSize())
  48.                     .url(url)
  49.                     .uri(fileName)
  50.                     .insertDatetime(new Date())
  51.                     .lastUpdateTime(new Date())
  52.                     .build();
  53.             System.out.println(fileEntity);
  54.             fileMapper.insert(fileEntity);
  55.             return JSONObject.toJSONString(fileEntity);
  56.         }
  57.     }
  60. }