开源minio-AWS-S3存储的部署及go操作详细

介绍

MinIO是一个开源的分布式对象存储服务，它允许用户在私有云或公有云环境中构建自己的对象存储基础设施。MinIO旨在提供高性能、高可用性的对象存储，并且与Amazon S3兼容，这意味着可以使用S3客户端工具和库直接与MinIO交互，而无需更改现有的应用程序代码。

以下是一些关键的MinIO特性和信息：

1. 分布式架构： MinIO设计为具有分布式架构，允许用户将多个MinIO实例组合成一个集群，提供高可用性和可扩展性。每个MinIO实例可以运行在独立的硬件节点上，通过负载均衡器或DNS轮询等方式进行负载均衡。

2. S3兼容性： MinIO与Amazon S3的API兼容，这意味着现有的S3客户端工具和库可以直接用于与MinIO进行交互。这种兼容性使得迁移现有S3应用程序到MinIO变得相对简单。

3. 开源： MinIO是开源的，它的源代码可以在GitHub上获得。这使得用户能够审查和修改源代码以满足他们特定的需求，并且可以在社区的支持下获得帮助。

4. 轻量级： MinIO设计为轻量级和高性能。它专注于提供快速的对象存储服务，而不引入过多的复杂性。

5. 安全性： MinIO支持SSL/TLS加密，以确保在数据传输过程中的安全性。此外，它还提供身份验证和访问控制功能，以保护存储在MinIO中的数据。

6. 版本控制： MinIO支持对象版本控制，允许用户存储和检索不同版本的对象。这对于处理数据的变更和回滚操作非常有用。

7. 事件通知： MinIO支持事件通知，可以在对象被创建、删除或更新时触发通知。这为构建自动化工作流和应用程序提供了便利。

8. 易于部署： MinIO提供了容器化的部署选项，可以轻松地在容器环境中部署，例如使用Docker。

总的来说，MinIO是一个灵活、高性能、可扩展且S3兼容的对象存储解决方案，适用于构建私有云、混合云或公有云环境中的存储基础设施。

部署

yum remove docker docker-common container-selinux docker-selinux docker-engine
yum install -y yum-utils
yum-config-manager --add-repo http://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repoyum install -y docker-cedocker run -d \-p 9000:9000 \-p 9001:9001 \-e "MINIO_ROOT_USER=LIUYUNSHENG" \-e "MINIO_ROOT_PASSWORD=LIUYUNSHENGKEY" \minio/minio server /data --console-address "0.0.0.0:9001"

go相关操作代码

package mainimport ("context""fmt""log""os""path""github.com/aws/aws-sdk-go-v2/aws""github.com/aws/aws-sdk-go-v2/config""github.com/aws/aws-sdk-go-v2/credentials""github.com/aws/aws-sdk-go-v2/service/s3"
)func main() {cfg, err := config.LoadDefaultConfig(context.TODO(),config.WithCredentialsProvider(credentials.NewStaticCredentialsProvider("LIUYUNSHENG", "LIUYUNSHENGKEY", "")),config.WithEndpointResolverWithOptions(aws.EndpointResolverWithOptionsFunc(func(service, region string, options ...interface{}) (aws.Endpoint, error) {return aws.Endpoint{URL: "http://127.0.0.1:9000",}, nil})),config.WithRegion("cn-north-1"),)if err != nil {return}client := s3.NewFromConfig(cfg, func(o *s3.Options) {o.UsePathStyle = true //https://s3.amazonaws.com/BUCKET/KEY})// 打印所有的桶result, err := client.ListBuckets(context.TODO(), &s3.ListBucketsInput{})if err != nil {return}for _, bucket := range result.Buckets {fmt.Println(*bucket.Name)}// 创建桶bucketName := "liuysh-bucket"client.CreateBucket(context.TODO(), &s3.CreateBucketInput{Bucket: &bucketName})// 上传文件fileName := "/var/lib/pgsql/pgsql/go/go1.21.5.linux-amd64.tar.gz"file, err := os.Open(fileName)fileBase := path.Base(fileName)if err != nil {fmt.Printf("Couldn't open file %v to upload. Here's why: %v\n", fileName, err)} else {defer file.Close()_, err = client.PutObject(context.TODO(), &s3.PutObjectInput{Bucket: aws.String(bucketName),Key:    aws.String(fileBase),Body:   file,})if err != nil {log.Printf("Couldn't upload file %v to %v:%v. Here's why: %v\n",fileName, bucketName, file.Name(), err)}}}