minio 安装

请参考使用 docker compose 部署方式

minio JAVA SKD 构建

JAVA SDK 官方文档

引入依赖，版本不同构建客户端代码不同

  1. implementation 'io.minio:minio:8.2.1'

构建客户端，通过 boot 的 yml 配置文件完成用户名密码等配置

  2. import org.apache.commons.lang3.StringUtils;
  3. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  7. import io.minio.BucketExistsArgs;
  8. import io.minio.MakeBucketArgs;
  9. import io.minio.MinioClient;
  10. import lombok.extern.slf4j.Slf4j;
  12. /**
  13.  * @author mrcode
  14.  * @date 2021/5/20 14:07
  15.  */
  16. @Configuration
  17. @EnableConfigurationProperties({
  18.         MinioConfig.class
  19. })
  20. @Slf4j
  21. public class MinioClientConfig {
  22.     @Bean
  23.     public MinioClient minioClient(MinioConfig minioConfig) {
  24.         // 使用 MinIO 服务的 URL，端口，Access key 和 Secret key创建一个 MinioClient 对象
  25.         MinioClient minioClient =
  26.                 MinioClient.builder()
  27.                         .endpoint(minioConfig.getUrl())
  28.                         .credentials(minioConfig.getAccessKey(), minioConfig.getSecretKey())
  29.                         .build();
  30.         final String bucket = minioConfig.getBucket();
  31.         if (StringUtils.isBlank(bucket)) {
  32.             return minioClient;
  33.         }
  34.         try {
  35.             // 检查存储桶是否已经存在
  36.             boolean isExist = minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucket).build());
  37.             if (isExist) {
  38.                 log.info("s3 存储桶 {} 已存在", bucket);
  39.             } else {
  40.                 minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucket).build());
  41.                 log.info("s3 存储桶 {} 已创建", bucket);
  42.             }
  43.         } catch (Exception e) {
  44.             throw new RuntimeException(e);
  45.         }
  46.         return minioClient;
  47.     }
  48. }

配置类

  1. import org.springframework.boot.context.properties.ConfigurationProperties;
  3. import java.util.List;
  5. import lombok.Data;
  6. import lombok.ToString;
  8. /**
  9.  * @author mrcode
  10.  * @date 2021/5/20 14:16
  11.  */
  12. @Data
  13. @ToString
  14. @ConfigurationProperties(prefix = "mrcode.minio")
  15. public class MinioConfig {
  16.     /**
  17.      * http://localhost:9000/
  18.      */
  19.     private String url;
  20.     /**
  21.      * 用户名
  22.      */
  23.     private String accessKey;
  24.     /**
  25.      * 密码
  26.      */
  27.     private String secretKey;
  28.     /**
  29.      * 使用的桶，用于自动创建桶, 一个项目一个桶
  30.      */
  31.     private String bucket;
  32. }

测试上传、下载

  1. import org.junit.jupiter.api.Test;
  2. import org.springframework.beans.factory.annotation.Autowired;
  3. import org.springframework.boot.test.context.SpringBootTest;
  5. import java.io.IOException;
  6. import java.nio.file.Files;
  7. import java.nio.file.Path;
  8. import java.nio.file.Paths;
  9. import java.security.InvalidKeyException;
  10. import java.security.NoSuchAlgorithmException;
  12. import cn.hutool.core.io.FileUtil;
  13. import io.minio.DownloadObjectArgs;
  14. import io.minio.MinioClient;
  15. import io.minio.PutObjectArgs;
  16. import io.minio.errors.ErrorResponseException;
  17. import io.minio.errors.InsufficientDataException;
  18. import io.minio.errors.InternalException;
  19. import io.minio.errors.InvalidResponseException;
  20. import io.minio.errors.ServerException;
  21. import io.minio.errors.XmlParserException;
  23. /**
  24.  * @author mrcode
  25.  * @date 2021/5/20 14:53
  26.  */
  27. @SpringBootTest
  28. class ConsumerDataControllerTest {
  29.     @Autowired
  30.     private MinioClient minioClient;
  32.     @Test
  33.     public void uploadTest() throws IOException, ServerException, InsufficientDataException, ErrorResponseException, NoSuchAlgorithmException, InvalidKeyException, InvalidResponseException, XmlParserException, InternalException {
  34.         final String first = "D:\\360Downloads\\product.xls";
  35.         final Path path = Paths.get(first);
  37.         // 上传文件
  38.         minioClient.putObject(
  39.                 PutObjectArgs.builder()
  40.                         // 存储桶，相当于命名空间
  41.                         .bucket("test-bucket")
  42.                         // 上传上去的路径，相对的
  43.                         .object("img/test.xls")
  44.                         // 该 API 分未已知文件大小和未知文件大小上传，下面是已知文件大小，未知的可以看该 API 使用方式
  45.                         .stream(Files.newInputStream(path), Files.size(path), -1)
  46.                         // contentType 默认是二进制文件类型，可以为 null
  47.                         .contentType(FileUtil.getMimeType(first))
  48.                         .build());
  50.         // 下载文件
  51.         minioClient.downloadObject(DownloadObjectArgs.builder()
  52.                 // 存储桶
  53.                 .bucket("test-bucket")
  54.                 // 在存储桶中的路径
  55.                 .object("img/test.xls")
  56.                 // 要下载到本地的文件路径
  57.                 .filename("D:\\360Downloads\\product-111.xls")
  58.                 .build());
  59.     }
  60. }

删除文件

  1.     public boolean delete(String objectPath) {
  2.         try {
  3.             minioClient.removeObject(RemoveObjectArgs.builder()
  4.                     .bucket(minioConfig.getBucket())
  5.                     .object(objectPath)
  6.                     .build());
  7.             return true;
  8.         } catch (Exception e) {
  9.             log.error(StrUtil.format("文件删除失败,objectPath={}", objectPath), e);
  10.             return false;
  11.         }
  12.     }

客户端 CLI 命令行使用

官方文档

可视化的 WEB 版无法批量下载，可以使用 CLI 这个来做一些更高级的操作。比如 下载整个目录 的文件。

第一步：下载 mc 命令行程序，并验证是否可使用

  1. # 下载之后 https://dl.min.io/client/mc/release/windows-amd64/mc.exe
  2. # 在 mc.exe 所在路径打开 windows 的 cmd.exe 程序，执行下面的代码验证
  3. # 在 linux 下，是 mc 
  4. mc.exe --help

第二步：配置一个别名，里面配置的是访问 minio 的链接、账户名、密码信息

  1. #                    取别名、 端点                  用户名               密码
  2. # 语法：mc alias set <ALIAS> <YOUR-S3-ENDPOINT> <YOUR-ACCESS-KEY> <YOUR-SECRET-KEY>
  3. # 注意：可视化的 web 管理地址并不是端点地址，这个一定要注意
  4. mc alias set minio http://192.168.1.51 BKIKJAA5BMMU2RHO6IBB V7f1CwQqAcwo80UEIJEjc5gVQUSSx5ohQ9GSrr12
  6. # 当你第一次使用 mc 命令时，会初始一些文件
  7. # 上面执行的命令其实就被写入到了 config.json 这个 json 文件中
  8. mc.exe: Configuration written to `C:\Users\xx\mc\config.json`. Please update your access credentials.
  9. mc.exe: Successfully created `C:\Users\xx\mc\share`.
  10. mc.exe: Initialized share uploads `C:\Users\xx\mc\share\uploads.json` file.
  11. mc.exe: Initialized share downloads `C:\Users\xx\mc\share\downloads.json` file.
  12. # 如果校验通过，会有日志出现
  13. Added `minio` successfully.

同时在 config.json 文件中也会出现你的信息

  1. {
  2.     "version": "10",
  3.     "aliases": {
  4.         "minio": {
  5.             "url": "http://192.168.1.51",
  6.             "accessKey": "BKIKJAA5BMMU2RHO6IBB",
  7.             "secretKey": "V7f1CwQqAcwo80UEIJEjc5gVQUSSx5ohQ9GSrr12",
  8.             "api": "s3v4",
  9.             "path": "auto"
  10.         }
  11. }

第三步：使用 ls 命令查看

  1. # 查看根目录，下面的 testdir 就是一个 桶 名称。可以深入进去查看
  2. # 注意：这里的 minio 是上面配置的别名，它代表访问你指定的 minio
  3. mc.exe ls minio
  4. [2021-08-19 18:34:26 CST]     0B testdir\
  6. # 比如查看 a 目录下有哪些东西
  7. mc.exe ls minio/testdir/a
  8. [2021-10-12 15:34:51 CST]     0B p-3\
  9. [2021-10-12 15:34:51 CST]     0B p-4\
  10. [2021-10-12 15:34:51 CST]     0B p-5\
  11. [2021-10-12 15:34:51 CST]     0B p-6\

到这里已经可以正常使用了

下载目录到本地 CP

cp 命令完整文档

  1. # 复制一个目录，需要添加 --recursive 标志 简写为 -r
  2. # 将指定的目录复制到 本地当前目录下，不用手动创建目录 p-3，会自动创建
  3. mc.exe cp minio/testdir/a/p-3 . --recursive
  4. ...3/xxx.jpg:  2.22 MiB / 210.43 MiB [=>