package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建OSSClient实例。 // yourEndpoint填写Bucket对应的Endpoint。 // 以华东1（杭州）为例，填写为https://oss-cn-hangzhou.aliyuncs.com。 client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 新增 err = client.CreateBucket( "examplebucket", oss.StorageClass(oss.StorageIA), oss.ACL(oss.ACLPublicRead), oss.RedundancyType(oss.RedundancyZRS) ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } /* StorageClass：存储类型。 StorageStandard=标准存储 StorageIA=低频访问 StorageArchive=归档存储 StorageColdArchive=冷归档存储 ACL：访问权限。 ACLPrivate=私有 ACLPublicRead=公共读 ACLPublicReadWrite=公共读写 RedundancyType：冗余类型。 RedundancyLRS=本地冗余 RedundancyZRS=同城冗余 */// 查询 marker := "" for { lsRes, err := client.ListBuckets(oss.Marker(marker)) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 默认情况下一次返回100条记录。 for _, bucket := range lsRes.Buckets { fmt.Println("Bucket: ", bucket.Name) }if lsRes.IsTruncated { marker = lsRes.NextMarker } else { break } }// 查询Region ID regionID, err := client.GetBucketLocation("examplebucket") if err != nil { fmt.Println("Error:", err) os.Exit(-1) } fmt.Println("Bucket Location:", regionID) // oss-cn-shanghai /* Region ID可以理解为Endpoint的前缀： 外网Endpoint：oss-cn-shanghai.aliyuncs.com 内网Endpoint：oss-cn-shanghai-internal.aliyuncs.com */// 删除 err = client.DeleteBucket("examplebucket") if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

1. 仅支持根据前缀和标签进行匹配，不支持通配符匹配、后缀匹配以及正则匹配。
2. 可以叠加，但上限为1000条。
3. 溯及既往
4. 生效：规则创建成功后的24小时内完成加载，加载成功后将于每天的08:00执行。
5. 最后修改时间与规则执行时间的间隔必须大于24小时。

package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func Main() { client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 定义规则// 前缀为10086的Object将于最后一次修改时间后的第14天删除 ruleA := oss.BuildLifecycleRuleByDays("ruleA", "10086", true, 14)// 前缀为10010的Object将于2025年10月10日的08:00删除 ruleB := oss.BuildLifecycleRuleByDate("ruleB", "10010", true, 2025, 10, 10)// 前缀为10000的Object的存储类型将于最后一次修改时间的30天后变更为低频访问 ruleC := oss.LifecycleRule{ ID:"ruleC", Prefix: "10000", Status: "Enabled", Transitions: []oss.LifecycleTransition{ { Days:30, StorageClass: oss.StorageIA, }, }, }// 设置规则 err = client.SetBucketLifecycle( "examplebucket", []oss.LifecycleRule{ruleA, ruleB, ruleC}, ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

• UTF-8编码
• 1 ~ 1024个字符
• 不能以/和\开头

package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func Main() { client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 生成Bucket实例 bucket, e := client.Bucket("examplebucket") if err != nil { fmt.Println("Error:", e) os.Exit(-1) }// 上传 if err = bucket.PutObject("objectKey", file); err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 删除 if err = bucket.DeleteObject("objectKey"); err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

{ "Version": "1", "Statement": [ { "Effect": "Deny", "Action": [ "oss:PutObject" ], "Resource": [ "acs:oss:*:*:examplebucket" ], "Condition": {} } ] }

Version：版本
Statement：授权语句
Effect：效力（Allow / Deny）
Action：操作
Resource：资源
Condition：条件

{ "Version": "1", "Statement": [ { "Effect": "Deny", "Action": [ "oss:PutObject" ], "Resource": [ "acs:oss:*:*:avatar" ], "Condition": {} } ] }

package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func Main() { client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 配置policy（禁止192.168.1.1之外的所有人对examplebucket的所有请求） policy := `{ "Version": "1", "Statement": [ { "Principal": ["*"], "Effect": "Deny", "Action": ["oss:*"], "Resource": ["acs:oss:*:*:examplebucket"], "Condition": { "NotIpAddress": { "acs:SourceIp": ["192.168.1.1"] } } } ] }`// 设置 err = client.SetBucketPolicy("examplebucket", policy) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 查询 policy, e := client.GetBucketPolicy("examplebucket") if e != nil { fmt.Println("Error:", e) os.Exit(-1) }// 删除 err = client.DeleteBucketPolicy("examplebucket") if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func Main() { client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置examplebucket的权限为公共读 err = client.SetBucketACL("examplebucket", oss.ACLPublicRead) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置examplebucket的权限为公共读写 err = client.SetBucketACL("examplebucket", oss.ACLPublicReadWrite) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置examplebucket的权限为私有 err = client.SetBucketACL("examplebucket", oss.ACLPrivate) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 查询Bucket ACL res, e := client.GetBucketACL("examplebucket") if e != nil { fmt.Println("Error:", e) os.Exit(-1) } }

package mainimport ( "fmt" "os" "github.com/aliyun/aliyun-oss-go-sdk/oss" )func Main() { client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 生成Bucket实例 bucket, e := client.Bucket("examplebucket") if e != nil { fmt.Println("Error:", e) os.Exit(-1) }// 设置exampleobject的权限为公共读 err = bucket.SetObjectACL("exampleobject", oss.ACLPublicRead) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置exampleobject的权限为公共读写 err = bucket.SetObjectACL("exampleobject", oss.ACLPublicReadWrite) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置exampleobject的权限为私有 err = bucket.SetObjectACL("exampleobject", oss.ACLPrivate) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 设置exampleobject的权限为继承Bucket err = bucket.SetObjectACL("exampleobject", oss.ACLDefault) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 查询Object ACL res, er := bucket.GetObjectACL("exampleobject") if er != nil { fmt.Println("Error:", er) os.Exit(-1) } }

err = client.CreateBucket( "examplebucket", oss.StorageClass(oss.StorageIA), oss.ACL(oss.ACLPublicRead), oss.RedundancyType(oss.RedundancyZRS) ) /* RedundancyType：冗余类型。 RedundancyLRS=本地冗余 RedundancyZRS=同城冗余 */

冗余类型仅支持创建Bucket时指定，一旦创建不支持修改。

package mainimport ( "fmt" "github.com/aliyun/aliyun-oss-go-sdk/oss" "os" )func main(){ client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }/* 指定仅同步复制规则创建后新写入的数据 不同步源Bucket的历史数据 且此后将源Bucket执行的所有操作都将实时同步到目标Bucket */ putXml := `

prefix_1

prefix_2 ALL destexamplebucket oss-cn-beijing oss_acc disabled aliyunramrole Enabled c4d49f85-ee30-426b-a5ed-95e9139d**** `// 开启跨区域复制 err = client.PutBucketReplication("srcexamplebucket",putXml) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

数据加密 OSS服务侧加密
上传Object时，OSS对收到的文件进行加密，再将加密文件持久化保存。
下载Object时，OSS自动将加密文件解密后返回，并在响应头中返回x-oss-server-side-encryption，用于声明该文件进行了OSS服务侧加密。

package mainimport ( "fmt" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建OSSClient实例 client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 初始化加密规则，使用AES256算法 config := oss.ServerEncryptionRule{ SSEDefault: oss.SSEDefaultRule{SSEAlgorithm: "AES256"}, }// 设置OSS服务侧加密 err = client.SetBucketEncryption("examplebucket", config) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

应用服务侧加密
应用服务侧加密是指将Object发送到OSS之前进行加密，然后将加密后的Object传输至OSS持久化保存。

文章图片

package mainimport ( "bytes" "fmt" "io" "io/ioutil" "log" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" "github.com/aliyun/aliyun-oss-go-sdk/oss/crypto" )func main() { // 创建OSSClient实例。 client, err := oss.New( "", "", "", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 创建一个主密钥的描述信息，创建后不允许修改。主密钥描述信息和主密钥一一对应。 // 如果所有的Object都使用相同的主密钥，主密钥描述信息可以为空，但后续不支持更换主密钥。 // 如果主密钥描述信息为空，解密时无法判断使用的是哪个主密钥。 // 强烈建议为每个主密钥都配置主密钥描述信息(json字符串), 由客户端保存主密钥和描述信息之间的对应关系（服务端不保存两者之间的对应关系）。// 由主密钥描述信息(json字符串)转换的map。 materialDesc := make(map[string]string) materialDesc["desc"] = ""// 根据主密钥描述信息创建一个主密钥对象。 masterRsaCipher, err := osscrypto.CreateMasterRsa( materialDesc, "", "", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 根据主密钥对象创建一个用于加密的接口, 使用aes ctr模式加密。 contentProvider := osscrypto.CreateAesCtrCipher(masterRsaCipher)// 获取bucket。 cryptoBucket, err := osscrypto.GetCryptoBucket(client, "", contentProvider) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 上传时时自动加密。 err = cryptoBucket.PutObject( "", bytes.NewReader([]byte("yourObjectValueByteArray")), ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 下载时自动解密。 body, err := cryptoBucket.GetObject("") if err != nil { fmt.Println("Error:", err) os.Exit(-1) } defer func(b *io.ReadCloser) { err = (*b).Close() if err != nil { log.Println("Error:", err) } }(&body)data, err := ioutil.ReadAll(body) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } fmt.Println("data:", string(data)) }

版本控制 版本控制以回滚至任一历史版本的方式，为错误覆盖和错误删除提供容错空间。
版本控制的一些限制：

1. 与合规保留策略无法同时配置
2. 开启版本控制的Bucket，x-oss-forbid-overwrite请求头将不再生效
3. 不建议同时开通OSS-HDFS服务并设置保留策略

版本控制有三个状态：未开启、开启、暂停。

package mainimport ( "fmt" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建Client实例。 client, err := oss.New( "", "", "", ) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 创建Bucket实例。 err = client.CreateBucket("") if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 开启版本控制。 config := oss.VersioningConfig{Status: "Enabled"} err = client.SetBucketVersioning("", config) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 暂停版本控制。 config.Status = "Suspended" err = client.SetBucketVersioning("", config) if err != nil { fmt.Println("Error:", err) os.Exit(-1) } }

防盗链 OSS通过对比request header的Referer与配置规则是否一致来判断允许或拒绝该请求。

package mainimport ( "fmt" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建Client实例。 client, err := oss.New("yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret") if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 初始化Referer白名单。支持通配符星号（*）和问号（？）。 referers := []string{ "http://www.aliyun.com", "http://www.???.aliyuncs.com", "http://www.*.com", }// 设置Referer白名单，并禁止空Referer // 注意：如果你配置了白名单但允许空Referer，结局会很僵硬... err = client.SetBucketReferer("yourBucketName", referers, false) if err != nil { fmt.Println("Error:", err) os.Exit(-1) }// 查询Bucket Referer res, e := client.GetBucketReferer("yourBucketName") if e != nil { fmt.Println("Error:", e) os.Exit(-1) } fmt.Println(res.RefererList, res.AllowEmptyReferer) }

合规保留策略 合规保留策略允许用户以“不可删除、不可篡改”方式保存和使用数据，符合美国证券交易委员会（SEC）和金融业监管局（FINRA）的合规要求。

package mainimport ( "fmt" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建OSSClient实例。 client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { handleError(err) }// 初始化WORM规则（锁定60天）。 // 最短锁定1天，最长锁定70年。 wormID, e := client.InitiateBucketWorm("examplebucket", 60) if e != nil { handleError(e) }/* 初始化后的24小时内，WORM处于InProgress状态。 在此期间，可以提交锁定，或者删除。 若在此期间即未提交锁定也未删除，则WORM自动失效。 */// 提交锁定 err = client.CompleteBucketWorm("examplebucket", wormID) if err != nil { handleError(err) }// 或者删除 /* err = client.AbortBucketWorm("examplebucket") if err != nil { handleError(err) } */// 通过Bucket查询WORM wormConfiguration, er := client.GetBucketWorm("examplebucket") if er != nil { handleError(er) }// WORM一旦提交锁定，在解锁日期前，WORM和Bucket内的所有Object均不支持删除。 // 但可以延长锁定期： err = client.ExtendBucketWorm( "examplebucket", 180, wormConfiguration.WormId, ) if err != nil { handleError(err) } }func handleError(err error) { fmt.Println("Error:", err) os.Exit(-1) }

日志

package mainimport ( "fmt" "os""github.com/aliyun/aliyun-oss-go-sdk/oss" )func main() { // 创建OSSClient实例。 client, err := oss.New( "yourEndpoint", "yourAccessKeyId", "yourAccessKeySecret", ) if err != nil { handleError(err) }// 开启 // 将examplebucket的日志存入destbucket。 err = client.SetBucketLogging("examplebucket", "destbucket", "log/", true) if err != nil { handleError(err) }// 查询 res, e := client.GetBucketLogging("examplebucket") if e != nil { handleError(e) } fmt.Println( res.LoggingEnabled.TargetBucket, res.LoggingEnabled.TargetPrefix, )// 关闭 err = client.DeleteBucketLogging("examplebucket") if err != nil { handleError(err) } }func handleError(err error) { fmt.Println("Error:", err) os.Exit(-1) }

细节 防止意外覆盖
默认情况下，如果上传的文件与已有文件同名，则覆盖已有文件。
为防止文件被意外覆盖，可以在上传请求的Header中携带参数x-oss-forbid-overwrite，并指定其值为true。
避免修改路径
OSS可以通过一些操作来模拟类似文件夹的功能，但是代价非常昂贵。

比如重命名目录，希望将test1目录重命名成test2，那么OSS的实际操作是将所有以test1/开头的Object都重新复制成以test2/开头的Object。
这是一个非常消耗资源的操作。因此在使用OSS的时候要尽量避免类似的操作。

性能与扩展性最佳实践
Object Key不要使用顺序前缀！！！
Object Key不要使用顺序前缀！！！
Object Key不要使用顺序前缀！！！

阿里云 对象存储 OSS

推荐阅读

• 

  weibull分布 威布尔分析方法
• 

  学习P.E.T父母效能训练第十四天《孩子欺负别人怎么办》
• 

  河南驻马店特产有哪些可带走
• 

  小米手环7
• 

  红眼病发烧反复怎么办 红眼病病毒存活时间
• 

  鱼缸co2钢瓶用什么气好,鱼缸打co2好吗
• 

  B站音乐播放器功能怎么样？B站音乐播放器功能正式上线
• 

  求推荐几款便宜的三脚架
• 

  卤煮是什么 什么是卤煮
• 

  靳煜（别回头、别纠缠、别念旧）
• 

  投稿|中国企业的冬奥进行时
• 

  网络适配器感叹号解决方法
• 

  html5盒子超出，html中设置盒子的宽高
• 

  boost哪款好穿？
• 

  酒精性脂肪肝|轻度脂肪肝没在意，4年后肝硬化中晚期！脂肪肝到肝癌只要4步
• 

  lru算法的分析与总结,算法设计与分析心得总结3000
• 

  怎么用java代码画爱心 用java编个爱心图案
• 

  吃鱼腥草可以喝酒吗
• 

  喜欢抱怨的孩子是怎么形成的
• 

  Java通过键盘输入一个字符串，判断字符串中出现最多的字符并输出该字符和输出出现次数...

• 前端面试|JS数组乱序的几种方法
• 微信小程序使用navigator实现页面跳转功能
• 科普达人丨一图看懂阿里云ECS
• Django4.0 RestFramework 序列器使用
• 官宣，首届阿里云NoSQL数据库峰会来袭！火速收藏
• vue项目打包后使用reverse-sourcemap反编译到源码（详解版）
• Flutter学习第四课（SharedPreferences本地存储的简单使用）
• html网页设计|使用html+css+js实现一个静态页面（含源码）
• html期末大作业|学生HTML个人网页作业作品 使用HTML+CSS+JavaScript个人介绍博客网站 web前端课程设计 web前端课程设计代码 web课程设计
• 使用|使用 Presto 和 Alluxio 在 AWS 上搭建高性能平台来支持实时游戏服务

上一篇：华为云主机安全助力企业种出“金葫芦”

下一篇：React报错之Expected an assignment or function