首页 > 其他分享 >初步搭建一个自己的对象存储服务---Minio

初步搭建一个自己的对象存储服务---Minio

时间：2024-06-01 20:55:40浏览次数：17  
标签：Minio minio -- --- 9001 9000 import 搭建 String

docker安装

1、拉取镜像
docker pull minio/minio
2、启动镜像

docker run -p 9000:9000 -p 9001:9001 --name minio -d --restart=always -e "MINIO_ACCESS_KEY=admin" -e "MINIO_SECRET_KEY=admin123456" -v /home/data:/data -v /home/config:/root/.minio minio/minio server --console-address ":9000" --address ":9001" /data

重要：

  • -p：9000 是图形界面的端口，9001 是 API 的端口，在使用 SDK 连接需要用到
  • MINIO_ACCESS_KEY：指定图形界面的用户名
  • MINIO_SECRET_KEY：指定图形界面的密码

命令参数及选项说明：

  1. docker run: 这是 Docker 的基本命令，用于运行一个新的容器。
  2. -p 9000:9000 -p 9001:9001: 使用 -p 或 --publish 选项将主机（宿主机）端口映射到容器内部端口。这里分别做了两个端口映射：
    • 9000:9000：将主机的 9000 端口与容器内的 9000 端口绑定，使得外部可以通过主机的 9000 端口访问到容器内运行的服务。
    • 9001:9001：同样地，将主机的 9001 端口与容器内的 9001 端口绑定。
  3. --name minio: 使用 --name 选项指定新创建容器的名称为 minio，便于后续管理和引用。
  4. -d: 使用 -d 或 --detach 标志使容器在后台以守护进程模式运行，即启动后立即返回控制台而不阻塞。
  5. --restart=always: 设置容器的重启策略为 always，这意味着如果容器意外停止（如由于系统重启或故障），Docker 将自动重新启动该容器。
  6. -e "MINIO_ACCESS_KEY=admin" -e "MINIO_SECRET_KEY=admin": 使用 -e 或 --env 选项设置环境变量。这里设置了 MinIO 需要的访问密钥和秘密密钥：
    • MINIO_ACCESS_KEY=admin：定义 MinIO 的访问密钥（Access Key），用于身份验证。
    • MINIO_SECRET_KEY=admin：定义 MinIO 的秘密密钥（Secret Key），与访问密钥一起构成认证凭据。
  7. -v /home/data:/data -v /home/config:/root/.minio: 使用 -v 或 --volume 选项挂载主机目录到容器内：
    • -v /home/data:/data：将主机上的 /home/data 目录挂载到容器内的 /data 目录，用于存放 MinIO 存储的数据。
    • -v /home/config:/root/.minio：将主机上的 /home/config 目录挂载到容器内的 /root/.minio 目录，通常用于保存 MinIO 的配置文件和其他持久化数据。
  8. minio/minio: 指定要使用的 Docker 镜像，这里是官方的 minio/minio 镜像。
  9. server: 运行 MinIO 容器时执行的命令，通常为 server，用于启动 MinIO 服务。
  10. --console-address ":9000" --address ":9001": 传递给 server 命令的 MinIO 特定参数：
  • --console-address ":9000"：指定 MinIO 管理控制台的监听地址为 :9000，即容器内的所有网络接口都会监听此端口。由于已经做了端口映射，外部可以通过主机的 9000 端口访问控制台。
  • --address ":9001"：指定 MinIO 服务 API 的监听地址为 :9001，同样对所有网络接口开放。外部可通过主机的 9001 端口与 MinIO API 进行交互。
  1. /data: 最后的 /data 参数指定了 MinIO 服务的数据目录，即使用挂载的 /data 目录作为存储桶数据的实际位置。

访问

浏览器输入http://ip:9000/login

图形界面

1、创建桶
image.png

2、设置权限
image.png

3、获取accessKey 和 secretKey
image.png

注意：创建__accessKey 和 secretKey的时候，要注意保存好。

Java连接Minio（SDK）

1、添加依赖

<dependency>
  <groupId>io.minio</groupId>
  <artifactId>minio</artifactId>
  <version>8.2.1</version>
</dependency>

2、demo

import io.minio.BucketExistsArgs;
import io.minio.MakeBucketArgs;
import io.minio.MinioClient;
import io.minio.UploadObjectArgs;
import io.minio.errors.MinioException;

import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;

public class FileUploader {
    // minio的api 端口（不是图形界面）
    public static String endPoint = "http://xxx.xxx.xxx.xxx:9001/";
    
    public static String accessKey = "YLCS8UYJFX02E70OV7MK";
    public static String secretKey = "不能外露";

    public static void main(String[] args) throws IOException, NoSuchAlgorithmException, InvalidKeyException {
        try {
            // 创建minioClient， 使用上面的endpoint,ak,sk
            MinioClient minioClient =
            MinioClient.builder()
            .endpoint(endPoint)
            .credentials(accessKey, secretKey)
            .build();

            // 如果指定的bucket不存在，则创建，否则使用已有bucket
            // 指定bucket名称
            String bucketName = "test";
            boolean found =
            minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            if (!found) {
                minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
            } else {
                System.out.println("Bucket '" + bucketName + "' already exists.");
            }

            // 文件来自哪里
            String filePath = "C:\\Users\\DELL\\Pictures\\Saved Pictures\\2.jpg";
            // 存储后的文件名
            String fileName = "minio_test_text.png";

            // 执行文件上传
            minioClient.uploadObject(
                UploadObjectArgs.builder()
                .bucket(bucketName)
                .object(fileName)
                .filename(filePath)
                .build());
            System.out.println("'" + filePath + "' 成功上传对象 '" + fileName + "' 到 bucket '" + bucketName + "'.");
        } catch (MinioException e) {
            System.out.println("Error occurred: " + e);
            System.out.println("HTTP trace: " + e.httpTrace());
        }
    }
}

封装工具类

1、配置文件

  chuangyue:
    minio:
      # 访问的url
      endpoint: http://xxx.xxx.xxx.xxx
      # API的端口
      port: 9001
      # 秘钥
      accessKey: YLCS8UYJFX02E70OV7MK
      secretKey: 不能看
      secure: false
      bucket-name: test # 桶名 我这是给出了一个默认桶名
      image-size: 10485760 # 我在这里设定了 图片文件的最大大小
      file-size: 1073741824 # 此处是设定了文件的最大大小

2、属性配置类

@Component
@ConfigurationProperties(prefix = "chuangyue.minio")
@Data
public class MinioProperties {
    // 访问的 api 的url
    private String endpoint;
    // api端口号
    private String port;
    // 密钥
    private String accessKey;
    private String secretKey;
    private Boolean secure;
    // 桶名
    private String bucketName;
    // 图片文件的最大大小
    private long imageSize;
    // 文件的最大大小
    private long fileSize;
}

3、工具类

package com.zyp.utils;

import io.minio.*;
import io.minio.errors.MinioException;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import org.springframework.web.multipart.MultipartFile;

import java.io.IOException;
import java.security.InvalidKeyException;
import java.security.NoSuchAlgorithmException;
import java.util.UUID;

@Component
@Slf4j
public class MinioUtil {
    
    /**
     * @ description 上传
     * @param file 文件
     * @param endPoint 访问的地址
     * @param port 端口号
     * @param accessKey 密钥
     * @param secretKey 密钥
     * @param bucketName 桶名称
     * @ return java.lang.String
     * @ author DELL
     */
    public static String upload(MultipartFile file, String endPoint, String port, String accessKey, String secretKey, String bucketName) throws IOException, NoSuchAlgorithmException, InvalidKeyException {
        try {
            // 创建minioClient
            MinioClient minioClient =
                    MinioClient.builder()
                            .endpoint(endPoint + ":" + port)
                            .credentials(accessKey, secretKey)
                            .build();

            // 如果指定的bucket不存在，则创建，否则使用已有bucket
            boolean found =
                    minioClient.bucketExists(BucketExistsArgs.builder().bucket(bucketName).build());
            if (!found) {
                minioClient.makeBucket(MakeBucketArgs.builder().bucket(bucketName).build());
            } else {
                log.info("Bucket {} already exists", bucketName);
            }

            // 获取文件原始名称
            String oringinalName = file.getOriginalFilename();
            // 获取后缀
            String suffix = oringinalName.substring(oringinalName.lastIndexOf('.'));
            // 拼接存储后的文件名
            String fileName = UUID.randomUUID().toString() + suffix;

            PutObjectArgs putObjectArgs = PutObjectArgs.builder()
                    .bucket(bucketName)
                    .object(fileName)
                    .stream(file.getInputStream(), file.getSize(), -1)
                    .contentType(file.getContentType())
                    .build();

            minioClient.putObject(putObjectArgs);
            log.info("文件上传成功");

            // 拼接url并返回
            return endPoint + ":" + port + "/" + bucketName + "/" + fileName;

        } catch (MinioException e) {
            System.out.println("Error occurred: " + e);
            System.out.println("HTTP trace: " + e.httpTrace());
            return "error";
        }
    }
}

4、使用，定义一个文件上传的接口

@RestController
@Slf4j
public class FileUploadController {
    @Autowired
    private MinioProperties minioProperties;

    /**
     * @ description 文件上传
     * @param file
     * @ return com.zyp.pojo.Result<java.lang.String>
     * @ author DELL
     */
    @PostMapping("/upload")
    public Result<String> upload(MultipartFile file) throws Exception {

        String url = MinioUtil.upload(file, minioProperties.getEndpoint(), minioProperties.getPort(), minioProperties.getAccessKey(), minioProperties.getSecretKey(), minioProperties.getBucketName());
        log.info("url= {}",url);

        if(url.isEmpty() || url.equals("error")){
            throw new UploadErrorException("文件上传失败");
        }else{
            return Result.success(url);
        }
    }
}

常见问题

1、tomcat限制了文件上传或者下载的大小
解决：修改配置文件

spring:
  servlet:
    multipart:
      max-file-size: 50MB
      max-request-size: 50MB

标签：Minio,minio,--,---,9001,9000,import,搭建,String
From： https://www.cnblogs.com/beiyuan888/p/18226370

相关文章

  • Springboot 开发 -- 统一异常处理最佳实践
    引言在企业级应用开发中，异常处理是保障系统稳定性和可维护性的关键环节。SpringBoot提供了一系列优雅的异常处理机制，帮助开发者更高效地管理和响应异常情况。本文将总结SpringBoot中异常处理的最佳实践。一、异常处理原则在进行异常处理之前，需要明确几个基本的处理......
  • 鸿蒙HarmonyOS实战-Web组件（请求响应和页面调试）
    ......
  • 数据分析实战2---时间序列分析
    项目背景：本实训以自行车租赁统计数据为例，使用Pandas中的时间序列分析方法，探究自行车租赁数据随时间及天气变化的分布情况。采用的数据可在Kaggle网站（BikeSharingDemandStella|Kaggle）下载任务步骤：1.导入模块importpandasaspdimportnumpyasnpimportmatplotlib.......
  • 项目管理---计算机英语常见词汇
    项目管理英语词汇常见的计算机词汇Agile敏捷APIApplicationProgramminInterface应用程序编程接口ApplicationLayer应用层ArtificialIntelligence人工智能Augmented Reality增强现实Availability可用性B/S：Browser/ServerBeidouSatelliteNavigationSystem......
  • 锐捷校园网自助服务-字符过滤存在缺陷
    锐捷校园网自助服务-字符过滤存在缺陷漏洞介绍令人感到十分遗憾的是，锐捷网络安全应急响应中心对漏洞上报似乎缺少了一些奖励，令人对官方上报漏洞失去了些许兴趣​。该缺陷仅仅打破了安全检查防护，并没有造成实质性危害，至于打破了护盾后能够产生什么样的具有实质性危害的web......
  • Ansible05-Ansible进阶（流程控制、Roles角色、加密优化调优等）
    目录写在前面7Ansible进阶7.1流程控制7.1.1handlers触发器与notify7.1.1.1未使用handlers7.1.1.2使用handlers7.1.2when判断7.1.2.1when的语法7.1.2.2when判断主机名选择模块输出7.1.2.3when结合register变量7.1.3loop/with_items循环7.1.3.1with_items案......
  • 基于BERT-BILSTM的中文情感识别
            欢迎来到BERT-BiLSTM中文情感识别项目！我们利用BERT模型提取文本语义特征，结合BiLSTM网络学习时序信息，显著提升中文情感识别性能。为解决训练时间长问题，我们部署在GPU环境，加速模型训练。项目提供可视化中文情感识别系统，欢迎贡献代码、建议或数据，共同优化模型，让中......
  • Vue-router之页面跳转
    目录1.Vue Router1.1VueRouter的简介1.2安装1.3创建路由器实例2.router-link页面跳转2.1.router-link简介2.2使用路由对象的query属性进行传参1.Vue Router1.1VueRouter的简介官方文档见：https://router.vuejs.org/zh/introduction.htmlhttps://router.v......
  • HIT-CSAPP大作业——程序人生-Hello‘s P2P
    计算机系统大作业题    目  程序人生-Hello’sP2P 专      业        信息安全        学号       2022******        班    级          22*****        ......
  • Spire.Doc for Java 12.5.1 -2024-05-30
    Spire.DocforJavaisaprofessionalWordAPIthatempowersJavaapplicationstocreate,convert,manipulateandprintWorddocumentswithoutdependencyonMicrosoftWord.Byusingthismultifunctionallibrary,developersareabletoprocesscopioustasks......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99