根据Minio文件直接返回下载

方案一

首先创建一个名为 DownloadFile 的方法它接受一个 types.DownloadReq 类型的参数，并返回一个 byte 类型的切片和一个 error 类型的错误。

在该方法中从 Minio 客户端获取一个 object 对象，并使用 minio.GetObjectOptions 结构体获取该对象的详细信息。随后，我们使用 ioutil 包的 ReadAll 方法将对象读取到 chunk 切片中。最后返回我们读取到的内容

func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}

	chunk, err := ioutil.ReadAll(object)
	if err != nil {
		fmt.Println("read to fd fail", err)
		return nil, nil
	}

	return chunk, nil
}

方案二

我们可以再将上一个方案稍作改进，并使用 bytes.Buffer 类型的变量 bowl 代替 ioutil 包。

func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}

	bowl := bytes.Buffer{}
	num, err := bowl.ReadFrom(object)
	fmt.Println(num)
	return bowl.Bytes(),nil
	
}

方案三

这个方案与前两个方案有所不同。我们采用了一个循环来读取对象的每个块，并将它们添加到一个 chunk 切片中。

func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}

	var chunk []byte
	buf := make([]byte, 1024)
	for {
		// 从file读取到buf中
		// Read reads up to len(b) bytes into b.
		// It returns the number of bytes read (0 <= n <= len(b)) and any error encountered.
		// Returns io.EOF upon end of file.
		n, err := object.Read(buf)
		if err != nil && err != io.EOF {
			fmt.Println("read buf fail", err)
			return err, nil
		}
		// 读取结束
		if n == 0 {
			fmt.Println("n=0")
			break
		}
		// 读取到最终的缓冲区中
		chunk = append(chunk, buf[:n]...)
	}
	return chunk, nil
}

方案四

类似第三个方案，这个方案通过一个 bufio.Reader 来逐块读取文件，并将每个块添加到一个 chunk 切片中。

func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}
	r := bufio.NewReader(object)
	var chunk []byte
	buf := make([]byte, 1024)
	for {
		n, err := r.Read(buf)
		if err != nil && err != io.EOF {
			panic(err)
		}
		if 0 == n {
			break
		}
		//fmt.Println(string(buf))
		chunk = append(chunk, buf...)
	}
	return chunk, nil
}

Minio文件压缩返回Zip文件

在这个示例中我们将会从 Minio 中获取一个文件，将其添加到一个新的 Zip 文件中，并将 Zip 文件返回给客户端。

func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}
	buf := new(bytes.Buffer)
	w := zip.NewWriter(buf)
	f, err := w.Create(req.GetObjectName)
	if err != nil {
		return nil, err
	}
	if _, err := io.Copy(f, object); err != nil {
		return nil, err
	}
	if err := w.Close(); err != nil {
		return nil, err
	}
	return buf.Bytes(), nil
}

生成带压缩密码ZiP文件

如果你想创建带有压缩密码的 Zip 文件，可以使用 zipWriter.Encrypt 方法来为每个文件项设置密码。在下面的示例中，我们遵循与上一个示例相同的基本格式，只是这次我们在 zipWriter.Encrypt 中传递了一个字符串作为密码。

import (
"bytes"
"context"
"github.com/alexmullins/zip"
"github.com/minio/minio-go/v6"
"github.com/zeromicro/go-zero/core/logx"
"io"
)


func (l *DownloadFileLogic) DownloadFile(req *types.DownloadReq) (byte []byte, err error) {

	// 获取MinIO对象
	var object *minio.Object
	object, err = l.svcCtx.Minio.Client.GetObject(l.svcCtx.Config.Minio.Bucket, req.GetObjectName, minio.GetObjectOptions{})
	if err != nil {
		l.Logger.Error("Download from minio error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}
	// 创建一个新的字节数组缓冲区和zip文件写入器
	buf := new(bytes.Buffer)
	zipWriter := zip.NewWriter(buf)
	// 向zip文件写入器中添加一个文件项，并将原始数据复制到该文件项中
	file, err := zipWriter.Encrypt(req.GetObjectName, "pwd")
	if err != nil {
		l.Logger.Error("DownloadFile zipWriter.Create error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}
	if _, err = io.Copy(file, object); err != nil {
		l.Logger.Error("DownloadFile io.Copy error:{} object: {}", err, objectName)
		return nil, err
	}
	// 关闭zip文件写入器以刷新所有缓冲区并生成完整的ZIP文件
	if err = zipWriter.Close(); err != nil {
		l.Logger.Error("DownloadFile zipWriter.Close() error:{} object: {}", err, req.GetObjectName)
		return nil, err
	}
	// 返回ZIP文件的字节切片
	return buf.Bytes(), nil
    
}

小结

在这篇文章中我们以 Golang 实现 Minio 获取文件转压缩文件下载为主题，介绍了四种方案。方案一是直接从 Minio 客户端获取一个对象，并使用 ioutil 包读取到一个切片中。方案二则是利用 bytes.Buffer 类型的变量来代替 ioutil 包进行读取。方案三和方案四则采用了不同方式通过循环分块读取文件内容，并将其添加到一个切片中。

此外也介绍了如何使用 Minio 执行文件压缩并返回 Zip 文件，以及如何生成带有压缩密码的 Zip 文件。这些示例让您可以更好地理解使用 Golang 实现 Minio 获取文件转压缩文件下载的方式，并能够将其应用于自己的项目中。

总而言之，论您是初学者还是高级程序员，在阅读本文之后，您都能够更好地理解如何使用 Golang 实现 Minio 获取文件转压缩文件下载，并能够将其应用于自己的项目中。