【go语言开发】Minio基本使用，包括环境搭建，接口封装和代码测试

news2024/11/20 14:32:13

本文主要介绍go语言使用Minio对象存储，首先介绍搭建minio，创建bucket等，然后讲解封装minio客户端接口，包括但不限于：上传文件，下载，获取对象url，最后测试开发的接口

文章目录

  • 前言
  • Minio
    • docker安装minio
    • 创建bucket，指定accesskey等
  • 客户端接口封装
  • 代码测试

前言

Minio是一个开源的对象存储服务器，旨在提供高性能、可扩展和易于使用的存储解决方案。它兼容Amazon S3 API，因此可以与现有的S3工具和库集成，同时也提供了一套丰富的客户端SDK。

以下是Minio的一些主要特点：

  • 分布式架构： Minio支持分布式部署，可以通过添加更多的节点来实现容量和性能的无缝扩展。它使用一致性哈希算法来分配对象到不同的节点上，从而实现负载均衡和数据冗余。

  • 高性能： Minio采用了并发、异步和流式处理等技术，在保持数据完整性的同时，提供了出色的读写性能。它还支持多线程分段上传和下载，以加快大文件的传输速度。

  • 数据安全： Minio提供了多种数据保护机制，包括数据加密、访问控制列表（ACL）、策略和签名等。它还支持SSL/TLS加密传输，确保数据在传输过程中的安全性。

  • 易于使用： Minio提供了简单而直观的API，可以轻松地进行对象存储操作，如创建存储桶、上传和下载文件、删除对象等。它还提供了Web管理界面，方便用户进行管理和监控。

  • 多语言支持： Minio提供了多种编程语言的客户端SDK，包括Go、Java、Python、JavaScript等，使开发人员可以在不同的平台上使用自己熟悉的语言与Minio进行交互。

  • 可扩展性： Minio可以轻松地与其他存储系统集成，如分布式文件系统、块存储和对象存储等。它还支持动态缩放和容器化部署，以适应不同规模和需求的应用场景。

Minio

docker安装minio

docker介绍和常用命令使用请参考：docker常用命令介绍

具体搭建步骤可以参考：docker安装minio

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

启动成功：

在这里插入图片描述

创建bucket，指定accesskey等

网页访问：http://localhost:9090/，端口号9090修改为你指定的端口号，一般常用9090或者9000。

红圈地方用于创建AccessKey和SecretKey，注意记得备份一下额~
在这里插入图片描述
创建Buckets:
在这里插入图片描述

客户端接口封装

这里封装了上传、下载、删除、列出指定buckets下的对象等常规接口，可以按照自己的需求更改~

package utils

import (
	"fmt"
	"github.com/minio/minio-go"
	"log"
	"os"
)

var MinioClientGlobal *MinioClient

type MinioClient struct {
	Client *minio.Client
}

// NewMinioClient 初始化minio
func NewMinioClient(endpoint, accessKey, secretKey string) (*MinioClient, error) {
	// 初始化 Minio 客户端
	minioClient, err := minio.New(endpoint, accessKey, secretKey, false)
	if err != nil {
		log.Println("new minio client fail: ", err)
		return nil, err
	}
	client := &MinioClient{
		Client: minioClient,
	}
	MinioClientGlobal = client
	return client, nil
}

// UploadFile 上传文件
func (m *MinioClient) UploadFile(bucketName, objectName, filePath string) error {
	// 打开本地文件
	file, err := os.Open(filePath)
	if err != nil {
		log.Printf("open filePath: %s fail: %s", filePath, err)
		return err
	}
	defer file.Close()

	// 上传文件到存储桶
	_, err = m.Client.PutObject(bucketName, objectName, file, -1, minio.PutObjectOptions{})
	if err != nil {
		log.Println("putObject fail: ", err)
		return err
	}

	fmt.Println("Successfully uploaded", objectName)

	return nil
}

// DownloadFile 下载文件
func (m *MinioClient) DownloadFile(bucketName, objectName, filePath string) error {
	// 创建本地文件
	file, err := os.Create(filePath)
	if err != nil {
		return err
	}
	defer file.Close()

	// 下载存储桶中的文件到本地
	err = m.Client.FGetObject(bucketName, objectName, filePath, minio.GetObjectOptions{})
	if err != nil {
		return err
	}

	fmt.Println("Successfully downloaded", objectName)
	return nil
}

// DeleteFile 删除文件
func (m *MinioClient) DeleteFile(bucketName, objectName string) (bool, error) {
	// 删除存储桶中的文件
	err := m.Client.RemoveObject(bucketName, objectName)
	if err != nil {
		log.Println("remove object fail: ", err)
		return false, err
	}

	fmt.Println("Successfully deleted", objectName)
	return true, err
}

// ListObjects 列出文件
func (m *MinioClient) ListObjects(bucketName, prefix string) ([]string, error) {
	var objectNames []string

	for object := range m.Client.ListObjects(bucketName, prefix, true, nil) {
		if object.Err != nil {
			return nil, object.Err
		}

		objectNames = append(objectNames, object.Key)
	}

	return objectNames, nil
}

// GetPresignedGetObject 返回对象的url地址，有效期时间为expires
func (m *MinioClient) GetPresignedGetObject(bucketName string, objectName string, expires time.Duration) (string, error) {
	object, err := m.Client.PresignedGetObject(bucketName, objectName, expires, nil)
	if err != nil {
		log.Println("get object fail: ", err)
		return "", err
	}

	return object.String(), nil
}

代码测试

如何编写测试代码，可以参考【go语言开发】编写单元测试

下面是minio的配置，替换成自己的就可以

[minio]
MinioEndPoint = 127.0.0.1:9000
MinioAccessKey = NLtS0iNRFSCv6umJ
MinioSecretKey = 0cFaw1C0rp2CvhNIKYvAlqKrHNMB1rkn
MinioBucketName = go-blog

package test

import (
	"gin-blog/utils"
	"log"
	"testing"
)

const (
	filePath         = "./assets/test.txt"
	objectName       = "test.txt"
	downloadFilePath = "./assets/test2.txt"
)

// MinioInitTest 初始化minio client
func MinioInitTest() *utils.MinioClient {
	// 加载minio的endpoint等
	utils.InitConfig()
	log.Println(utils.MinioEndPoint, utils.MinioAccessKey, utils.MinioSecretKey)

	client, err := utils.NewMinioClient(utils.MinioEndPoint, utils.MinioAccessKey, utils.MinioSecretKey)
	if err != nil {
		log.Println("init minio fail")
		return nil
	}
	return client
}

// 测试上传文件
func TestMinioUpload(t *testing.T) {
	client := MinioInitTest()
	err := client.UploadFile(utils.MinioBucketName, objectName, filePath)
	if err != nil {
		t.Error("upload file: ", err)
	}
}

// 测试下载文件
func TestMinioDownloadFile(t *testing.T) {
	client := MinioInitTest()
	err := client.DownloadFile(utils.MinioBucketName, objectName, downloadFilePath)
	if err != nil {
		t.Error("download file: ", err)
	}
}

// 测试列出bucket下所有的对象
func TestListObjects(t *testing.T) {
	client := MinioInitTest()
	objects, err := client.ListObjects(utils.MinioBucketName, "")
	if err != nil {
		t.Error("list object: ", err)
	}
	log.Println("objects: ", objects)
}

// 删除对象
func TestDeleteFile(t *testing.T) {
	client := MinioInitTest()
	ret, err := client.DeleteFile(utils.MinioBucketName, objectName)
	if err != nil {
		t.Error("delete object: ", ret, err)
	}
	log.Println("delete object: ", ret)
}

// 获取对象，返回url,
func TestGetPresignedGetObject(t *testing.T) {
	client := MinioInitTest()
	object, err := client.GetPresignedGetObject(utils.MinioBucketName, objectName, 24*time.Hour)
	if err != nil {
		t.Error("GetPresignedGetObject: ", err)
	}
	log.Println("GetPresignedGetObject: ", object)
}

所有的接口都已经测试

上传文件：
在这里插入图片描述
在这里插入图片描述

获取对象url:
在这里插入图片描述

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1282643.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

【机器学习】线性模型之逻辑回归

【机器学习】线性模型之逻辑回归

文章目录 逻辑回归Sigmoid 函数概率输出结果预测值与真实标签之间的并不匹配交叉熵逻辑回归模型 梯度下降逻辑回归模型求解编程求解sklearn 实现，并查看拟合指标 逻辑回归 逻辑回归是一种广义线性模型，形式上引入了 S i g m o i d Sigmoid Sigmoid 函数…
阅读更多...
php之zip文件中压缩、解压、增加文件、删除

php之zip文件中压缩、解压、增加文件、删除

官方文档 PHP: Zip - Manual 在PHP中，zip扩展提供了处理ZIP文件的功能。它允许你创建、读取、更新和提取ZIP文件。 首先，确保你的PHP环境已经安装了zip扩展。你可以在php.ini文件中找到以下行来检查： extensionzip 如果没有注释掉&#xf…
阅读更多...
分享76个节日PPT，总有一款适合您

分享76个节日PPT，总有一款适合您

分享76个节日PPT，总有一款适合您 76个节日PPT下载链接：https://pan.baidu.com/s/1pUnIoIUhzyXAB_5LnKGnNg?pwd6666 提取码：6666 Python采集代码下载链接：采集代码.zip - 蓝奏云 学习知识费力气，收集整理更不易…
阅读更多...
openGauss学习笔记-139 openGauss 数据库运维-例行维护-检查应用连接数

openGauss学习笔记-139 openGauss 数据库运维-例行维护-检查应用连接数

文章目录 openGauss学习笔记-139 openGauss 数据库运维-例行维护-检查应用连接数139.1 操作步骤139.2 异常处理 openGauss学习笔记-139 openGauss 数据库运维-例行维护-检查应用连接数 如果应用程序与数据库的连接数超过最大值，则新的连接无法建立。建议每天检查连…
阅读更多...
日志模块Loguru

日志模块Loguru

安装 Loguru 仅支持 Python 3.5 及以上的版本，使用 pip 安装即可： pip install loguru开箱即用 Loguru 的主要概念是只有一个：logger from loguru import loggerlogger.info("This is log info!") logger.warning("This i…
阅读更多...
06、基于内容的过滤算法Tensorflow实现

06、基于内容的过滤算法Tensorflow实现

06、基于内容的过滤算法Tensorflow实现 开始学习机器学习啦，已经把吴恩达的课全部刷完了，现在开始熟悉一下复现代码。全部工程可从最上方链接下载。 05、基于梯度下降的协同过滤算法中已经介绍了协同过滤算法的基本实现方法，但是这种方法仅…
阅读更多...
Biomod2结果预览（部分结果草图预览）

Biomod2结果预览（部分结果草图预览）

阅读更多...
《视觉SLAM十四讲 从理论到实践（第2版）》

《视觉SLAM十四讲 从理论到实践（第2版）》

书中代码：GitHub - gaoxiang12/slambook2: edition 2 of the slambook 书籍PDF：关注【Learn from Zero】回复【SLAM142】即可领取
阅读更多...
变配电智能监控系统

变配电智能监控系统

变配电智能监控系统是一种能够实时监测电力变压器和配电柜、配电箱运行状态的智能设备。这种系统利用先进的传感器和数据通信技术，能够实时监测电力设备的运行状态，包括电压、电流、温度、湿度等参数，并且能够对这些数据进行处理和分析&#…
阅读更多...
2024版软件测试面试100问（答案+文档）

2024版软件测试面试100问（答案+文档）

软件测试面试百题 1、问：你在测试中发现了一个bug，但是开发经理认为这不是一个bug，你应该怎样解决? 首先，将问题提交到缺陷管理库里面进行备案。 然后，要获取判断的依据和标准： 根据需求说明书、产品说…
阅读更多...
AI时代的C++编程方向

AI时代的C++编程方向

欢迎关注博主 Mindtechnist 或加入【智能科技社区】一起学习和分享Linux、C、C、Python、Matlab，机器人运动控制、多机器人协作，智能优化算法，滤波估计、多传感器信息融合，机器学习，人工智能等相关领域的知识和技术。关…
阅读更多...
UOS打印任务监控

UOS打印任务监控

UOS系统下如何对一个打印任务进行监控呢？ 首先，UOS系统是支持这个功能。比如说我们打印一个任务后，UOS自带的打印管理器是能知道打印任务的状态的： 经过研究，最终发现了他的监控原理。 还得是DBus 没错，还是得通过DBus来实现打印任务监控。 话不多说，直接上代码： …
阅读更多...
SystemVerilog基础：并行块fork-join、join_any、join_none（一）

SystemVerilog基础：并行块fork-join、join_any、join_none（一）

相关阅读 SystemVerilog基础https://blog.csdn.net/weixin_45791458/category_12517449.html?spm1001.2014.3001.5482 有关Verilog中顺序块和并行块的相关内容已经在之前的Verilog基础的文章讲过，如下所示。 Verilog基础：块语句https://blog.csdn.net…
阅读更多...
Linux进程通信——内存映射mmap

Linux进程通信——内存映射mmap

Linux进程通信——内存映射mmap 1、创建内存映射区2、进程间通信2.1 有血缘关系2.2 没有血缘关系 3、拷贝文件 原文链接 1、创建内存映射区 如果想要实现进程间通信，可以通过函数创建一块内存映射区，和管道不同的是管道对应的内存空间在内核中&#xf…
阅读更多...
知识点滴 - 什么是半透膜和渗透压

知识点滴 - 什么是半透膜和渗透压

半透膜和渗透作用 1748年的一天，法国物理学家诺勒为了改进酒的制作水平，设计了这样一个试验：在一个玻璃圆筒中装满酒精，用猪膀胱封住，然后把圆筒全部浸在水中。当他正要做下一步的工作时，突然发现&#xff…
阅读更多...
MySQL 的 NULL 是怎么存储的？

MySQL 的 NULL 是怎么存储的？

目录 一、MySQL介绍 二、什么是NULL 三、MySQL 的 NULL 是怎么存储的 一、MySQL介绍 MySQL是一种关系型数据库管理系统（RDBMS），它是一种开源软件，由瑞典MySQL AB公司开发，后被Sun Microsystems收购，现在…
阅读更多...
【电机控制】PMSM无感foc控制（六）相电流检测及重构 — 双电阻采样、三电阻采样

【电机控制】PMSM无感foc控制（六）相电流检测及重构 — 双电阻采样、三电阻采样

0. 前言 目前，永磁同步电机的电流信号采样方法应用较多的是分流电阻采样，包括单电阻、双电阻以及三电阻采样法。其中，单电阻采样上一章节已经讲解，这章讲双电阻以及三电阻电流采样法。 1. 双电阻采样 1.1 双电阻采样原理 双电阻采…
阅读更多...
CRM管理系统：让你的业务运行更流畅

CRM管理系统：让你的业务运行更流畅

是客户关系管理系统的缩写。现代企业利用网络技术协调企业和客户之间在销售和服务上的对接，提升企业核心竞争力的一种手段。那么CRM管理系统一般包含哪些功能模块呢？今天小编为大家介绍一下。 一、好的CRM管理系统有哪些功能特性 1、有全方位的客户视图…
阅读更多...
【开源】基于Vue.js的河南软件客服系统

【开源】基于Vue.js的河南软件客服系统

文末获取源码，项目编号： S 067 。 \color{red}{文末获取源码，项目编号：S067。} 文末获取源码，项目编号：S067。 目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 系统管理人员2.2 业务操作人员 三、…
阅读更多...
Elasticsearch高级

Elasticsearch高级

文章目录 一.数据聚合二.RestAPI实现聚合三.ES自动补全(联想)四.数据同步五.elasticsearch集群 一.数据聚合 在ES中的数据聚合（aggregations）可以近似看做成mysql中的groupby分组,聚合可以实现对文档数据的统计、分析、运算,常见的聚合的分类有以下几种…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023