Go 实现的 aliyun oss sdk

用法

1. 在项目根目录创建 .env 文件，在文件内填写 oss 的配置信息：

ALIYUN_KEY_ID=xxx
ALIYUN_KEY_SECRET=xxx
ALIYUN_ENDPOINT=cn-shanghai
# 支持内网使用
# ALIYUN_ENDPOINT=cn-shanghai-internal
ALIYUN_BUCKET=xxx

2. 运行如下代码

package main

import (
	"fmt"
	"os"

	"github.com/tu6ge/oss-go"
	"github.com/tu6ge/oss-go/types"
)

func main() {
	// 初始化 client
	client, err := oss.NewWithEnv()
	// 或者
	// client,err := oss.New("key","secret","bucket_name","cn-hangzhou")
	if err != nil {
		fmt.Println(err)
		return
	}

	// 根据默认配置的 endpoint 获取 bucket 列表
	buckets_from_cofig, err := client.GetBuckets()
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(buckets_from_cofig)

	end, err := types.NewEndPoint("cn-shanghai")
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(end)

	// 获取所有 bucket
	buckets, err := client.GetBuckets(end)
	if err != nil {
		fmt.Println(err)
		return
	}

	// 查询文件列表
	query := map[string]string{
		oss.QUERY_MAX_KEYS: "5",
	}

	objects, err := buckets[1].Query(query).GetObjects(&client)
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(objects)

	// 查询第二页的文件列表
	second_objects, err := objects.NextList(&client)
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println(second_objects)

	// 初始化文件结构体
	obj := oss.NewObject("aaabbc4.html")


	// 使用文件内容上传文件
	content := []byte("foo")

	err = obj.Content(content).ContentType("text/plain;charset=utf-8").Upload(&client)
	if err != nil {
		fmt.Println(err)
		return
	}

	// 使用文件句柄上传文件
	f, err := os.Open("./demofile.txt")
	if err != nil {
		fmt.Println(err)
		return
	}
	defer f.Close()

	err = oss.NewObject("from_file.txt").File(f).ContentType("text/plain;charset=utf-8").Upload(&client)
	if err != nil {
		fmt.Println(err)
		return
	}

	// 使用本地文件路径上传文件
	err = oss.NewObject("from_file2.txt").FilePath("./demofile.txt").ContentType("text/plain;charset=utf-8").Upload(&client)
	if err != nil {
		fmt.Println(err)
		return
	}

  // 下载文件内容
	con, err := obj.Download(&client)
	if err != nil {
		fmt.Println(err)
		return
	}
	fmt.Println("content:", string(con))

	// 复制文件
	obj_copy := oss.NewObject("xyz.html")
	err = obj_copy.CopySource("/honglei123/aaabbc.html").ContentType("text/plain;charset=utf-8").Copy(&client)
	if err != nil {
		fmt.Println(err)
		return
	}

	// 删除文件
	err = obj.Delete(&client)
	if err != nil {
		fmt.Println(err)
		return
	}

	// 文件的分片上传
	object := oss.NewPartsUpload("video222.mov")

	err = object.FilePath("./video.mov").Upload(&client)
	if err != nil {
		fmt.Println("error:", err)
	}
	fmt.Println("upload success")

	// 大文件的分片下载
	object := oss.NewPartsDownload("video222.mov")

	err = object.FilePath("./video.mov").Download(&client)
	if err != nil {
		fmt.Println("error:", err)
	}
	fmt.Println("download success")
}

Bench

跟 aliyun 官方提供的 sdk 进行 bench 比较，发现性能提高了一倍，以下是上传文件进行 bench 的测试

goos: darwin
goarch: arm64
pkg: bench
cpu: Apple M1
BenchmarkSelfUpload-8                 19          55770158 ns/op
BenchmarkAliyunUpload-8               10         102589812 ns/op

运行 bench 的方法

git clone [email protected]:tu6ge/oss-go.git
cd oss-go/bench
# 重命名 .env.example 为 .env 并加上 aliyun oss 的配置
go test --bench=.