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

       
目录
上传到指定路径
一、代码层级结构
二、文件上传接口
三、利用postman进行测试；
MultipartFile接收前端通报的文件：127.0.0.1:8082/path/uploadFile
part接收前端通报的文件：127.0.0.1:8082/path/uploadFileByRequest
接收前端通报binary 类型：127.0.0.1:8082/path/upload2
四、springboot 配置
五、文件下载接口
六、利用postman进行测试
上传至数据库
一、代码层级结构
二、文件上传接口
三、文件下载接口
四、利用postman进行测试
上传至Minio
一、代码层级结构
二、文件上传/下载接口
MinioUtils
三、利用postman进行测试

---

        业务分析：现实开辟过程中，我们常常对文件的上传和下载的功能实现，所以这也是一个步伐员应该把握的基本开辟本领。所以下面我给大家分享一下文件上传和下载的三种方式，分别将文件上传到指定路径下/本地数据库/minio当中。
       所有代码都以上传至压缩包资源，可以自行免费进行下载测试；
上传到指定路径

一、代码层级结构

        

二、文件上传接口

1. /**
2. * 上传到指定路径下
3. */
4. @RestController
5. @Slf4j
6. @RequestMapping("/path")
7. public class UploadController {
9.     @Autowired
10.     private ResourceLoader resourceLoader;
13.     private BufferedOutputStream bufferedOutputStream = null;
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 {
28.         // 获取项目部署路径
29.        /* String appPath = request.getServletContext().getRealPath("/");
30.         // 构建上传文件的目录路径
31.         String path = appPath + "static/upload/";*/
33.         //绝对路劲
34. //        String path = "D:\\Users\\MXIN\\IdeaProjects\\springboot-uploadanddownload\\src\\main\\resources\\static\";
35.         //相对路径
36.         String path = "src/main/resources/static/";
38.         //前端传递多个file（只对file2进行处理）
39.         for (MultipartFile multipartFile : file2) {
40. //            使用 MultipartFile 字节流保存文件
41.             fileUtil(multipartFile, String.valueOf(path));
42.         }
43.         fileUtil(file1, String.valueOf(path));
45.         return "success";
46.     }
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/";*/
58.         //绝对路劲
59.         String path = "D:\\Users\\MXIN\\IdeaProjects\\springboot-uploadanddownload\\src\\main\\resources\\static\";
62. //                使用 Part 接收文件字节流
63. //        Part file1 = request.getPart("file1");
64. //        file1.write(path + file1.getSubmittedFileName());
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.     }
88.     public String fileUtil(MultipartFile file, String path) {
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.     }
107. }

复制代码

三、利用postman进行测试；

MultipartFile接收前端通报的文件：127.0.0.1:8082/path/uploadFile

测试效果

part接收前端通报的文件：127.0.0.1:8082/path/uploadFileByRequest

测试效果

 
四、上传文件巨细设置

        由于springboot默认上传文件巨细为1M，单个哀求最大为10M，当文件凌驾1M会报错。所以可以通过配置文件限定文件上传巨细。

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

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

复制代码

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

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

五、文件下载接口

1. /**
2. * 下载指定路径下的文件
3. * */
4. @RestController
5. @Slf4j
6. @RequestMapping("/path")
7. public class DownloadController {
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();
20.             // 获取文件扩展名
21.             String extension = fileName.substring(fileName.lastIndexOf(".") + 1);
23.             if (!isOnLine) {
24.                 // 根据文件扩展名设置Content-Type
25.                 String contentType = getContentType(extension);
26.                 response.setContentType(contentType);
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.     }
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 {
9.     @Autowired
10.     private FilesService filesService;
13.     @PostMapping("/uploadFile")
14.     public Files inputFile(@RequestParam("file") MultipartFile file) {
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 {
9.     @Autowired
10.     private FilesService filesService;
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.             }
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 {
9.     @Autowired
10.     private MinioUtils minioUtils;
12.     @Autowired
13.     private MinioConfig minioConfig;
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.     }
36.     /**
37.      * 删除
38.      *
39.      * @param fileName
40.      */
41.     @DeleteMapping("/")
42.     public void delete(@RequestParam("fileName") String fileName) {
43.         minioUtils.removeFile(minioConfig.getBucketName(), fileName);
44.     }
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.     }
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.     }
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 {
5.     @Autowired
6.     private MinioClient minioClient;
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.     }
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.     }
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.     }
50.     /**
51.      * 获得所有Bucket列表
52.      *
53.      * @return
54.      */
55.     @SneakyThrows
56.     public List<Bucket> getAllBuckets() {
57.         return minioClient.listBuckets();
58.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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);
215.         }
216.         return null;
217.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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.     }
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. }

复制代码

三、利用postman进行测试

文件上传到minio

测试效果：

从minio中下载文件

 

直接下载即可，这样就完成了从minio中下载指定文件，另有部门接口，如果感兴趣的小伙伴可以自行测试看下现实效果。
        综上所有的代码就简朴的介绍了一下Java实现文件上传和下载，希望能给你们现实开辟带来肯定的帮助，如果有出现问题的地方，希望指出，便于后续修改。
所有源码均以上传至https://download.csdn.net/download/m0_64210833/89233948

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。