devbox
菜鸟追梦旅行
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

MINIO部署

作者：菜鸟追梦旅行 | 2024-05-02 11:34:23

赞

踩

minio部署

一、MINIO单机部署

Linux下载地址:https://min.io/download#/linux

  1. 服务器创建新的文件夹； 
    mkdir -p /home/minio/data

  2. 上传下载好的minio文件，到指定的目录下/home/minio/data；

  3. 执行命令；

    1. chmod +x minio    //给予权限
    2. export MINIO_ACCESS_KEY=minioadmin   //创建账号
    3. export MINIO_SECRET_KEY=minioadmin   //创建密码
  4. 启动minio； 
    nohup ./minio server  --address :9000 --console-address :9001 /home/minio/data > /home/minio/data/minio.log &

    自定义端口方式：自定义启动端口号以及控制台端口号，不设置则控制台会自动配置其他端口号，非常不方便

  5. 查看状态；

    ps -  ef|grep   minio
  6. 至此安装启动完成；

  7. 访问：127.0.0.1:9001/（注意：端口是控制台的端口）；

  8. 输入步骤3设置的账号密码，进入到了管理页面；

  9. 设置桶，创建桶，在服务器中会生成一个和桶名称相同的文件夹；

  10. 设置桶规则；修改权限public,设置规则为readwrite;
  11. 测试上传文件到桶里边；

  12. 上传完文件之后，在服务器的桶中会生成一个文件；

二、JAVA集成

1) pom.xml导入相关依赖;

  1. <dependency>
  2.     <groupId>io.minio</groupId>
  3.     <artifactId>minio</artifactId>
  4.     <version>8.3.5</version>
  5. </dependency>
  6. <!--OK Http-->
  7. <dependency>
  8.     <groupId>com.squareup.okhttp3</groupId>
  9.     <artifactId>okhttp</artifactId>
  10.     <version>4.9.1</version>
  11. </dependency>

2)配置文件中增加配置信息;

  1. minio:
  2.   endpoint: http://127.0.0.1:9000
  3.   accesskey: minioadmin             #用户名
  4.   secretKey: minioadmin             #密码
  5.   bucketName: files                  #桶名称

3)配置创建实体类;

  1. @Data
  2. @Component
  3. @ConfigurationProperties(prefix = "minio")
  4. public class MinioProp {
  5.     /**
  6.      * 连接url
  7.      */
  8.     private String endpoint;
  9.     /**
  10.      * 用户名
  11.      */
  12.     private String accesskey;
  13.     /**
  14.      * 密码
  15.      */
  16.     private String secretKey;
  17.  
  18.     /**
  19.      * 桶名称
  20.      */
  21.     private String bucketName;
  22.  
  23. }

4)创建minioconfig;

  1. @Configuration
  2. @EnableConfigurationProperties(MinioProp.class)
  3. public class MinioConfig {
  4.     @Autowired
  5.     private MinioProp minioProp;
  6.  
  7.     @Bean
  8.     public MinioClient minioClient(){
  9.         MinioClient minioClient = MinioClient.builder().endpoint(minioProp.getEndpoint()).
  10.                 credentials(minioProp.getAccesskey(), minioProp.getSecretKey()).region("china").build();
  11.         return minioClient;
  12.     }
  13.  
  14. }

5)编写minioUtil类；

上传：

  1. public JSONObject uploadFile(MultipartFile file) throws Exception {
  2.     JSONObject res = new JSONObject();
  3.     res.put("code", 0);
  4.     // 判断上传文件是否为空
  5.     if (null == file || 0 == file.getSize()) {
  6.         res.put("msg", "上传文件不能为空");
  7.         return res;
  8.     }
  9.     InputStream is=null;
  10.     try {
  11.         // 判断存储桶是否存在
  12.         createBucket(minioProp.getBucketName());
  13.         // 文件名
  14.         String originalFilename = file.getOriginalFilename();
  15.         // 新的文件名 = 存储桶名称_时间戳.后缀名
  16.         String fileName = minioProp.getBucketName() + "_" + IdUtil.getId() + originalFilename.substring(originalFilename.lastIndexOf("."));
  17.         // 开始上传
  18.         is=file.getInputStream();
  19.         PutObjectArgs putObjectArgs = PutObjectArgs.builder()
  20.                 .bucket(minioProp.getBucketName())
  21.                 .object(fileName)
  22.                 .contentType(file.getContentType())
  23.                 .stream(is, is.available(), -1)
  24.                 .build();
  25.         minioClient.putObject(putObjectArgs);
  26.  
  27.         res.put("code", 1);
  28.         res.put("msg",  minioProp.getBucketName() + "/" + fileName);
  29.         res.put("bucket", minioProp.getBucketName());
  30.         res.put("fileName", fileName);
  31.         return res;
  32.     }  catch (Exception e) {
  33.         e.printStackTrace();
  34.         log.error("上传文件失败：{}", e.getMessage());
  35.     }finally {
  36.         is.close();
  37.     }
  38.     res.put("msg", "上传失败");
  39.     return res;
  40. }

下载：

  1. public void downLoad(String fileName,String realFileName, HttpServletResponse response, HttpServletRequest request) {
  2.     InputStream is=null;
  3.     OutputStream os =null;
  4.     try {
  5.         is=getObjectInputStream(fileName,minioProp.getBucketName());
  6.         if(is!=null){
  7.             byte buf[] = new byte[1024];
  8.             int length = 0;
  9.             String codedfilename = "";
  10.             String agent = request.getHeader("USER-AGENT");
  11.             System.out.println("agent:" + agent);
  12.             if ((null != agent && -1 != agent.indexOf("MSIE")) || (null != agent && -1 != agent.indexOf("Trident"))) {
  13.                 String name = URLEncoder.encode(realFileName, "UTF8");
  14.                 codedfilename = name;
  15.             } else if (null != agent && -1 != agent.indexOf("Mozilla")) {
  16.                 codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");
  17.             } else {
  18.                 codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");
  19.             }
  20.             response.reset();
  21.             response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(realFileName.substring(realFileName.lastIndexOf("/") + 1), "UTF-8"));
  22.             response.setContentType("application/octet-stream");
  23.             response.setCharacterEncoding("UTF-8");
  24.             os = response.getOutputStream();
  25.             // 输出文件
  26.             while ((length = is.read(buf)) > 0) {
  27.                 os.write(buf, 0, length);
  28.             }
  29.             // 关闭输出流
  30.             os.close();
  31.  
  32.         }else{
  33.             log.error("下载失败");
  34.         }
  35.     }catch (Exception e){
  36.         e.printStackTrace();
  37.         log.error("错误："+e.getMessage());
  38.     }finally {
  39.         if(is!=null){
  40.             try {
  41.                 is.close();
  42.             } catch (IOException e) {
  43.                 e.printStackTrace();
  44.             }
  45.         }
  46.         if(os!=null){
  47.             try {
  48.                 os.close();
  49.             } catch (IOException e) {
  50.                 e.printStackTrace();
  51.             }
  52.         }
  53.     }
  54. }

删除：

  1. public void deleteObject(String objectName) {
  2.     try {
  3.         RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder()
  4.                 .bucket(minioProp.getBucketName())
  5.                 .object(objectName)
  6.                 .build();
  7.         minioClient.removeObject(removeObjectArgs);
  8.     }catch (Exception e){
  9.         log.error("错误："+e.getMessage());
  10.     }
  11. }

查看：一个url

例如127.0.0.1:9000/files/files_1660635187005.png;

格式：ip:端口/桶/文件在桶里的真实名字；

完整的util类：

  1.  
  2.  
  3. import com.alibaba.fastjson2.JSONObject;
  4. import com.crcc.statistics.common.entity.MinioProp;
  5. import io.minio.*;
  6. import lombok.SneakyThrows;
  7. import lombok.extern.slf4j.Slf4j;
  8. import org.springframework.beans.factory.annotation.Autowired;
  9. import org.springframework.stereotype.Component;
  10. import org.springframework.web.multipart.MultipartFile;
  11.  
  12. import javax.servlet.http.HttpServletRequest;
  13. import javax.servlet.http.HttpServletResponse;
  14. import java.io.IOException;
  15. import java.io.InputStream;
  16. import java.io.OutputStream;
  17. import java.net.URLEncoder;
  18. import java.util.HashMap;
  19. import java.util.Map;
  20.  
  21. /**
  22.  * @Author smallhou
  23.  * @Date 2022-08-15 14:31
  24.  * @Version V1.0
  25.  */
  26. @Slf4j
  27. @Component
  28. public class MinioUtils {
  29.  
  30.     @Autowired
  31.     private MinioClient minioClient;
  32.     @Autowired
  33.     private MinioProp minioProp;
  34.  
  35.     /**
  36.      * @Author smallhou
  37.      * @Description //TODO 判断桶存在不存在，不存在创建桶
  38.      * @Date 10:49 2022-08-16
  39.      * @Param [bucketName]
  40.      * @return void
  41.      **/
  42.     @SneakyThrows
  43.     public void createBucket(String bucketName) {
  44.         if (!minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build())) {
  45.             minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
  46.         }
  47.  
  48.     }
  49.  
  50.     @SneakyThrows
  51.     public InputStream getObjectInputStream(String objectName,String bucketName){
  52.         GetObjectArgs getObjectArgs = GetObjectArgs.builder()
  53.                 .bucket(bucketName)
  54.                 .object(objectName)
  55.                 .build();
  56.         return minioClient.getObject(getObjectArgs);
  57.     }
  58.  
  59.  
  60.     public JSONObject uploadFile(MultipartFile file) throws Exception {
  61.         JSONObject res = new JSONObject();
  62.         res.put("code", 0);
  63.         // 判断上传文件是否为空
  64.         if (null == file || 0 == file.getSize()) {
  65.             res.put("msg", "上传文件不能为空");
  66.             return res;
  67.         }
  68.         InputStream is=null;
  69.         try {
  70.             // 判断存储桶是否存在
  71.             createBucket(minioProp.getBucketName());
  72.             // 文件名
  73.             String originalFilename = file.getOriginalFilename();
  74.             // 新的文件名 = 存储桶名称_时间戳.后缀名
  75.             String fileName = minioProp.getBucketName() + "_" + IdUtil.getId() + originalFilename.substring(originalFilename.lastIndexOf("."));
  76.             // 开始上传
  77.             is=file.getInputStream();
  78.             PutObjectArgs putObjectArgs = PutObjectArgs.builder()
  79.                     .bucket(minioProp.getBucketName())
  80.                     .object(fileName)
  81.                     .contentType(file.getContentType())
  82.                     .stream(is, is.available(), -1)
  83.                     .build();
  84.             minioClient.putObject(putObjectArgs);
  85.  
  86.             res.put("code", 1);
  87.             res.put("msg",  minioProp.getBucketName() + "/" + fileName);
  88.             res.put("bucket", minioProp.getBucketName());
  89.             res.put("fileName", fileName);
  90.             return res;
  91.         }  catch (Exception e) {
  92.             e.printStackTrace();
  93.             log.error("上传文件失败：{}", e.getMessage());
  94.         }finally {
  95.             is.close();
  96.         }
  97.         res.put("msg", "上传失败");
  98.         return res;
  99.     }
  100.  
  101.     public void downLoad(String fileName,String realFileName, HttpServletResponse response, HttpServletRequest request) {
  102.         InputStream is=null;
  103.         OutputStream os =null;
  104.         try {
  105.             is=getObjectInputStream(fileName,minioProp.getBucketName());
  106.             if(is!=null){
  107.                 byte buf[] = new byte[1024];
  108.                 int length = 0;
  109.                 String codedfilename = "";
  110.                 String agent = request.getHeader("USER-AGENT");
  111.                 System.out.println("agent:" + agent);
  112.                 if ((null != agent && -1 != agent.indexOf("MSIE")) || (null != agent && -1 != agent.indexOf("Trident"))) {
  113.                     String name = URLEncoder.encode(realFileName, "UTF8");
  114.                     codedfilename = name;
  115.                 } else if (null != agent && -1 != agent.indexOf("Mozilla")) {
  116.                     codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");
  117.                 } else {
  118.                     codedfilename = new String(realFileName.getBytes("UTF-8"), "iso-8859-1");
  119.                 }
  120.                 response.reset();
  121.                 response.setHeader("Content-Disposition", "attachment;filename=" + URLEncoder.encode(realFileName.substring(realFileName.lastIndexOf("/") + 1), "UTF-8"));
  122.                 response.setContentType("application/octet-stream");
  123.                 response.setCharacterEncoding("UTF-8");
  124.                 os = response.getOutputStream();
  125.                 // 输出文件
  126.                 while ((length = is.read(buf)) > 0) {
  127.                     os.write(buf, 0, length);
  128.                 }
  129.                 // 关闭输出流
  130.                 os.close();
  131.  
  132.             }else{
  133.                 log.error("下载失败");
  134.             }
  135.         }catch (Exception e){
  136.             e.printStackTrace();
  137.             log.error("错误："+e.getMessage());
  138.         }finally {
  139.             if(is!=null){
  140.                 try {
  141.                     is.close();
  142.                 } catch (IOException e) {
  143.                     e.printStackTrace();
  144.                 }
  145.             }
  146.             if(os!=null){
  147.                 try {
  148.                     os.close();
  149.                 } catch (IOException e) {
  150.                     e.printStackTrace();
  151.                 }
  152.             }
  153.         }
  154.     }
  155.  
  156.     public void deleteObject(String objectName) {
  157.         try {
  158.             RemoveObjectArgs removeObjectArgs = RemoveObjectArgs.builder()
  159.                     .bucket(minioProp.getBucketName())
  160.                     .object(objectName)
  161.                     .build();
  162.             minioClient.removeObject(removeObjectArgs);
  163.         }catch (Exception e){
  164.             log.error("错误："+e.getMessage());
  165.         }
  166.     }
  167.  
  168.  
  169. }

三、总结：

部署相对简单，JAVA集成快，上手更容易；

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/523843
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号