0
0

minio + linux + docker + spring boot实现文件上传与下载

minio + docker + spring boot实现文件上传与下载

1.在linux上安装并启动docker

  • 检查linux内核，必须是3.10以上
uname ‐r
  • 安装docker
yum installdocker
  • 启动docker
systemctl start docker

2.在docker中拉取minio并启动

  • 搜索镜像
docker search minio

在这里插入图片描述

  • 拉取镜像
docker pull minio/minio

在这里插入图片描述

  • 启动minio
docker run  -p9000:9000 -p9090:9090 --name minio \-d--restart=always \-eMINIO_ACCESS_KEY=vinci \-eMINIO_SECRET_KEY=123456\-v /usr/local/minio/data:/data \-v /usr/local/minio/config:/root/.minio \
  minio/minio server /data  --console-address ":9000"--address":9090"

-p: 指定端口映射，格式为：主机端口:容器端口 (这里注意要映射两个，否则API会访问不到)
-e “MINIO_ROOT_USER=vinci” minio用户名；
-e MINIO_SECRET_KEY=123456 minio 密码
-d: 后台运行容器，并返回容器ID；
-v: 绑定一个卷

这里可以看到minio已经在docker里启动起来了
在这里插入图片描述

接下来我们可以通过以下命令来查看 minio console和minio api 访问端口

docker logs minio

在这里插入图片描述

  • 访问minio控制台 在此步骤前记得开放端口号在这里插入图片描述 我们接下来可以使用密码和账号登录minio控制台了

3.Spring Boot 整合 minio

在此之前我们可以先通过控制台来创建一个bucket
在这里插入图片描述

  • 集成minio
<dependency><groupId>io.minio</groupId><artifactId>minio</artifactId><version>8.4.0</version></dependency>
  • 编写minio配置类
/**
 * @package: com.vinci.minio.config
 * @className: MinioConfig
 * @author: Vinci
 * @description: minio配置类
 * @date: 2023/10/27 13:10
 */@Data@Configuration@ConfigurationProperties(prefix ="minio")publicclassMinioConfig{privateString endpoint;privateString accessKey;privateString secretKey;privateString bucketName;@BeanpublicMinioClientminioClient(){returnMinioClient.builder().endpoint(endpoint).credentials(accessKey, secretKey).build();}}
  • 在application.properties中添加以下配置
minio.endpoint=http://108.13.21.28:9090/ 
minio.bucket-name=images
minio.access-key=xxxxx
minio.secret-key=xxxxx

注意 minio.endpoint 是minio API地址，不是控制台地址
minio.bucket-name 是 bucket的名称
minio.access-key 是用户名
minio.secret-key是密码

  • 编写minio工具类
packagecom.vinci.minio.utils;importcom.vinci.minio.config.MinioConfig;importio.minio.*;importio.minio.http.Method;importio.minio.messages.Bucket;importio.minio.messages.Item;importlombok.extern.slf4j.Slf4j;importorg.springframework.stereotype.Component;importorg.springframework.util.FastByteArrayOutputStream;importorg.springframework.web.multipart.MultipartFile;importjavax.annotation.Resource;importjavax.servlet.ServletOutputStream;importjavax.servlet.http.HttpServletResponse;importjava.text.SimpleDateFormat;importjava.util.ArrayList;importjava.util.Date;importjava.util.List;importjava.util.UUID;/**
 * @description: minio工具类
 * @author: Vinci
 * @date: 2023/10/27 13:23
 **/@Component@Slf4jpublicclassMinioUtil{@ResourceprivateMinioConfig config;@ResourceprivateMinioClient minioClient;/**
     * @description: 查看存储bucket是否存在
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param bucketName 要查看的bucket名称
     * @return 存在即返回true
     **/publicBooleanbucketExists(String bucketName){try{return minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());}catch(Exception e){
            log.error("发现异常",e);returnfalse;}}/**
     * @description: 创建存储bucket
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param bucketName 要创建的bucket名称
     * @return 创建成功即返回true
     **/publicBooleanmakeBucket(String bucketName){try{
            minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());returntrue;}catch(Exception e){
            log.error("发现异常",e);returnfalse;}}/**
     * @description: 删除存储bucket
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param bucketName 要删除的bucket名称
     * @return 删除成功即返回true
     **/publicBooleanremoveBucket(String bucketName){try{
            minioClient.removeBucket(RemoveBucketArgs.builder().bucket(bucketName).build());returntrue;}catch(Exception e){
            log.error("发现异常",e);returnfalse;}}/**
     * @description: 获取全部bucket
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @return 返回bucket结果集
     **/publicList<Bucket>getAllBuckets(){try{return minioClient.listBuckets();}catch(Exception e){
            log.error("发现异常",e);returnnull;}}/**
     * @description: 文件上传
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param file 表单上传的文件
     * @return 返回文件上传的路径
     **/publicStringupload(MultipartFile file){String originalFilename = file.getOriginalFilename();if(originalFilename ==null|| originalFilename.isEmpty()){thrownewRuntimeException();}String fileName =UUID.randomUUID()+ originalFilename.substring(originalFilename.lastIndexOf("."));String objectName =newSimpleDateFormat("yyyyMM").format(newDate())+"/"+ fileName;try{PutObjectArgs objectArgs =PutObjectArgs.builder().bucket(config.getBucketName()).object(objectName).stream(file.getInputStream(), file.getSize(),-1).contentType(file.getContentType()).build();
            minioClient.putObject(objectArgs);return objectName;}catch(Exception e){
            log.error("发现异常",e);returnnull;}}/**
     * @description: 预览图片
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param fileName 文件在bucket中的全路径
     * @return 返回文件的浏览路径
     **/publicStringpreview(String fileName){// 查看文件地址GetPresignedObjectUrlArgs build =GetPresignedObjectUrlArgs.builder().bucket(config.getBucketName()).object(fileName).method(Method.GET).build();try{return minioClient.getPresignedObjectUrl(build);}catch(Exception e){
            log.error("发现异常",e);returnnull;}}/**
     * @description: 文件下载
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @param fileName 文件在bucket中的全路径
     **/publicvoiddownload(String fileName,HttpServletResponse res){GetObjectArgs objectArgs =GetObjectArgs.builder().bucket(config.getBucketName()).object(fileName).build();try(GetObjectResponse response = minioClient.getObject(objectArgs)){byte[] buf =newbyte[1024];int len;try(FastByteArrayOutputStream os =newFastByteArrayOutputStream()){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","inline;fileName="+ fileName);try(ServletOutputStream stream = res.getOutputStream()){
                    stream.write(bytes);
                    stream.flush();}}}catch(Exception e){
            log.error("发现异常",e);}}/**
     * @description: 查看文件对象
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @return 存储bucket内文件对象信息
     **/publicList<Item>listObjects(){Iterable<Result<Item>> results = minioClient.listObjects(ListObjectsArgs.builder().bucket(config.getBucketName()).build());List<Item> items =newArrayList<>();try{for(Result<Item> result : results){
                items.add(result.get());}return items;}catch(Exception e){
            log.error("发现异常",e);returnnull;}}/**
     * @description: 删除文件信息
     * @author: Vinci
     * @date: 2023/10/27 13:24
     * @return 删除成功则返回true
     **/publicbooleanremove(String fileName){try{
            minioClient.removeObject(RemoveObjectArgs.builder().bucket(config.getBucketName()).object(fileName).build());returntrue;}catch(Exception e){
            log.error("发现异常",e);returnfalse;}}}

4.测试 minio 文件上传、下载及图片预览等功能

  • 编写controller通过接口的方式来测试minio功能
packagecom.vinci.minio.controller;importcom.vinci.minio.utils.MinioUtil;importorg.springframework.stereotype.Controller;importorg.springframework.web.bind.annotation.*;importorg.springframework.web.multipart.MultipartFile;importjavax.annotation.Resource;importjavax.servlet.http.HttpServletResponse;/**
 * @package: com.vinci.minio.controller
 * @className: TestMinioController
 * @author: Vinci
 * @description: 测试minio
 * @date: 2023/10/27 13:48
 */@Controller@RequestMapping(value ="/minio")publicclassTestMinioController{@ResourceprivateMinioUtil minioUtil;/**
     * @description: 文件上传测试
     * @author: Vinci
     * @date: 2023/10/27 13:48
     **/@ResponseBody@PostMapping("/upload")publicStringfileUpload(MultipartFile file){return minioUtil.upload(file);}/**
     * @description: 文件下载测试
     * @author: Vinci
     * @date: 2023/10/27 13:51
     **/@ResponseBody@GetMapping("/download")publicStringfileDownload(String fileName,HttpServletResponse response){
        minioUtil.download(fileName,response);return"success";}/**
     * @description: 图片预览
     * @author: Vinci
     * @date: 2023/10/27 13:53
     **/@GetMapping("/preview")publicStringimagePreview(String fileName){return minioUtil.preview(fileName);}}
  • 测试文件上传 使用postMan来调用文件上传的接口在这里插入图片描述 我们返回控制台可以看到文件已经上传上去了在这里插入图片描述
  • 测试文件下载在这里插入图片描述 我们借助postman工具点击发送并下载可以看到文件下载成功了在这里插入图片描述在这里插入图片描述
  • 图片在线预览在这里插入图片描述 我们同样借助postman工具发送请求，我们可以看到返回了图片的在线浏览地址，点击即可在线浏览图片在这里插入图片描述 以上便是minio 整合springboot的全部流程了，感谢阅读！ SpringBoot案例地址：https://gitee.com/vinci99/springboot-minio-test.git
标签： linux docker spring boot
本文转载自: https://blog.csdn.net/qq_45004609/article/details/134073781
版权归原作者 李予安 _ 所有， 如有侵权，请联系我们删除。
登录后发布评论

“minio + linux + docker + spring boot实现文件上传与下载”的评论:

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

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

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

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

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

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

Kafka学习笔记

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

文章导航