什么是MinIo
Minio是Apcche旗下的一款開源的輕量級文件服務器，基於對象存儲，協議是基於Apache License v2.0，開源可用於商務。
Minio主要用來存儲非結構化的數據，類似文件，圖片，照片，日志文件，各類備份文件等，按照官網描述，文件的大小從幾KB到5TB。
Minio提供了非常方便，友好的界面，並且文檔也是非常豐富，具體可以參考它的文檔：https://docs.min.io/cn/
為什么選擇MinIo
在之前開發中曾使用了分布式文件服務FASTDFS和阿里雲的OSS對象存儲來存儲。奈何OSS太貴，FASTDFS搭建配置又太繁瑣，今天給大家推薦一款極易上手的高性能對象存儲服務MinIo。
MinIO 是高性能的對象存儲，兼容 Amazon S3接口，充分考慮開發人員的需求和體驗；支持分布式存儲，具備高擴展性、高可用性；部署簡單但功能豐富。官方的文檔也很詳細。它有多種不同的部署模式（單機部署，分布式部署）。
為什么說 MinIO 簡單易用，原因就在於它的啟動、運行和配置都很簡單。可以通過 docker 方式進行安裝運行，也可以下載二進制文件，然后使用腳本運行。
安裝MinIo
推薦使用 docker 一鍵安裝：
引入依賴7.0用這個
docker run -it -p 9000:9000 --name minio \ -d --restart=always \ -e "MINIO_ACCESS_KEY=admin" \ -e "MINIO_SECRET_KEY=admin123456" \ -v /mnt/minio/data:/data \ -v /mnt/minio/config:/root/.minio \ minio/minio server /data
引入依賴8.0使用這個
docker run --name minio -p 9000:9000 -p 9090:9090 -d --restart=always -e "MINIO_ROOT_USER=admin" -e "MINIO_ROOT_PASSWORD=1111" -v /mnt/minio/data:/data -v /mnt/minio/config:/root/.minio minio/minio server /data --console-address ":9090" --address ":9000"
注意：
密鑰必須大於8位，否則會創建失敗
文件目錄和配置文件一定要映射到主機，你懂得
整合Nginx
最好直接https配置好 這樣后續不需要改
server{ listen 80; server_name static.java.com; location /{ proxy_set_header Host $http_host; proxy_pass http://localhost:9000; } location ~ /\.ht { deny all; } }
這樣，通過瀏覽器訪問配置的地址，使用指定的 MINIO_ACCESS_KEY 及 MINIO_SECRET_KEY 登錄即可。
簡單看了一下，功能還算可以，支持創建Bucket，文件上傳、刪除、分享、下載，同時可以對Bucket設置讀寫權限。
整合SpringBoot
Minio支持接入JavaScript、Java、Python、Golang等多種語言，這里我們選擇最熟悉的Java語言，使用最流行的框架 SpringBoot。
pom.xml
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>7.0.2</version>
</dependency>
8.0依賴pom.xml
<!-- 引入minio-->
<dependency>
<groupId>io.minio</groupId>
<artifactId>minio</artifactId>
<version>8.0.3</version>
</dependency>
<!-- 解決 NoSuchMethodError kotlin.collections.ArraysKt.copyInto([B[BIII)[B -->
<!-- <dependency>-->
<!-- <groupId>org.jetbrains.kotlin</groupId>-->
<!-- <artifactId>kotlin-stdlib</artifactId>-->
<!-- <version>1.3.70</version>-->
<!-- </dependency>-->
application.yml minio配置
minio: endpoint: https://static.java.com/ fileUploadUrl: https://static.java.com/ accessKey: admin secretKey: xxxx bucketName: program
Minio客戶端配置類，並注入到Spring中
@Data @Configuration @ConfigurationProperties(prefix = "minio") public class MinioConfig { private String endpoint; private String accessKey; private String secretKey; private String bucketName; @Bean public MinioClient minioClient() { MinioClient minioClient = MinioClient.builder() .endpoint(endpoint) .credentials(accessKey, secretKey) .build(); return minioClient; } }
工具類
7.0版本的工具類
@Component public class MinioUtil { @Autowired private MinioClient minioClient; private static final int DEFAULT_EXPIRY_TIME = 7 * 24 * 3600; /** * 檢查存儲桶是否存在 * * @param bucketName 存儲桶名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public boolean bucketExists(String bucketName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = minioClient.bucketExists(bucketName); if (flag) { return true; } return false; } /** * 創建存儲桶 * * @param bucketName 存儲桶名稱 * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException * @throws RegionConflictException */ public boolean makeBucket(String bucketName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException, RegionConflictException { boolean flag = bucketExists(bucketName); if (!flag) { minioClient.makeBucket(bucketName); return true; } else { return false; } } /** * 列出所有存儲桶名稱 * * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public List<String> listBucketNames() throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { List<Bucket> bucketList = listBuckets(); List<String> bucketListName = new ArrayList<>(); for (Bucket bucket : bucketList) { bucketListName.add(bucket.name()); } return bucketListName; } /** * 列出所有存儲桶 * * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public List<Bucket> listBuckets() throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { return minioClient.listBuckets(); } /** * 刪除存儲桶 * * @param bucketName 存儲桶名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public boolean removeBucket(String bucketName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { Iterable<Result<Item>> myObjects = listObjects(bucketName); for (Result<Item> result : myObjects) { Item item = result.get(); // 有對象文件，則刪除失敗 if (item.size() > 0) { return false; } } // 刪除存儲桶，注意，只有存儲桶為空時才能刪除成功。 minioClient.removeBucket(bucketName); flag = bucketExists(bucketName); if (!flag) { return true; } } return false; } /** * 列出存儲桶中的所有對象名稱 * * @param bucketName 存儲桶名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public List<String> listObjectNames(String bucketName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { List<String> listObjectNames = new ArrayList<>(); boolean flag = bucketExists(bucketName); if (flag) { Iterable<Result<Item>> myObjects = listObjects(bucketName); for (Result<Item> result : myObjects) { Item item = result.get(); listObjectNames.add(item.objectName()); } } return listObjectNames; } /** * 列出存儲桶中的所有對象 * * @param bucketName 存儲桶名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public Iterable<Result<Item>> listObjects(String bucketName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { return minioClient.listObjects(bucketName); } return null; } /** * 通過文件上傳到對象 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param fileName File name * @return * @throws InvalidKeyException * @throws ErrorResponseException * @throws IllegalArgumentException * @throws InsufficientDataException * @throws InternalException * @throws InvalidBucketNameException * @throws InvalidResponseException * @throws NoSuchAlgorithmException * @throws XmlParserException * @throws IOException */ public boolean putObject(String bucketName, String objectName, String fileName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { minioClient.putObject(bucketName, objectName, fileName, null); ObjectStat statObject = statObject(bucketName, objectName); if (statObject != null && statObject.length() > 0) { return true; } } return false; } /** * 通過InputStream上傳對象 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param stream 要上傳的流 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public boolean putObject(String bucketName, String objectName, InputStream stream) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { minioClient.putObject(bucketName, objectName, stream, new PutObjectOptions(stream.available(), -1)); ObjectStat statObject = statObject(bucketName, objectName); if (statObject != null && statObject.length() > 0) { return true; } } return false; } /** * 以流的形式獲取一個文件對象 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public InputStream getObject(String bucketName, String objectName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { ObjectStat statObject = statObject(bucketName, objectName); if (statObject != null && statObject.length() > 0) { InputStream stream = minioClient.getObject(bucketName, objectName); return stream; } } return null; } /** * 以流的形式獲取一個文件對象（斷點下載） * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param offset 起始字節的位置 * @param length 要讀取的長度 (可選，如果無值則代表讀到文件結尾) * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public InputStream getObject(String bucketName, String objectName, long offset, Long length) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { ObjectStat statObject = statObject(bucketName, objectName); if (statObject != null && statObject.length() > 0) { InputStream stream = minioClient.getObject(bucketName, objectName, offset, length); return stream; } } return null; } /** * 下載並將文件保存到本地 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param fileName File name * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public boolean getObject(String bucketName, String objectName, String fileName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { ObjectStat statObject = statObject(bucketName, objectName); if (statObject != null && statObject.length() > 0) { minioClient.getObject(bucketName, objectName, fileName); return true; } } return false; } /** * 刪除一個對象 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public boolean removeObject(String bucketName, String objectName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { minioClient.removeObject(bucketName, objectName); return true; } return false; } /** * 刪除指定桶的多個文件對象,返回刪除錯誤的對象列表，全部刪除成功，返回空列表 * * @param bucketName 存儲桶名稱 * @param objectNames 含有要刪除的多個object名稱的迭代器對象 * @return * @throws InvalidKeyException * @throws ErrorResponseException * @throws IllegalArgumentException * @throws InsufficientDataException * @throws InternalException * @throws InvalidBucketNameException * @throws InvalidResponseException * @throws NoSuchAlgorithmException * @throws XmlParserException * @throws IOException */ public List<String> removeObject(String bucketName, List<String> objectNames) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { List<String> deleteErrorNames = new ArrayList<>(); boolean flag = bucketExists(bucketName); if (flag) { Iterable<Result<DeleteError>> results = minioClient.removeObjects(bucketName, objectNames); for (Result<DeleteError> result : results) { DeleteError error = result.get(); deleteErrorNames.add(error.objectName()); } } return deleteErrorNames; } /** * 生成一個給HTTP GET請求用的presigned URL。 * 瀏覽器/移動端的客戶端可以用這個URL進行下載，即使其所在的存儲桶是私有的。這個presigned URL可以設置一個失效時間，默認值是7天。 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param expires 失效時間（以秒為單位），默認是7天，不得大於七天 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException * @throws InvalidExpiresRangeException */ public String presignedGetObject(String bucketName, String objectName, Integer expires) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException, InvalidExpiresRangeException { boolean flag = bucketExists(bucketName); String url = ""; if (flag) { if (expires < 1 || expires > DEFAULT_EXPIRY_TIME) { throw new InvalidExpiresRangeException(expires, "expires must be in range of 1 to " + DEFAULT_EXPIRY_TIME); } url = minioClient.presignedGetObject(bucketName, objectName, expires); } return url; } /** * 生成一個給HTTP PUT請求用的presigned URL。 * 瀏覽器/移動端的客戶端可以用這個URL進行上傳，即使其所在的存儲桶是私有的。這個presigned URL可以設置一個失效時間，默認值是7天。 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @param expires 失效時間（以秒為單位），默認是7天，不得大於七天 * @return * @throws InvalidKeyException * @throws ErrorResponseException * @throws IllegalArgumentException * @throws InsufficientDataException * @throws InternalException * @throws InvalidBucketNameException * @throws InvalidResponseException * @throws NoSuchAlgorithmException * @throws XmlParserException * @throws IOException * @throws InvalidExpiresRangeException */ public String presignedPutObject(String bucketName, String objectName, Integer expires) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException, InvalidExpiresRangeException { boolean flag = bucketExists(bucketName); String url = ""; if (flag) { if (expires < 1 || expires > DEFAULT_EXPIRY_TIME) { throw new InvalidExpiresRangeException(expires, "expires must be in range of 1 to " + DEFAULT_EXPIRY_TIME); } url = minioClient.presignedPutObject(bucketName, objectName, expires); } return url; } /** * 獲取對象的元數據 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public ObjectStat statObject(String bucketName, String objectName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); if (flag) { ObjectStat statObject = minioClient.statObject(bucketName, objectName); return statObject; } return null; } /** * 文件訪問路徑 * * @param bucketName 存儲桶名稱 * @param objectName 存儲桶里的對象名稱 * @return * @throws IOException * @throws XmlParserException * @throws NoSuchAlgorithmException * @throws InvalidResponseException * @throws InvalidBucketNameException * @throws InternalException * @throws InsufficientDataException * @throws IllegalArgumentException * @throws ErrorResponseException * @throws InvalidKeyException */ public String getObjectUrl(String bucketName, String objectName) throws InvalidKeyException, ErrorResponseException, IllegalArgumentException, InsufficientDataException, InternalException, InvalidBucketNameException, InvalidResponseException, NoSuchAlgorithmException, XmlParserException, IOException { boolean flag = bucketExists(bucketName); String url = ""; if (flag) { url = minioClient.getObjectUrl(bucketName, objectName); } return url; } }
8.0版本的工具類
/** * 文件服務器工具類 */ @Component public class MinioUtil { @Resource private MinioClient minioClient; /** * 查看存儲bucket是否存在 * @return boolean */ public Boolean bucketExists(String bucketName) { Boolean found; try { found = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build()); } catch (Exception e) { //e.printStackTrace(); return false; } return found; } /** * 創建存儲bucket * @return Boolean */ public Boolean makeBucket(String bucketName) { try { minioClient.makeBucket(MakeBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 刪除存儲bucket * @return Boolean */ public Boolean removeBucket(String bucketName) { try { minioClient.removeBucket(RemoveBucketArgs.builder() .bucket(bucketName) .build()); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 獲取全部bucket */ public List<Bucket> getAllBuckets() { try { return minioClient.listBuckets(); } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件上傳 * @param file 文件 * @return Boolean */ public Boolean upload(String bucketName, String fileName, MultipartFile file,InputStream inputStream) { try { PutObjectArgs objectArgs = PutObjectArgs.builder().bucket(bucketName).object(fileName) .stream(inputStream,file.getSize(),-1).contentType(file.getContentType()).build(); //文件名稱相同會覆蓋 minioClient.putObject(objectArgs); } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * 預覽圖片 * @param fileName * @return */ public String preview(String fileName,String bucketName){ // 查看文件地址 GetPresignedObjectUrlArgs build = new GetPresignedObjectUrlArgs().builder().bucket(bucketName).object(fileName).method(Method.GET).build(); try { String url = minioClient.getPresignedObjectUrl(build); return url; } catch (Exception e) { e.printStackTrace(); } return null; } /** * 文件下載 * @param fileName 文件名稱 * @param res response * @return Boolean */ public void download(String fileName,String bucketName, HttpServletResponse res) { GetObjectArgs objectArgs = GetObjectArgs.builder().bucket(bucketName) .object(fileName).build(); try (GetObjectResponse response = minioClient.getObject(objectArgs)){ byte[] buf = new byte[1024]; int len; try (FastByteArrayOutputStream os = new FastByteArrayOutputStream()){ while ((len=response.read(buf))!=-1){ os.write(buf,0,len); } os.flush(); byte[] bytes = os.toByteArray(); res.setCharacterEncoding("utf-8"); //設置強制下載不打開 //res.setContentType("application/force-download"); res.addHeader("Content-Disposition", "attachment;fileName=" + fileName); try (ServletOutputStream stream = res.getOutputStream()){ stream.write(bytes); stream.flush(); } } } catch (Exception e) { e.printStackTrace(); } } /** * 查看文件對象 * @return 存儲bucket內文件對象信息 */ public List<Item> listObjects(String bucketName) { Iterable<Result<Item>> results = minioClient.listObjects( ListObjectsArgs.builder().bucket(bucketName).build()); List<Item> items = new ArrayList<>(); try { for (Result<Item> result : results) { items.add(result.get()); } } catch (Exception e) { e.printStackTrace(); return null; } return items; } /** * 刪除 * @param fileName * @return * @throws Exception */ public boolean remove(String fileName,String bucketName){ try { minioClient.removeObject( RemoveObjectArgs.builder().bucket(bucketName).object(fileName).build()); }catch (Exception e){ return false; } return true; } /** * 批量刪除文件對象（沒測試） * @param objects 對象名稱集合 */ public Iterable<Result<DeleteError>> removeObjects(List<String> objects,String bucketName) { List<DeleteObject> dos = objects.stream().map(e -> new DeleteObject(e)).collect(Collectors.toList()); Iterable<Result<DeleteError>> results = minioClient.removeObjects(RemoveObjectsArgs.builder().bucket(bucketName).objects(dos).build()); return results; } }
目前SDK不支持文件夾的創建，如果想創建文件夾，只能通過文件的方式上傳並創建。
minIoUtils.putObject("javakf","test/1.jpg","C:\\1.jpg");
一個實例只能有一個賬號，如果想使用多個賬號，需要創建多個實例。此外 minio還支持單主機，多塊磁盤以及分布式部署，不過對於大部分單體應用來說，單體已經夠用了。
上傳文件
7.0的 controller參考
@RestController public class MinioController { @Autowired private MinioUtil minioUtil; @PostMapping("/upload") public String MinIOUpload(MultipartFile file) { if (file.isEmpty() || file.getSize() == 0) { return "文件為空"; } try { if (!minioUtil.bucketExists("program")) { minioUtil.makeBucket("program"); } String fileName = file.getOriginalFilename(); String newName = "image/" + UUID.randomUUID().toString().replaceAll("-", "") + fileName.substring(fileName.lastIndexOf(".")); InputStream inputStream = file.getInputStream(); minioUtil.putObject("program", newName, inputStream); inputStream.close(); String url = minioUtil.getObjectUrl("program", newName); return url; } catch (Exception e) { e.printStackTrace(); return "上傳失敗"; } } }
8.0 controller參考
@RestController public class MinioController { @Autowired private MinioUtil minioUtil; @PostMapping("/upload") public String MinIOUpload(MultipartFile file) { if (file.isEmpty() || file.getSize() == 0) { return "文件為空"; } try { if (!minioUtil.bucketExists("program")) { minioUtil.makeBucket("program"); }
Boolean flag = minioUtil.upload("program", newName,file, inputStream); inputStream.close(); String fileUrl = minioUtil.preview(newName,"program"); String fileUrlNew=fileUrl.substring(0, fileUrl.indexOf("?")); return fileUrlNew; } catch (Exception e) { e.printStackTrace(); return "上傳失敗"; } } }
postman測試
安裝完之后 需要注意圖片只有7天有效期 需要搜索minio設置永久有效
由於MinIO服務端中並沒有自帶客戶端，所以我們需要安裝配置完客戶端后才能使用，這里以Docker環境下的安裝為例。 下載MinIO Client 的Docker鏡像： docker pull minio/mc 在Docker容器中運行mc： docker run -it --entrypoint=/bin/sh minio/mc 運行完成后我們需要進行配置，將我們自己的MinIO服務配置到客戶端上去，配置的格式如下： mc config host add <ALIAS> <YOUR-S3-ENDPOINT> <YOUR-ACCESS-KEY> <YOUR-SECRET-KEY> <API-SIGNATURE> 對於我們的MinIO服務可以這樣配置： mc config host add minio http://192.168.6.132:9090 minioadmin minioadmin S3v4
mc policy set download minio/program/
#下面是補充知識
常用操作 查看存儲桶和查看存儲桶中存在的文件： # 查看存儲桶 mc ls minio # 查看存儲桶中存在的文件 mc ls minio/progrm 創建一個名為test的存儲桶： mc mb minio/program 共享avatar.png文件的下載路徑： mc share download minio/blog/avatar.png 查找blog存儲桶中的png文件： mc find minio/blog --name "*.png" 設置test存儲桶的訪問權限為只讀： # 目前可以設置這四種權限：none, download, upload, public mc policy set download minio/program/ # 查看存儲桶當前權限 mc policy list minio/test/
直接安裝不使用docker方法
wget https://dl.min.io/client/mc/release/linux-amd64/mc //下載minio client chmod a+x mc ./mc config host add minio http://172.12.3.1:9999 admin passwd //添加minio server ./mc policy set download minio/yourbucket //設置需要開放下載的bucket, 注意需要帶minio http://172.16.3.1:9999/yourbucket/test.png //瀏覽器訪問, 注意不需要帶minio
MinIO啟動報錯“WARNING: Console endpoint is listening on a dynamic port... 主要是7.0 8.0版本問題
請參考 https://blog.csdn.net/gaofenglxx/article/details/118943343
NoSuchMethodError kotlin.collections.ArraysKt.copyInto([B[BIII)[B
請參考https://blog.csdn.net/lin819747263/article/details/107047149
參考鏈接如下
http://m.bubuko.com/infodetail-3796338.html
https://blog.csdn.net/weixin_45730091/article/details/106780517
https://www.jianshu.com/p/d8552e5050eb
https://www.cnblogs.com/cicada-smile/p/13387459.html