Java分布式文件对象存储Minio框架并发上传、下载、合并、删除等操作示例Demo完整版

package com.anx.minio.controller; import io.minio.*; import io.minio.http.Method; import io.minio.messages.Bucket; import io.minio.messages.DeleteError; import io.minio.messages.DeleteObject; import io.minio.messages.Item; import lombok.extern.slf4j.Slf4j; import okhttp3.*; import org.apache.commons.io.IOUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.http.client.MultipartBodyBuilder; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.*; import org.springframework.web.multipart.MultipartFile; import javax.crypto.spec.SecretKeySpec; import javax.servlet.http.HttpServletResponse; import java.io.*; import java.net.MalformedURLException; import java.net.URL; import java.net.URLConnection; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; import java.text.DecimalFormat; import java.time.ZonedDateTime; import java.util.*; import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; /** * @author liangdaliang * @Description： * @date 2022-07-21 16:12 */ @Slf4j @RestController public class MinioFileController { @Autowired private MinioClient minioClient; private static final String MINIO_BUCKET = "test"; @GetMapping("/list") public List<Object> list(ModelMap map) throws Exception { Iterable<Result<Item>> myObjects = minioClient.listObjects(ListObjectsArgs.builder().bucket(MINIO_BUCKET).recursive(true).build()); Iterator<Result<Item>> iterator = myObjects.iterator(); List<Object> items = new ArrayList<>(); String format = "{'fileName':'%s','fileSize':'%s'}"; while (iterator.hasNext()) { Item item = iterator.next().get(); items.add(String.format(format, item.objectName(), formatFileSize(item.size()))); } return items; } @PostMapping("/upload") public Res upload(@RequestParam(name = "file", required = false) MultipartFile[] file) { Res res = new Res(); res.setCode(500); if (file == null || file.length == 0) { res.setMessage("上传文件不能为空"); return res; } List<String> orgfileNameList = new ArrayList<>(file.length); for (MultipartFile multipartFile : file) { String orgfileName = multipartFile.getOriginalFilename(); orgfileNameList.add(orgfileName); try { InputStream in = multipartFile.getInputStream(); minioClient.putObject(PutObjectArgs.builder() .bucket(MINIO_BUCKET) .object(orgfileName) .stream(in, multipartFile.getSize(), -1) .build()); // minioClient.putObject(MINIO_BUCKET, orgfileName, in, new PutObjectOptions(in.available(), -1)); in.close(); } catch (Exception e) { log.error(e.getMessage()); res.setMessage("上传失败"); return res; } } Map<String, Object> data = new HashMap<String, Object>(); data.put("bucketName", MINIO_BUCKET); data.put("fileName", orgfileNameList); res.setCode(200); res.setMessage("上传成功"); res.setData(data); return res; } @RequestMapping("/download/{fileName}") public void download(HttpServletResponse response, @PathVariable("fileName") String fileName) { InputStream in = null; try { StatObjectResponse stat = minioClient.statObject(StatObjectArgs.builder().bucket(MINIO_BUCKET).object(fileName).build()); response.setContentType(stat.contentType()); response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(fileName, "UTF-8")); in = minioClient.getObject(GetObjectArgs.builder() .bucket(MINIO_BUCKET) .object(fileName) .build()); IOUtils.copy(in, response.getOutputStream()); } catch (Exception e) { log.error(e.getMessage()); } finally { if (in != null) { try { in.close(); } catch (IOException e) { log.error(e.getMessage()); } } } } @DeleteMapping("/delete/{fileName}") public Res delete(@PathVariable("fileName") String fileName) { Res res = new Res(); res.setCode(200); try { minioClient.removeObject(RemoveObjectArgs.builder().bucket(MINIO_BUCKET).object(fileName).build()); } catch (Exception e) { res.setCode(500); log.error(e.getMessage()); } return res; } private static String formatFileSize(long fileS) { DecimalFormat df = new DecimalFormat("#.00"); String fileSizeString = ""; String wrongSize = "0B"; if (fileS == 0) { return wrongSize; } if (fileS < 1024) { fileSizeString = df.format((double) fileS) + " B"; } else if (fileS < 1048576) { fileSizeString = df.format((double) fileS / 1024) + " KB"; } else if (fileS < 1073741824) { fileSizeString = df.format((double) fileS / 1048576) + " MB"; } else { fileSizeString = df.format((double) fileS / 1073741824) + " GB"; } return fileSizeString; } /** * Description 下载 minio文件，返回流的方式，同时支持在线预览 * * @param object 文件名称 * @param isOnline 是否在线预览，不同文件类型请修改 setContentType * @param response 响应对象 * @return void * @time 2022/7/10 9:51 **/ public void download(String object, Boolean isOnline, HttpServletResponse response) { try (InputStream stream = minioClient.getObject( GetObjectArgs.builder() .bucket(MINIO_BUCKET) .object(object) .build())) { try { BufferedInputStream br = new BufferedInputStream(stream); byte[] buf = new byte[1024]; int len = 0; response.reset(); // 非常重要 if (Objects.nonNull(isOnline) && isOnline) { // 在线打开方式 response.setContentType("application/pdf"); response.setHeader("Content-Disposition", "inline; filename=" + object); } else { // 纯下载方式 response.setContentType("application/x-msdownload"); response.setHeader("Content-Disposition", "attachment; filename=" + object); } OutputStream out = response.getOutputStream(); while ((len = br.read(buf)) > 0) { out.write(buf, 0, len); } out.flush(); br.close(); } catch (Exception e) { e.printStackTrace(); } } catch (Exception e) { e.printStackTrace(); } } /** * Description 以流的方式上传文件 * * @param in input 流 * @param object 文件名 * @param size 文件大小 * @return java.lang.Boolean * @time 2022/7/10 9:55 **/ public Boolean uploadObject(InputStream in, String object, Long size) { try { minioClient.putObject( PutObjectArgs.builder() .bucket(MINIO_BUCKET) .object(object) .stream(in, s