devbox
代码探险家
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

【Java】java实现文件上传和下载（上传到指定路径/数据库/minio）_java 上传文件

作者：代码探险家 | 2024-07-22 13:02:55

赞

踩

java 上传文件

目录

上传到指定路径

一、代码层级结构

二、文件上传接口

三、使用postman进行测试；

MultipartFile接收前端传递的文件：127.0.0.1:8082/path/uploadFile

part接收前端传递的文件：127.0.0.1:8082/path/uploadFileByRequest

四、上传文件大小设置

五、文件下载接口

六、使用postman进行测试

上传至数据库

一、代码层级结构

二、文件上传接口

三、文件下载接口

四、使用postman进行测试

上传至Minio

一、代码层级结构

二、文件上传/下载接口

MinioUtils

        InitConfig

        MinioConfig

三、使用postman进行测试

        业务分析：实际开发过程中，我们经常对文件的上传和下载的功能实现，所以这也是一个程序员应该掌握的基本开发能力。所以下面我给大家分享一下文件上传和下载的三种方式，分别将文件上传到指定路径下/本地数据库/minio当中。

       所有代码都以上传至压缩包资源，可以自行免费进行下载测试；

所有application.yml为：

  1. # MyBatis
  2. mybatis:
  3.   mapper-locations: classpath*:mapper/*.xml
  4. server:
  5.   port: 8888
  6. spring:
  7.   application:
  8.     name: user-service
  9.   datasource:
  10.     url: jdbc:mysql://127.0.0.1:3306/xxx
  11.     username: root
  12.     password: xxx
  13.     driver-class-name: com.mysql.cj.jdbc.Driver
  14.  
  15. # Redis
  16.   data:
  17.     redis:
  18.       port: 6379
  19.       username:
  20.       password:
  21.       host: 127.0.0.1
  22. # Minio
  23. minio:
  24.   access-key: "username"
  25.   secret-key: "password"
  26.   end-point: "http://127.0.0.1:9000/"
  27.   bucket: "playedu"
  28.   domain: "http://127.0.0.1:9000/"

上传到指定路径

一、代码层级结构

        

二、文件上传接口

  1. /**
  2.  * 上传到指定路径下
  3.  */
  4. @RestController
  5. @Slf4j
  6. @RequestMapping("/path")
  7. public class UploadController {
  8.  
  9.     @Autowired
  10.     private ResourceLoader resourceLoader;
  11.  
  12.  
  13.     private BufferedOutputStream bufferedOutputStream = null;
  14.  
  15.  
  16.     /**
  17.      * form-data 类型
  18.      * form-data 类型即常用的表单提交
  19.      * 两种处理参数的方式
  20.      * <p>
  21.      * MultipartFile 类接受前台传过来的文件
  22.      * part 接收字节流
  23.      */
  24.     @PostMapping("/uploadFile")
  25.     public String uploadFile(@RequestParam("name") String name, @RequestPart("file1") MultipartFile file1, @RequestPart("file2") MultipartFile[] file2) throws IOException, ServletException {
  26.  
  27.  
  28.         // 获取项目部署路径
  29.        /* String appPath = request.getServletContext().getRealPath("/");
  30.         // 构建上传文件的目录路径
  31.         String path = appPath + "static/upload/";*/
  32.  
  33.         //绝对路劲
  34. //        String path = "D:\\Users\\MXIN\\IdeaProjects\\springboot-uploadanddownload\\src\\main\\resources\\static\\";
  35.         //相对路径
  36.         String path = "src/main/resources/static/";
  37.  
  38.         //前端传递多个file（只对file2进行处理）
  39.         for (MultipartFile multipartFile : file2) {
  40. //            使用 MultipartFile 字节流保存文件
  41.             fileUtil(multipartFile, String.valueOf(path));
  42.         }
  43.         fileUtil(file1, String.valueOf(path));
  44.  
  45.         return "success";
  46.     }
  47.  
  48.     /**
  49.      * part 接收字节流
  50.      */
  51.     @PostMapping("/uploadFileByRequest")
  52.     public String uploadFileByRequest(HttpServletRequest request) throws IOException, ServletException {
  53.         // 获取项目部署路径
  54.        /* String appPath = request.getServletContext().getRealPath("/");
  55.         // 构建上传文件的目录路径
  56.         String path = appPath + "static/upload/";*/
  57.  
  58.         //绝对路劲
  59.         String path = "D:\\Users\\MXIN\\IdeaProjects\\springboot-uploadanddownload\\src\\main\\resources\\static\\";
  60.  
  61.  
  62. //		使用 Part 接收文件字节流
  63. //        Part file1 = request.getPart("file1");
  64. //        file1.write(path + file1.getSubmittedFileName());
  65.  
  66.         // request.getParts() 获取的是全部参数（name,age,file1,file2），包括文件参数和非文件参数
  67.         for (Part part : request.getParts()) {
  68.             // 获取文件类型
  69.             String contentType = part.getContentType();
  70.             // 获取文件大小
  71.             long size = part.getSize();
  72.             // 获取文件名
  73.             String submittedFileName = part.getSubmittedFileName();
  74.            
  75.             if (part.getContentType() != null) {
  76.                 //如果是文件会进行写入
  77.                 part.write(path + part.getSubmittedFileName());
  78.             } else {
  79.                 // 如果是参数会获取参数（根据实际需求对参数进行处理）
  80.                 // 获取参数名 
  81.                 String name1 = part.getName();
  82.             }
  83.         }
  84.         return "success";
  85.     }
  86.  
  87.  
  88.     public String fileUtil(MultipartFile file, String path) {
  89.  
  90.         if (!file.isEmpty()) {
  91.             try {
  92.                 byte[] bytes = file.getBytes();
  93.                 bufferedOutputStream = new BufferedOutputStream(new FileOutputStream(
  94.                         new File(path + file.getOriginalFilename())));
  95.                 bufferedOutputStream.write(bytes);
  96.                 bufferedOutputStream.close();
  97.                 return file.getOriginalFilename() + "上传成功";
  98.             } catch (Exception e) {
  99.                 return file.getOriginalFilename() + "上传失败，错误信息为：" + e;
  100.             }
  101.         } else {
  102.             return "上传得文件为空";
  103.         }
  104.     }
  105.  
  106.  
  107. }

三、使用postman进行测试；

MultipartFile接收前端传递的文件：127.0.0.1:8082/path/uploadFile

测试结果

part接收前端传递的文件：127.0.0.1:8082/path/uploadFileByRequest

测试结果

四、上传文件大小设置

        由于springboot默认上传文件大小为1M，单个请求最大为10M，当文件超过1M会报错。所以可以通过配置文件限制文件上传大小。

上传大于1M报错信息为：

Resolved [org.springframework.web.multipart.MaxUploadSizeExceededException: Maximum upload size exceeded]

所以修改配置文件（根据自己实际开发需求进行修改）：

上述简单的介绍了文件上传到指定路径下的方法，下面来简单介绍一下文件下载是如何实现的。

五、文件下载接口

  1. /**
  2.  * 下载指定路径下的文件
  3.  * */
  4. @RestController
  5. @Slf4j
  6. @RequestMapping("/path")
  7. public class DownloadController {
  8.  
  9.     /**
  10.      * 文件下载 isOnline默认为false
  11.      */
  12.     @GetMapping("/download")
  13.     public void download(String fileName, HttpServletResponse response, boolean isOnLine) throws IOException {
  14.         // 路径可以指定当前项目相对路径
  15.         File file = new File("D:\\Users\\Mixi\\IdeaProjects\\springboot-uploadanddownload\\src\\main\\resources\\static\\" + fileName);
  16.         if (file.exists()) {
  17.             FileInputStream fileInputStream = new FileInputStream(file);
  18.             ServletOutputStream outputStream = response.getOutputStream();
  19.  
  20.             // 获取文件扩展名
  21.             String extension = fileName.substring(fileName.lastIndexOf(".") + 1);
  22.  
  23.             if (!isOnLine) {
  24.                 // 根据文件扩展名设置Content-Type
  25.                 String contentType = getContentType(extension);
  26.                 response.setContentType(contentType);
  27.  
  28.                 // 如果文件名为中文需要设置编码
  29.                 response.setHeader("Content-Disposition", "attachment;fileName=" + URLEncoder.encode(fileName, "utf8"));
  30.                 // 返回前端文件名需要添加
  31.                 response.setHeader("Access-Control-Expose-Headers", "Content-Disposition");
  32.             }
  33.             byte[] bytes = new byte[1024];
  34.             int len;
  35.             while ((len = fileInputStream.read(bytes)) != -1) {
  36.                 outputStream.write(bytes, 0, len);
  37.             }
  38.         }
  39.     }
  40.  
  41.     // 根据文件扩展名获取Content-Type
  42.     private String getContentType(String extension) {
  43.         if ("jpg".equalsIgnoreCase(extension) || "jpeg".equalsIgnoreCase(extension)) {
  44.             return "image/jpeg";
  45.         } else if ("png".equalsIgnoreCase(extension)) {
  46.             return "image/png";
  47.         } else if ("gif".equalsIgnoreCase(extension)) {
  48.             return "image/gif";
  49.         } else if ("txt".equalsIgnoreCase(extension)) {
  50.             return "text/plain";
  51.         } else if ("pdf".equalsIgnoreCase(extension)) {
  52.             return "application/pdf";
  53.         } else if ("doc".equalsIgnoreCase(extension) || "docx".equalsIgnoreCase(extension)) {
  54.             return "application/msword";
  55.         } else if ("xls".equalsIgnoreCase(extension) || "xlsx".equalsIgnoreCase(extension)) {
  56.             return "application/vnd.ms-excel";
  57.         } else if ("ppt".equalsIgnoreCase(extension) || "pptx".equalsIgnoreCase(extension)) {
  58.             return "application/vnd.ms-powerpoint";
  59.         } else if ("zip".equalsIgnoreCase(extension)) {
  60.             return "application/zip";
  61.         } else if ("tar".equalsIgnoreCase(extension)) {
  62.             return "application/x-tar";
  63.         } else if ("rar".equalsIgnoreCase(extension)) {
  64.             return "application/x-rar-compressed";
  65.         } else if ("gz".equalsIgnoreCase(extension)) {
  66.             return "application/gzip";
  67.         } else {
  68.             return "application/octet-stream";
  69.         }
  70.     }
  71. }

六、使用postman进行测试

isOnlie为true和false决定了是否在浏览器上在线查看。

上传至数据库

这种业务需求就是用于项目开发过程中，文件上传下载的功能用的很少，避免搭建部署文件存储的服务器，简化了部署和管理，节约成本资源。

一、代码层级结构

二、文件上传接口

UploadToDBController：

  1. /**
  2.  * 上传到数据库
  3.  * */
  4. @RestController
  5. @Slf4j
  6. @RequestMapping("/db")
  7. public class UploadToDBController {
  8.  
  9.     @Autowired
  10.     private FilesService filesService;
  11.  
  12.  
  13.     @PostMapping("/uploadFile")
  14.     public Files inputFile(@RequestParam("file") MultipartFile file) {
  15.  
  16.         Files files = new Files();
  17.         if (null != file) {
  18.             String name = file.getOriginalFilename();
  19.             byte[] bytes;
  20.             try {
  21.                 bytes = file.getBytes();
  22.             } catch (IOException e) {
  23.                 throw new RuntimeException(e);
  24.             }
  25.             files.setName(name);
  26.             files.setFile(bytes);
  27.             filesService.save(files);
  28.         }
  29.         return files;
  30.     }
  31. }

FilesServiceImpl：

  1.     @Override
  2.     public void save(Files files) {
  3.         filesMapper.insert(files);
  4.     }

简单代码的增删改查我就不写了哈。

三、文件下载接口

DownloadFromDBController：

  1. /**
  2.  * 从数据库下载
  3.  */
  4. @RestController
  5. @Slf4j
  6. @RequestMapping("/db")
  7. public class DownloadFromDBController {
  8.  
  9.     @Autowired
  10.     private FilesService filesService;
  11.  
  12.     @GetMapping("/download/{id}")
  13.     public void download(HttpServletResponse response, @PathVariable("id") Integer id) {
  14.         filesService.download(response,id);
  15.     }
  16. }

FilesServiceImpl：

  1.  @Override
  2.     public HttpServletResponse download(HttpServletResponse response, Integer id) {
  3.         try {
  4.             byte[] buf;
  5.             Files byId = filesMapper.selectById(id);
  6.             if (byId == null) {
  7.                 return response;
  8.             }
  9.             buf = byId.getFile();
  10.             String suffix = FileToMultipartFile.getSuffix(byId.getName());
  11.             String contentType = "";
  12.             switch (Objects.requireNonNull(FileTypeEnum.getEnum(suffix))) {
  13.                 case DOC:
  14.                     contentType = "application/msword";
  15.                     break;
  16.                 case DOCX:
  17.                     contentType = "application/vnd.openxmlformats-officedocument.wordprocessingml.document";
  18.                     break;
  19.                 case PDF:
  20.                     contentType = "application/powerpoint";
  21.                     break;
  22.                 case JPE:
  23.                 case JPG:
  24.                 case JPEG:
  25.                     contentType = "image/jpeg";
  26.                     break;
  27.                 case PNG:
  28.                     contentType = "image/png";
  29.                     break;
  30.                 case ZIP:
  31.                     contentType = "application/zip";
  32.                     break;
  33.                 case TAR:
  34.                     contentType = "application/x-tar";
  35.                     break;
  36.                 case GZ:
  37.                     contentType = "application/x-gzip";
  38.                     break;
  39.                 case XLS:
  40.                     contentType = "application/vnd.ms-excel";
  41.                     break;
  42.                 case XLSX:
  43.                     contentType = "application/vnd.openxmlformats-officedocument.spreadsheetml.sheet";
  44.                     break;
  45.                 case PPT:
  46.                     contentType = "application/vnd.ms-powerpoint";
  47.                     break;
  48.                 case PPTX:
  49.                     contentType = "application/vnd.openxmlformats-officedocument.presentationml.presentation";
  50.                     break;
  51.             }
  52.  
  53.             // 清空
  54.             response.reset();
  55.             String encodedFileName = URLEncoder.encode(byId.getName().replaceAll(" ", "+"), "UTF-8");
  56.             // 设置header
  57.             response.addHeader("Content-Disposition", "attachment;filename=" + encodedFileName);
  58. //            response.addHeader("Content-Length", "" + byId.getFileNo());
  59.             response.setCharacterEncoding("UTF-8");
  60.             response.setContentType(contentType);
  61.             response.getOutputStream().write(buf);
  62.             // 强制输出，不然会留在内存里丢失掉
  63.             response.getOutputStream().flush();
  64.             return response;
  65.         } catch (Exception e) {
  66.             throw new RuntimeException(e);
  67.         }
  68.     }

四、使用postman进行测试

文件上传：

测试结果数据库：

文件下载：

 测试结果：

上传至Minio

        首先要在本地或者服务器上部署minio并启动才可以进行文件的上传和下载，还未安装minio的可以参考一下这篇文章：【Docker】手把手教你在windows使用Docker安装Minio[详细教程]_minio windows-CSDN博客

一、代码层级结构

二、文件上传/下载接口

  1. /**
  2.  * 文件上传、下载、删除、获取文件信息、获取文件url接口
  3.  * */
  4. @Slf4j
  5. @RestController
  6. @RequestMapping("/oss")
  7. public class MinioController {
  8.  
  9.     @Autowired
  10.     private MinioUtils minioUtils;
  11.  
  12.     @Autowired
  13.     private MinioConfig minioConfig;
  14.  
  15.     /**
  16.      * 文件上传
  17.      *
  18.      * @param file
  19.      */
  20.     @PostMapping("/upload")
  21.     public String upload(@RequestParam("file") MultipartFile file) {
  22.         try {
  23.             //文件名
  24.             String fileName = file.getOriginalFilename();
  25.             String newFileName = System.currentTimeMillis() + "." + StringUtils.substringAfterLast(fileName, ".");
  26.             //类型
  27.             String contentType = file.getContentType();
  28.             minioUtils.uploadFile(minioConfig.getBucketName(), file, newFileName, contentType);
  29.             return "上传成功,文件名：" + newFileName;
  30.         } catch (Exception e) {
  31.             e.printStackTrace();
  32.             return "上传失败";
  33.         }
  34.     }
  35.  
  36.     /**
  37.      * 删除
  38.      *
  39.      * @param fileName
  40.      */
  41.     @DeleteMapping("/")
  42.     public void delete(@RequestParam("fileName") String fileName) {
  43.         minioUtils.removeFile(minioConfig.getBucketName(), fileName);
  44.     }
  45.  
  46.     /**
  47.      * 获取文件信息
  48.      *
  49.      * @param fileName
  50.      * @return
  51.      */
  52.     @GetMapping("/info")
  53.     public String getFileStatusInfo(@RequestParam("fileName") String fileName) {
  54.         return minioUtils.getFileStatusInfo(minioConfig.getBucketName(), fileName);
  55.     }
  56.  
  57.     /**
  58.      * 获取文件外链
  59.      *
  60.      * @param fileName
  61.      * @return
  62.      */
  63.     @GetMapping("/url")
  64.     public String getPresignedObjectUrl(@RequestParam("fileName") String fileName) {
  65.         return minioUtils.getPresignedObjectUrl(minioConfig.getBucketName(), fileName);
  66.     }
  67.  
  68.     /**
  69.      * 文件下载
  70.      *
  71.      * @param fileName
  72.      * @param response
  73.      */
  74.     @GetMapping("/download")
  75.     public void download(@RequestParam("fileName") String fileName, HttpServletResponse response) {
  76.         try {
  77.             InputStream fileInputStream = minioUtils.getObject(minioConfig.getBucketName(), fileName);
  78.             response.setHeader("Content-Disposition", "attachment;filename=" + fileName);
  79.             response.setContentType("application/force-download");
  80.             response.setCharacterEncoding("UTF-8");
  81.             IOUtils.copy(fileInputStream, response.getOutputStream());
  82.         } catch (Exception e) {
  83.             log.error("下载失败");
  84.         }
  85.     }
  86. }

MinioUtils

  1. @Slf4j
  2. @Component
  3. public class MinioUtils {
  4.  
  5.     @Autowired
  6.     private MinioClient minioClient;
  7.  
  8.  
  9.     /**
  10.      * 启动SpringBoot容器的时候初始化Bucket
  11.      * 如果没有Bucket则创建
  12.      *
  13.      * @param bucketName
  14.      */
  15.     public void createBucket(String bucketName) {
  16.         try {
  17.             if (!bucketExists(bucketName)) {
  18.                 minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
  19.                 log.info("创建bucketName = {}完成!", bucketName);
  20.                 return;
  21.             }
  22.             log.info("bucketName = {}已存在！策略为：{}", bucketName, getBucketPolicy(bucketName));
  23.         } catch (Exception e) {
  24.             log.error("创建bucketName = {}异常!e = {}", bucketName, e);
  25.         }
  26.     }
  27.  
  28.     /**
  29.      * 判断Bucket是否存在，true：存在，false：不存在
  30.      *
  31.      * @param bucketName
  32.      * @return
  33.      */
  34.     @SneakyThrows
  35.     public boolean bucketExists(String bucketName) {
  36.         return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
  37.     }
  38.  
  39.     /**
  40.      * 获得Bucket的策略
  41.      *
  42.      * @param bucketName
  43.      * @return
  44.      */
  45.     @SneakyThrows
  46.     public String getBucketPolicy(String bucketName) {
  47.         return minioClient.getBucketPolicy(GetBucketPolicyArgs.builder().bucket(bucketName).build());
  48.     }
  49.  
  50.     /**
  51.      * 获得所有Bucket列表
  52.      *
  53.      * @return
  54.      */
  55.     @SneakyThrows
  56.     public List<Bucket> getAllBuckets() {
  57.         return minioClient.listBuckets();
  58.     }
  59.  
  60.     /**
  61.      * 根据bucketName获取其相关信息
  62.      *
  63.      * @param bucketName
  64.      * @return
  65.      */
  66.     @SneakyThrows(Exception.class)
  67.     public Optional<Bucket> getBucket(String bucketName) {
  68.         return getAllBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();
  69.     }
  70.  
  71.     /**
  72.      * 根据bucketName删除Bucket，true：删除成功； false：删除失败，文件或已不存在
  73.      *
  74.      * @param bucketName
  75.      * @throws Exception
  76.      */
  77.     @SneakyThrows(Exception.class)
  78.     public void removeBucket(String bucketName) {
  79.         minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());
  80.     }
  81.  
  82.  
  83.     /**
  84.      * 判断文件是否存在
  85.      *
  86.      * @param bucketName
  87.      * @param objectName
  88.      * @return
  89.      */
  90.     public boolean isObjectExist(String bucketName, String objectName) {
  91.         boolean exist = true;
  92.         try {
  93.             minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build());
  94.         } catch (Exception e) {
  95.             log.error("[Minio工具类]>>>> 判断文件是否存在, 异常：", e);
  96.             exist = false;
  97.         }
  98.         return exist;
  99.     }
  100.  
  101.     /**
  102.      * 判断文件夹是否存在
  103.      *
  104.      * @param bucketName
  105.      * @param objectName
  106.      * @return
  107.      */
  108.     public boolean isFolderExist(String bucketName, String objectName) {
  109.         boolean exist = false;
  110.         try {
  111.             Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(objectName).recursive(false).build());
  112.             for (Result<Item> result : results) {
  113.                 Item item = result.get();
  114.                 if (item.isDir() && objectName.equals(item.objectName())) {
  115.                     exist = true;
  116.                 }
  117.             }
  118.         } catch (Exception e) {
  119.             log.error("[Minio工具类]>>>> 判断文件夹是否存在，异常：", e);
  120.             exist = false;
  121.         }
  122.         return exist;
  123.     }
  124.  
  125.     /**
  126.      * 根据文件前置查询文件
  127.      *
  128.      * @param bucketName 存储桶
  129.      * @param prefix     前缀
  130.      * @param recursive  是否使用递归查询
  131.      * @return MinioItem 列表
  132.      */
  133.     @SneakyThrows(Exception.class)
  134.     public List<Item> getAllObjectsByPrefix(String bucketName, String prefix, boolean recursive) {
  135.         List<Item> list = new ArrayList<>();
  136.         Iterable<Result<Item>> objectsIterator = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(recursive).build());
  137.         if (objectsIterator != null) {
  138.             for (Result<Item> o : objectsIterator) {
  139.                 Item item = o.get();
  140.                 list.add(item);
  141.             }
  142.         }
  143.         return list;
  144.     }
  145.  
  146.     /**
  147.      * 获取文件流
  148.      *
  149.      * @param bucketName 存储桶
  150.      * @param objectName 文件名
  151.      * @return 二进制流
  152.      */
  153.     @SneakyThrows(Exception.class)
  154.     public InputStream getObject(String bucketName, String objectName) {
  155.         return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(objectName).build());
  156.     }
  157.  
  158.     /**
  159.      * 断点下载
  160.      *
  161.      * @param bucketName 存储桶
  162.      * @param objectName 文件名称
  163.      * @param offset     起始字节的位置
  164.      * @param length     要读取的长度
  165.      * @return 二进制流
  166.      */
  167.     @SneakyThrows(Exception.class)
  168.     public InputStream getObject(String bucketName, String objectName, long offset, long length) {
  169.         return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(objectName).offset(offset).length(length).build());
  170.     }
  171.  
  172.     /**
  173.      * 获取路径下文件列表
  174.      *
  175.      * @param bucketName 存储桶
  176.      * @param prefix     文件名称
  177.      * @param recursive  是否递归查找，false：模拟文件夹结构查找
  178.      * @return 二进制流
  179.      */
  180.     public Iterable<Result<Item>> listObjects(String bucketName, String prefix, boolean recursive) {
  181.         return minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(recursive).build());
  182.     }
  183.  
  184.     /**
  185.      * 使用MultipartFile进行文件上传
  186.      *
  187.      * @param bucketName  存储桶
  188.      * @param file        文件名
  189.      * @param objectName  对象名
  190.      * @param contentType 类型
  191.      * @return
  192.      */
  193.     @SneakyThrows(Exception.class)
  194.     public ObjectWriteResponse uploadFile(String bucketName, MultipartFile file, String objectName, String contentType) {
  195.         InputStream inputStream = file.getInputStream();
  196.         return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).contentType(contentType).stream(inputStream, inputStream.available(), -1).build());
  197.     }
  198.  
  199.     /**
  200.      * 图片上传
  201.      *
  202.      * @param bucketName
  203.      * @param imageBase64
  204.      * @param imageName
  205.      * @return
  206.      */
  207.     public ObjectWriteResponse uploadImage(String bucketName, String imageBase64, String imageName) {
  208.         if (!StringUtils.isEmpty(imageBase64)) {
  209.             InputStream in = base64ToInputStream(imageBase64);
  210.             String newName = System.currentTimeMillis() + "_" + imageName + ".jpg";
  211.             String year = String.valueOf(new Date().getYear());
  212.             String month = String.valueOf(new Date().getMonth());
  213.             return uploadFile(bucketName, year + "/" + month + "/" + newName, in);
  214.  
  215.         }
  216.         return null;
  217.     }
  218.  
  219.     public static InputStream base64ToInputStream(String base64) {
  220.         ByteArrayInputStream stream = null;
  221.         try {
  222.             byte[] bytes = Base64.getEncoder().encode(base64.trim().getBytes());
  223.             stream = new ByteArrayInputStream(bytes);
  224.         } catch (Exception e) {
  225.             e.printStackTrace();
  226.         }
  227.         return stream;
  228.     }
  229.  
  230.  
  231.     /**
  232.      * 上传本地文件
  233.      *
  234.      * @param bucketName 存储桶
  235.      * @param objectName 对象名称
  236.      * @param fileName   本地文件路径
  237.      * @return
  238.      */
  239.     @SneakyThrows(Exception.class)
  240.     public ObjectWriteResponse uploadFile(String bucketName, String objectName, String fileName) {
  241.         return minioClient.uploadObject(UploadObjectArgs.builder().bucket(bucketName).object(objectName).filename(fileName).build());
  242.     }
  243.  
  244.     /**
  245.      * 通过流上传文件
  246.      *
  247.      * @param bucketName  存储桶
  248.      * @param objectName  文件对象
  249.      * @param inputStream 文件流
  250.      * @return
  251.      */
  252.     @SneakyThrows(Exception.class)
  253.     public ObjectWriteResponse uploadFile(String bucketName, String objectName, InputStream inputStream) {
  254.         return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(inputStream, inputStream.available(), -1).build());
  255.     }
  256.  
  257.     /**
  258.      * 创建文件夹或目录
  259.      *
  260.      * @param bucketName 存储桶
  261.      * @param objectName 目录路径
  262.      * @return
  263.      */
  264.     @SneakyThrows(Exception.class)
  265.     public ObjectWriteResponse createDir(String bucketName, String objectName) {
  266.         return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(new ByteArrayInputStream(new byte[]{}), 0, -1).build());
  267.     }
  268.  
  269.     /**
  270.      * 获取文件信息, 如果抛出异常则说明文件不存在
  271.      *
  272.      * @param bucketName 存储桶
  273.      * @param objectName 文件名称
  274.      * @return
  275.      */
  276.     @SneakyThrows(Exception.class)
  277.     public String getFileStatusInfo(String bucketName, String objectName) {
  278.         return minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build()).toString();
  279.     }
  280.  
  281.     /**
  282.      * 拷贝文件
  283.      *
  284.      * @param bucketName    存储桶
  285.      * @param objectName    文件名
  286.      * @param srcBucketName 目标存储桶
  287.      * @param srcObjectName 目标文件名
  288.      */
  289.     @SneakyThrows(Exception.class)
  290.     public ObjectWriteResponse copyFile(String bucketName, String objectName, String srcBucketName, String srcObjectName) {
  291.         return minioClient.copyObject(CopyObjectArgs.builder().source(CopySource.builder().bucket(bucketName).object(objectName).build()).bucket(srcBucketName).object(srcObjectName).build());
  292.     }
  293.  
  294.     /**
  295.      * 删除文件
  296.      *
  297.      * @param bucketName 存储桶
  298.      * @param objectName 文件名称
  299.      */
  300.     @SneakyThrows(Exception.class)
  301.     public void removeFile(String bucketName, String objectName) {
  302.         minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(objectName).build());
  303.     }
  304.  
  305.     /**
  306.      * 批量删除文件
  307.      *
  308.      * @param bucketName 存储桶
  309.      * @param keys       需要删除的文件列表
  310.      * @return
  311.      */
  312.     public void removeFiles(String bucketName, List<String> keys) {
  313.         List<DeleteObject> objects = new LinkedList<>();
  314.         keys.forEach(s -> {
  315.             objects.add(new DeleteObject(s));
  316.             try {
  317.                 removeFile(bucketName, s);
  318.             } catch (Exception e) {
  319.                 log.error("[Minio工具类]>>>> 批量删除文件，异常：", e);
  320.             }
  321.         });
  322.     }
  323.  
  324.     /**
  325.      * 获取文件外链
  326.      *
  327.      * @param bucketName 存储桶
  328.      * @param objectName 文件名
  329.      * @param expires    过期时间 <=7 秒 （外链有效时间（单位：秒））
  330.      * @return url
  331.      */
  332.     @SneakyThrows(Exception.class)
  333.     public String getPresignedObjectUrl(String bucketName, String objectName, Integer expires) {
  334.         GetPresignedObjectUrlArgs args = GetPresignedObjectUrlArgs.builder().expiry(expires).bucket(bucketName).object(objectName).build();
  335.         return minioClient.getPresignedObjectUrl(args);
  336.     }
  337.  
  338.     /**
  339.      * 获得文件外链
  340.      *
  341.      * @param bucketName
  342.      * @param objectName
  343.      * @return url
  344.      */
  345.     @SneakyThrows(Exception.class)
  346.     public String getPresignedObjectUrl(String bucketName, String objectName) {
  347.         GetPresignedObjectUrlArgs args = GetPresignedObjectUrlArgs.builder().bucket(bucketName).object(objectName).method(Method.GET).build();
  348.         return minioClient.getPresignedObjectUrl(args);
  349.     }
  350.  
  351.     /**
  352.      * 将URLDecoder编码转成UTF8
  353.      *
  354.      * @param str
  355.      * @return
  356.      * @throws UnsupportedEncodingException
  357.      */
  358.     public String getUtf8ByURLDecoder(String str) throws UnsupportedEncodingException {
  359.         String url = str.replaceAll("%(?![0-9a-fA-F]{2})", "%25");
  360.         return URLDecoder.decode(url, "UTF-8");
  361.     }
  362. }

        InitConfig

  1.  
  2. @Component
  3. @Slf4j
  4.     public class InitConfig implements InitializingBean {
  5.  
  6.     @Autowired
  7.     private MinioUtils minioUtils;
  8.  
  9.  
  10.     @Autowired
  11.     private MinioConfig minioConfig;
  12.  
  13.     @Override
  14.     public void afterPropertiesSet() throws Exception {
  15.         // 项目启动创建Bucket，不存在则进行创建
  16.         minioUtils.createBucket(minioConfig.getBucketName());
  17.     }
  18. }

        MinioConfig

  1.  
  2. import io.minio.MinioClient;
  3. import lombok.Data;
  4.  
  5. import org.springframework.beans.factory.annotation.Value;
  6. import org.springframework.context.annotation.Bean;
  7. import org.springframework.context.annotation.Configuration;
  8.  
  9. @Data
  10. @Configuration
  11. public class MinioConfig {
  12.  
  13.     /**
  14.      * 访问地址
  15.      */
  16.  
  17.     @Value("${minio.end-point}")
  18.     private String endpoint;
  19.  
  20.     /**
  21.      * accessKey类似于用户ID，用于唯一标识你的账户
  22.      */
  23.     @Value("${minio.access-key}")
  24.     private String accessKey;
  25.  
  26.     /**
  27.      * secretKey是你账户的密码
  28.      */
  29.     @Value("${minio.secret-key}")
  30.     private String secretKey;
  31.  
  32.     /**
  33.      * 默认存储桶
  34.      */
  35.     @Value("${minio.bucket}")
  36.     private String bucketName;
  37.  
  38.     @Bean
  39.     public MinioClient minioClient() {
  40.         MinioClient minioClient = MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();
  41.         return minioClient;
  42.     }
  43. }

三、使用postman进行测试

文件上传到minio

测试结果：

从minio中下载文件

 

直接下载即可，这样就完成了从minio中下载指定文件，还有部分接口，如果感兴趣的小伙伴可以自行测试看下实际效果。

        综上所有的代码就简单的介绍了一下Java实现文件上传和下载，希望能给你们实际开发带来一定的帮助，如果有出现问题的地方，希望指出，便于后续修改。

所有源码均以上传至https://download.csdn.net/download/m0_64210833/89233948

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/代码探险家/article/detail/865264
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号