Docker部署MinIO分布式文件存储服务及其教程#

1、什么是MinIO?#

Minio 是个基于 Golang 编写的开源对象存储套件,基于Apache License v2.0开源协议,虽然轻量,却拥有着不错的性能。它兼容亚马逊S3云存储服务接口。可以很简单的和其他应用结合使用,例如 NodeJS、Redis、MySQL等。

2、CentOS普通安装#

首先下载MinIO

1
wget https://dl.min.io/server/minio/release/linux-amd64/minio
2
#授权
3
chmod +x minio

操作MinIO的端口是9000 访问MinIO控制台界面的端口是42579,这是一个动态生成的端口,建议启动时添加—console-address ""来指定一个固定的端口默认的用户名和密码都是minioadmin,建议通过修改环境变量MINIO_ROOT_USER和MINIO_ROOT_PASSWORD来修改

1
# 修改环境变量,自定义minio的root用户名和密码(密码至少要8位)
2
export MINIO_ROOT_USER=admin
3
export MINIO_ROOT_PASSWORD=12345678
4

5
# 启动minio时指定控制台端口
6
./minio server --console-address ":9001" /data/minio
7
#后台日志启动
8
nohup ./minio server --console-address ":9001" /data/minio &

3、通过Docker快速安装MinIO#

获取镜像:#

1
docker pull minio/minio

创建目录:#

一个用来存放配置,一个用来存储上传文件的目录

启动前需要先创建Minio外部挂载的配置文件( /home/minio/config),和存储上传文件的目录( /home/minio/data)

1
mkdir -p /home/minio/config
2
mkdir -p /home/minio/data

创建Minio容器并运行:#

1
docker run -p 9000:9000 -p 9090:9090 \
2
     --net=host \
3
     --name minio \
4
     -d --restart=always \
5
     -e "MINIO_ACCESS_KEY=minioadmin" \
6
     -e "MINIO_SECRET_KEY=minioadmin" \
7
     -v /home/minio/data:/data \
8
     -v /home/minio/config:/root/.minio \
9
     minio/minio server \
10
     /data --console-address ":9090" -address ":9000"

查看运行情况#

1
docker ps

4、访问操作#

访问地址为你的部署IP地址:9090/login

默认的用户名密码都为: minioadmin minioadmin

5、Java中实际操作#

1)、在项目中导入相关的Maven依赖#

1
<dependency>
2
    <groupId>io.minio</groupId>
3
    <artifactId>minio</artifactId>
4
    <version>8.2.1</version>
5
</dependency>

2)、添加配置#

在aplication.yml配置中添加MInIO相关的配置,如下:

1
minio:
2
  # 访问的url
3
  endpoint: http://192.168.47.148
4
  # API的端口
5
  port: 9001
6
  # 秘钥
7
  accessKey: HQGWFYLWGC6FVJ0CQFOG
8
  secretKey: pUGhAgQhZDxJaLmN3uz65YX7Bb3FyLdLglBvcCr1
9
  secure: false
10
  bucket-name: test # 桶名 我这是给出了一个默认桶名
11
  image-size: 10485760 # 我在这里设定了 图片文件的最大大小
12
  file-size: 1073741824 # 此处是设定了文件的最大大小

3)、新建上传文件接口#

1
/**
2
 * @author cherryhua
3
 */
4
@RequestMapping("/minio")
5
@RestController
6
public class MinioController {
7

8
    @Autowired
9
    private  MinioService minioService;
10

11
    @PostMapping("/upload")
12
    public String uploadFile(MultipartFile file, String bucketName) {
13
        String fileType = FileTypeUtils.getFileType(file);
14
        if (fileType != null) {
15
            return minioService.putObject(file, bucketName, fileType);
16
        }
17
        return "不支持的文件格式。请确认格式,重新上传!!!";
18
    }
19
}

4)、测试上传效果#

直接调用接口上传一张图片试一下,如下:

接口返回的URL就是文件的访问地址,直接输入浏览器访问即可,在MInIO中也可以看到存储的文件。

6、实际项目和自定义Springboot-Starter使用#

1)、导入minio相关依赖#

1
<dependency>
2
      <groupId>io.minio</groupId>
3
      <artifactId>minio</artifactId>
4
      <version>${minio.version}</version>
5
</dependency>

2)、创建yaml对应的配置类#

1
@Data
2
@ConfigurationProperties("minio")
3
public class MinioConfigurationProperties {
4
    private String endpoint;
5
    private String accessKey;
6
    private String secretKey;
7
    private String bucket;
8
    private Integer tempUrlExpire;
9
}

3)、创建minio自动配置类,将MinioClient存入容器#

1
@Configuration
2
@EnableConfigurationProperties(MinioConfigurationProperties.class)
3
public class MinioAutoConfiguration {
4
    @Autowired
5
    private MinioConfigurationProperties minioProperties;
6

7
    @Bean
8
    public MinioClient minioClient() {
9
        return MinioClient.builder().endpoint(minioProperties.getEndpoint())
10
                .credentials(minioProperties.getAccessKey(), minioProperties.getSecretKey())
11
                .build();
12
    }
13
}

4)、创建MinioService,封装通用方法#

1
@Service
2
public class MinioService {
3
    @Autowired
4
    private MinioClient minioClient;
5

6
    @Autowired
7
    private MinioConfigurationProperties minioProperties;
8

9
    /**
10
     * 获取文件列表
11
     * @return 文件列表
12
     */
13
    public List<String> listFiles() {
14
        List<String> result = new ArrayList<>();
15
        // 获取bucket中的文件对象列表
16
        ListObjectsArgs listObjectsArgs = ListObjectsArgs.builder().bucket(minioProperties.getBucket()).build();
17
        Iterable<Result<Item>> objects = minioClient.listObjects(listObjectsArgs);
18
        objects.forEach(obj -> {
19
            try {
20
                Item item = obj.get();
21
                result.add(item.objectName());
22
            } catch (Exception e) {
23
                throw new MinioException("文件服务异常");
24
            }
25
        });
26
        return result;
27
    }
28

29
    /**
30
     * 获取文件输入流
31
     * @param filePath 文件在bucket中的相对路径
32
     * @return 文件输入流
33
     */
34
    public InputStream getFile(String filePath) {
35
        GetObjectArgs getObjectArgs = GetObjectArgs.builder().bucket(minioProperties.getBucket()).object(filePath).build();
36
        try {
37
            return minioClient.getObject(getObjectArgs);
38
        } catch (Exception e) {
39
            throw new MinioException("文件服务异常");
40
        }
41
    }
42

43
    /**
44
     * 获取文件参数
45
     * @param filePath 文件在bucket中的相对路径
46
     * @return 文件参数
47
     */
48
    public StatObjectResponse getFileStat(String filePath) {
49
        StatObjectArgs statObjectArgs = StatObjectArgs.builder().bucket(minioProperties.getBucket()).object(filePath).build();
50
        try {
51
            return minioClient.statObject(statObjectArgs);
52
        } catch (Exception e) {
53
            throw new MinioException("文件服务异常");
54
        }
55
    }
56

57
    /**
58
     * 上传文件
59
     * @param inputStream 文件输入流
60
     * @param filePath 文件在bucket中的相对路径
61
     * @param contentType 文件mime类型
62
     * @param fileSize 文件大小
63
     */
64
    public void uploadFile(InputStream inputStream, String filePath, String contentType, long fileSize) {
65
        PutObjectArgs putObjectArgs = PutObjectArgs.builder().bucket(minioProperties.getBucket()).object(filePath)
66
                .contentType(contentType)
67
                .stream(inputStream, fileSize, -1)
68
                .build();
69
        try {
70
            minioClient.putObject(putObjectArgs);
71
        } catch (Exception e) {
72
            throw new MinioException("文件服务异常");
73
        }
74
    }
75

76
    /**
77
     * 删除文件
78
     * @param filePath 文件在bucket中的相对路径
79
     */
80
    public void deleteFile(String filePath) {
81
        RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder().bucket(minioProperties.getBucket())
82
                .object(filePath).build();
83
        try {
84
            minioClient.removeObject(removeObjectArgs);
85
        } catch (Exception e) {
86
            throw new MinioException("文件服务异常");
87
        }
88
    }
89

90
    /**
91
     * 获取文件临时url
92
     * @param filePath 文件在bucket中的相对路径
93
     * @return 文件临时url
94
     */
95
    public String getFileTempUrl(String filePath) {
96
        GetPresignedObjectUrlArgs presignedObjectUrlArgs = GetPresignedObjectUrlArgs.builder()
97
                .bucket(minioProperties.getBucket())
98
                .object(filePath) // object的路径
99
                .method(Method.GET) // http请求方式
100
                .expiry(minioProperties.getTempUrlExpire(), TimeUnit.MINUTES) // url过期时间
101
                .build();
102
        try {
103
            return minioClient.getPresignedObjectUrl(presignedObjectUrlArgs);
104
        } catch (Exception e) {
105
            throw new MinioException("文件服务异常");
106
        }
107
    }
108
}

5)、其中自定义异常MinioException如下#

1
public class MinioException extends RuntimeException {
2
    public MinioException(String message) {
3
        super(message);
4
    }
5
}

6)、然后在resources下创建META-INF/spring.factories文件,指定自动配置类#

1
org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
2
com.baobao.minio.MinioAutoConfiguration

7)、最后install到本地maven仓库,这样在其他springboot工程中就可以使用这个starter了#

1
<dependency>
2
    <groupId>com.baobao.minio</groupId>
3
    <artifactId>minio-spring-boot-starter</artifactId>
4
    <version>0.0.7-SNAPSHOT</version>
5
</dependency>

8)、使用#

1
@RestController
2
@RequestMapping("minio")
3
public class MinioController {
4
    @Autowired
5
    private MinioService minioService;
6

7
    @GetMapping("list")
8
    public List<String> list() {
9
        return minioService.listFiles();
10
    }
11

12
    /**
13
     * 下载文件
14
     *
15
     * @param filePath 文件在bucket中的相对路径
16
     */
17
    @GetMapping("download/{filePath}")
18
    public void download(@PathVariable("filePath") String filePath, HttpServletResponse response) throws Exception {
19
        // 获取要下载的对象的信息
20
        StatObjectResponse stat = minioService.getFileStat(filePath);
21
        // 设置响应文件类型
22
        response.setContentType(stat.contentType());
23
        // 设置下载响应头
24
        response.setHeader("Content-Disposition", "attachment;filename="
25
                + URLEncoder.encode(filePath, "UTF-8"));
26
        // 下载文件流
27
        try (InputStream object = minioService.getFile(filePath);
28
             OutputStream out = response.getOutputStream()) {
29
            IOUtils.copy(object, out);
30
        }
31
    }
32

33
    @PostMapping("upload")
34
    public void upload(MultipartFile file) throws Exception {
35
        // 上传文件流
36
        try (InputStream in = file.getInputStream()) {
37
            minioService.uploadFile(in, file.getOriginalFilename(), file.getContentType(), file.getSize());
38
        }
39
    }
40

41
    @DeleteMapping("delete/{filePath}")
42
    public void delete(@PathVariable("filePath") String filePath) {
43
        minioService.deleteFile(filePath);
44
    }
45

46
    @GetMapping("url")
47
    public String getObjectUrl(String filePath) {
48
        return minioService.getFileTempUrl(filePath);
49
    }
50
}

音乐

音乐

Docker部署MinIO分布式文件存储服务及其教程#

1、什么是MinIO?#

2、CentOS普通安装#

3、通过Docker快速安装MinIO#

获取镜像:#

创建目录:#

创建Minio容器并运行:#

查看运行情况#

4、访问操作#

5、Java中实际操作#

1)、在项目中导入相关的Maven依赖#

2)、添加配置#

3)、新建上传文件接口#

4)、测试上传效果#

6、实际项目和自定义Springboot-Starter使用#

1)、导入minio相关依赖#

2)、创建yaml对应的配置类#

3)、创建minio自动配置类,将MinioClient存入容器#

4)、创建MinioService,封装通用方法#

5)、其中自定义异常MinioException如下#

6)、然后在resources下创建META-INF/spring.factories文件,指定自动配置类#

7)、最后install到本地maven仓库,这样在其他springboot工程中就可以使用这个starter了#

8)、使用#

支持与分享

音乐

文章目录

音乐

音乐

Docker部署MinIO分布式文件存储服务及其使用教程

Docker部署MinIO分布式文件存储服务及其教程#

1、什么是MinIO?#

2、CentOS普通安装#

3、通过Docker快速安装MinIO#

获取镜像:#

创建目录:#

创建Minio容器并运行:#

查看运行情况#

4、访问操作#

5、Java中实际操作#

1)、在项目中导入相关的Maven依赖#

2)、添加配置#

3)、新建上传文件接口#

4)、测试上传效果#

6、实际项目和自定义Springboot-Starter使用#

1)、导入minio相关依赖#

2)、创建yaml对应的配置类#

3)、创建minio自动配置类,将MinioClient存入容器#

4)、创建MinioService,封装通用方法#

5)、其中自定义异常MinioException如下#

6)、然后在resources下创建META-INF/spring.factories文件,指定自动配置类#

7)、最后install到本地maven仓库,这样在其他springboot工程中就可以使用这个starter了#

8)、使用#

支持与分享

音乐

文章目录