0
0

Docker 搭建 Minio 容器 (完整详细版)

Docker 搭建 Minio 容器 (完整详细版)

简介：

Minio 是一个基于Apache License v2.0开源协议的对象存储服务，虽然轻量，却拥有着不错的性能。它兼容亚马逊S3云存储服务接口，非常适合于存储大容量非结构化的数据。

例如图片、视频、日志文件、备份数据和容器/虚拟机镜像等，而一个对象文件可以是任意大小，从几 kb 到最大 5T 不等。

最重要的是免费

说明：

Docker如果想安装软件 , 必须先到Docker镜像仓库下载镜像。

Docker官方镜像

1、寻找Minio镜像

image-20231129205553602

image-20231130160039562

2、下载Minio镜像

# 下载镜像docker pull minio/minio

#查看镜像docker images

命令描述docker pull minio/minio下载最新版Minio镜像 (其实此命令就等同于 : docker pull minio/minio:latest )docker pull minio/minio:RELEASE.2023-11-20T22-40-07Z.fips下载指定版本的Minio镜像 (xxx指具体版本号)
image-20231129210410277

3、创建目录

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

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

mkdir-p /opt/minio/config

mkdir-p /opt/minio/data

4、创建Minio容器并运行

docker run \-p19000:9000 \-p9090:9090 \--net=host \--name minio \-d--restart=always \-e"MINIO_ACCESS_KEY=minioadmin"\-e"MINIO_SECRET_KEY=minioadmin"\-v /opt/minio/data:/data \-v /opt/minio/config:/root/.minio \
 minio/minio server \
/data --console-address ":9090"-address":19000"

命令描述-p 9000:9000 -p 9090:9090这是端口映射，前一个是服务器的端口，后一个是客户端也就是api接口访问的端口地址–name minio这是给新创建的容器命名的选项，名字是 “minio”–net=host这是网络设置，表示容器将使用主机的网络栈，这样就不需要在容器内部配置网络-d --restart=always这是运行容器的其他选项，-d使容器在后台运行，–restart=always表示容器总是会在退出后自动重启-e “MINIO_ACCESS_KEY=minioadmin”用户名-e “MINIO_SECRET_KEY=minioadmin”密码-v /opt/minio/data:/data这意味着将宿主机上的 /opt/minio/data 目录挂载到容器内的 /data 目录-v /opt/minio/config:/root/.minio将宿主机上的 /opt/minio/config 目录挂载到容器内的 /root/.minio 目录minio/minio server /data --console-address “:9090” -address “:9000”这是容器内要运行的命令，启动一个名为 “minio” 的服务器，数据存储在 /data 目录下，服务器的控制台地址为 “:9090”，服务地址为 “:9000”\换行

4.1、访问操作

访问：http://47.117.160.102:9090/login 用户名：密码 minioadmin：minioadmin

image-20231130165641764

4.2、创建用户

image-20231130173302737

image-20231130173436591

4.3、创建组

image-20231130173619690

image-20231130173728073

4.4、创建Buckets

image-20231130195452040

image-20231130195548997

4.5、创建Access Keys

image-20231130195953522

4.6、文件上传

image-20231201195412713

4.6、浏览器访问上传文件

image-20231201195651424

4.6.1、输入ip:19000/Buckets名/文件名，如果不行，看看端口是否开放

image-20231201195743467

5、Springboot简单使用

5.1、添加MinIO依赖Pom
<dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- MinIO 客户端 --><dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.5.7</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency><dependency><groupId>org.apache.commons</groupId><artifactId>commons-lang3</artifactId><version>3.11</version></dependency></dependencies>
5.2、配置MinIO的yaml
server:port:3333spring:servlet:multipart:max-request-size: 200MB
      max-file-size: 200MB

minio:url: http://127.0.0.1:19000#换成自己的minio服务端地址accessKey: minioadmin # 用户名secretKey: minioadmin # 密码bucketName: demo  # bucketName指的就是之前创建的MinIO桶Bucket
5.3、配置类Config
/**
 * @author HAOYANG
 * @create 2023-12-01 20:40
 */@Data@ConfigurationpublicclassMinioConfig{/**
     * 访问地址
     */@Value("${minio.url}")privateString endpoint;/**
     * accessKey类似于用户ID，用于唯一标识你的账户
     */@Value("${minio.accessKey}")privateString accessKey;/**
     * secretKey是你账户的密码
     */@Value("${minio.secretKey}")privateString secretKey;/**
     * 默认存储桶
     */@Value("${minio.bucketName}")privateString bucketName;@BeanpublicMinioClientminioClient(){MinioClient minioClient =MinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();return minioClient;}}
5.4、创建MinIO工具类
/**
 * MinIO工具类
 *
 */@Slf4j@Component@RequiredArgsConstructorpublicclassMinioUtils{privatefinalMinioClient minioClient;/******************************  Operate Bucket Start  ******************************//**
     * 启动SpringBoot容器的时候初始化Bucket
     * 如果没有Bucket则创建
     *
     * @param bucketName
     */@SneakyThrows(Exception.class)privatevoidcreateBucket(String bucketName){if(!bucketExists(bucketName)){
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());}}/**
     * 判断Bucket是否存在，true：存在，false：不存在
     *
     * @param bucketName
     * @return
     */@SneakyThrows(Exception.class)publicbooleanbucketExists(String bucketName){return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());}/**
     * 获得Bucket的策略
     *
     * @param bucketName
     * @return
     */@SneakyThrows(Exception.class)publicStringgetBucketPolicy(String bucketName){return minioClient.getBucketPolicy(GetBucketPolicyArgs.builder().bucket(bucketName).build());}/**
     * 获得所有Bucket列表
     *
     * @return
     */@SneakyThrows(Exception.class)publicList<Bucket>getAllBuckets(){return minioClient.listBuckets();}/**
     * 根据bucketName获取其相关信息
     *
     * @param bucketName
     * @return
     */@SneakyThrows(Exception.class)publicOptional<Bucket>getBucket(String bucketName){returngetAllBuckets().stream().filter(b -> b.name().equals(bucketName)).findFirst();}/**
     * 根据bucketName删除Bucket，true：删除成功； false：删除失败，文件或已不存在
     *
     * @param bucketName
     * @throws Exception
     */@SneakyThrows(Exception.class)publicvoidremoveBucket(String bucketName){
        minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());}/******************************  Operate Bucket End  ******************************//******************************  Operate Files Start  ******************************//**
     * 判断文件是否存在
     *
     * @param bucketName
     * @param objectName
     * @return
     */publicbooleanisObjectExist(String bucketName,String objectName){boolean exist =true;try{
            minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build());}catch(Exception e){
            log.error("[Minio工具类]>>>> 判断文件是否存在, 异常：", e);
            exist =false;}return exist;}/**
     * 判断文件夹是否存在
     *
     * @param bucketName
     * @param objectName
     * @return
     */publicbooleanisFolderExist(String bucketName,String objectName){boolean exist =false;try{Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(objectName).recursive(false).build());for(Result<Item> result : results){Item item = result.get();if(item.isDir()&& objectName.equals(item.objectName())){
                    exist =true;}}}catch(Exception e){
            log.error("[Minio工具类]>>>> 判断文件夹是否存在，异常：", e);
            exist =false;}return exist;}/**
     * 根据文件前置查询文件
     *
     * @param bucketName 存储桶
     * @param prefix     前缀
     * @param recursive  是否使用递归查询
     * @return MinioItem 列表
     */@SneakyThrows(Exception.class)publicList<Item>getAllObjectsByPrefix(String bucketName,String prefix,boolean recursive){List<Item> list =newArrayList<>();Iterable<Result<Item>> objectsIterator = minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(recursive).build());if(objectsIterator !=null){for(Result<Item> o : objectsIterator){Item item = o.get();
                list.add(item);}}return list;}/**
     * 获取文件流
     *
     * @param bucketName 存储桶
     * @param objectName 文件名
     * @return 二进制流
     */@SneakyThrows(Exception.class)publicInputStreamgetObject(String bucketName,String objectName){return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(objectName).build());}/**
     * 断点下载
     *
     * @param bucketName 存储桶
     * @param objectName 文件名称
     * @param offset     起始字节的位置
     * @param length     要读取的长度
     * @return 二进制流
     */@SneakyThrows(Exception.class)publicInputStreamgetObject(String bucketName,String objectName,long offset,long length){return minioClient.getObject(GetObjectArgs.builder().bucket(bucketName).object(objectName).offset(offset).length(length).build());}/**
     * 获取路径下文件列表
     *
     * @param bucketName 存储桶
     * @param prefix     文件名称
     * @param recursive  是否递归查找，false：模拟文件夹结构查找
     * @return 二进制流
     */publicIterable<Result<Item>>listObjects(String bucketName,String prefix,boolean recursive){return minioClient.listObjects(ListObjectsArgs.builder().bucket(bucketName).prefix(prefix).recursive(recursive).build());}/**
     * 使用MultipartFile进行文件上传
     *
     * @param bucketName  存储桶
     * @param file        文件名
     * @param objectName  对象名
     * @param contentType 类型
     * @return
     */@SneakyThrows(Exception.class)publicObjectWriteResponseuploadFile(String bucketName,MultipartFile file,String objectName,String contentType){InputStream inputStream = file.getInputStream();return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).contentType(contentType).stream(inputStream, inputStream.available(),-1).build());}/**
     * 图片上传
     * @param bucketName
     * @param imageBase64
     * @param imageName
     * @return
     */publicObjectWriteResponseuploadImage(String bucketName,String imageBase64,String imageName){if(!StringUtils.isEmpty(imageBase64)){InputStream in =base64ToInputStream(imageBase64);String newName =System.currentTimeMillis()+"_"+ imageName +".jpg";String year =String.valueOf(newDate().getYear());String month =String.valueOf(newDate().getMonth());returnuploadFile(bucketName, year +"/"+ month +"/"+ newName, in);}returnnull;}// BASE64Decoder在jdk8以上的版本移除了，报错最简单解决换成jdk8就行了publicstaticInputStreambase64ToInputStream(String base64){ByteArrayInputStream stream =null;try{byte[] bytes =newBASE64Decoder().decodeBuffer(base64.trim());
            stream =newByteArrayInputStream(bytes);}catch(Exception e){
            e.printStackTrace();}return stream;}/**
     * 上传本地文件
     *
     * @param bucketName 存储桶
     * @param objectName 对象名称
     * @param fileName   本地文件路径
     * @return
     */@SneakyThrows(Exception.class)publicObjectWriteResponseuploadFile(String bucketName,String objectName,String fileName){return minioClient.uploadObject(UploadObjectArgs.builder().bucket(bucketName).object(objectName).filename(fileName).build());}/**
     * 通过流上传文件
     *
     * @param bucketName  存储桶
     * @param objectName  文件对象
     * @param inputStream 文件流
     * @return
     */@SneakyThrows(Exception.class)publicObjectWriteResponseuploadFile(String bucketName,String objectName,InputStream inputStream){return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(inputStream, inputStream.available(),-1).build());}/**
     * 创建文件夹或目录
     *
     * @param bucketName 存储桶
     * @param objectName 目录路径
     * @return
     */@SneakyThrows(Exception.class)publicObjectWriteResponsecreateDir(String bucketName,String objectName){return minioClient.putObject(PutObjectArgs.builder().bucket(bucketName).object(objectName).stream(newByteArrayInputStream(newbyte[]{}),0,-1).build());}/**
     * 获取文件信息, 如果抛出异常则说明文件不存在
     *
     * @param bucketName 存储桶
     * @param objectName 文件名称
     * @return
     */@SneakyThrows(Exception.class)publicStringgetFileStatusInfo(String bucketName,String objectName){return minioClient.statObject(StatObjectArgs.builder().bucket(bucketName).object(objectName).build()).toString();}/**
     * 拷贝文件
     *
     * @param bucketName    存储桶
     * @param objectName    文件名
     * @param srcBucketName 目标存储桶
     * @param srcObjectName 目标文件名
     */@SneakyThrows(Exception.class)publicObjectWriteResponsecopyFile(String bucketName,String objectName,String srcBucketName,String srcObjectName){return minioClient.copyObject(CopyObjectArgs.builder().source(CopySource.builder().bucket(bucketName).object(objectName).build()).bucket(srcBucketName).object(srcObjectName).build());}/**
     * 删除文件
     *
     * @param bucketName 存储桶
     * @param objectName 文件名称
     */@SneakyThrows(Exception.class)publicvoidremoveFile(String bucketName,String objectName){
        minioClient.removeObject(RemoveObjectArgs.builder().bucket(bucketName).object(objectName).build());}/**
     * 批量删除文件
     *
     * @param bucketName 存储桶
     * @param keys       需要删除的文件列表
     * @return
     */publicvoidremoveFiles(String bucketName,List<String> keys){List<DeleteObject> objects =newLinkedList<>();
        keys.forEach(s ->{
            objects.add(newDeleteObject(s));try{removeFile(bucketName, s);}catch(Exception e){
                log.error("[Minio工具类]>>>> 批量删除文件，异常：", e);}});}/**
     * 获取文件外链
     *
     * @param bucketName 存储桶
     * @param objectName 文件名
     * @param expires    过期时间 <=7 秒 （外链有效时间（单位：秒））
     * @return url
     */@SneakyThrows(Exception.class)publicStringgetPresignedObjectUrl(String bucketName,String objectName,Integer expires){GetPresignedObjectUrlArgs args =GetPresignedObjectUrlArgs.builder().expiry(expires).bucket(bucketName).object(objectName).build();return minioClient.getPresignedObjectUrl(args);}/**
     * 获得文件外链
     *
     * @param bucketName
     * @param objectName
     * @return url
     */@SneakyThrows(Exception.class)publicStringgetPresignedObjectUrl(String bucketName,String objectName){GetPresignedObjectUrlArgs args =GetPresignedObjectUrlArgs.builder().bucket(bucketName).object(objectName).method(Method.GET).build();return minioClient.getPresignedObjectUrl(args);}/**
     * 将URLDecoder编码转成UTF8
     *
     * @param str
     * @return
     * @throws UnsupportedEncodingException
     */publicStringgetUtf8ByURLDecoder(String str)throwsUnsupportedEncodingException{String url = str.replaceAll("%(?![0-9a-fA-F]{2})","%25");returnURLDecoder.decode(url,"UTF-8");}}
5.5、创建Controller
/**
 * @author HAOYANG
 * @create 2023-12-01 20:38
 */@Slf4j@RestController@RequestMapping("/oss")publicclassOSSController{@AutowiredprivateMinioUtils minioUtils;@AutowiredprivateMinioConfig minioConfig;/**
     * 文件上传
     *
     * @param file
     */@PostMapping("/upload")publicStringupload(@RequestParam("file")MultipartFile file){try{//文件名String fileName = file.getOriginalFilename();String newFileName =System.currentTimeMillis()+"."+StringUtils.substringAfterLast(fileName,".");//类型String contentType = file.getContentType();
            minioUtils.uploadFile(minioConfig.getBucketName(), file, newFileName, contentType);return"上传成功";}catch(Exception e){
            log.error("上传失败");return"上传失败";}}/**
     * 删除
     *
     * @param fileName
     */@DeleteMapping("/")publicvoiddelete(@RequestParam("fileName")String fileName){
        minioUtils.removeFile(minioConfig.getBucketName(), fileName);}/**
     * 获取文件信息
     *
     * @param fileName
     * @return
     */@GetMapping("/info")publicStringgetFileStatusInfo(@RequestParam("fileName")String fileName){return minioUtils.getFileStatusInfo(minioConfig.getBucketName(), fileName);}/**
     * 获取文件外链
     *
     * @param fileName
     * @return
     */@GetMapping("/url")publicStringgetPresignedObjectUrl(@RequestParam("fileName")String fileName){return minioUtils.getPresignedObjectUrl(minioConfig.getBucketName(), fileName);}/**
     * 文件下载
     *
     * @param fileName
     * @param response
     */@GetMapping("/download")publicvoiddownload(@RequestParam("fileName")String fileName,HttpServletResponse response){try{InputStream fileInputStream = minioUtils.getObject(minioConfig.getBucketName(), fileName);
            response.setHeader("Content-Disposition","attachment;filename="+ fileName);
            response.setContentType("application/force-download");
            response.setCharacterEncoding("UTF-8");IOUtils.copy(fileInputStream, response.getOutputStream());}catch(Exception e){
            log.error("下载失败");}}}

6、测试验证

6.1、文件上传

使用Postman调用http://localhost:3333/oss/upload 接口，选择某个文件测试上传功能，如下图所示：

image-20231201213316663

6.2、文件下载

在浏览器中，调用http://localhost:3333/oss/download?fileName=1701436432918.gif 接口，验证文件下载接口，如下图所示：

image-20231201213607507

更多精彩文章可以关注
鹏摇星海

公众号

标签： docker 容器
本文转载自: https://blog.csdn.net/qq_54673740/article/details/134731886
版权归原作者 @昊阳 所有， 如有侵权，请联系我们删除。
登录后发布评论

“Docker 搭建 Minio 容器 (完整详细版)”的评论:

还没有评论
关于作者
...
overfit同步小助手
文章同步
相关阅读

网络安全法-网络运行安全

使用selenium/drissionpage时如何阻止chrome自动跳转http到https

docker desktop 里部署的Open WebUI 管理员密码忘记了的处理方法

在ubuntu20.04中搭建onsite比赛运行环境

利用开源的低代码表单设计器FcDesigner高效管理和渲染复杂表单结构

Kafka学习笔记

【前端】浏览器输入url到页面呈现发生了什么？

文章导航