具体可以参考七牛GO SDK的源码以及官网使用文档，以下Demo针对V7版本的SDK:
https://github.com/qiniu/go
http://developer.qiniu.com/code/v7/sdk/go.html
文件上传
简单上传
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"qiniupkg.com/api.v7/kodocli"
"fmt"
)
var (
//设置上传到的空间
bucket = "yourbucket"
)
//构造返回值字段
type PutRet struct {
Hash string `json:"hash"`
Key string `json:"key"`
}
func main() {
//初始化AK，SK
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//创建一个Client
c := kodo.New(0, nil)
//设置上传的策略
policy := &kodo.PutPolicy{
Scope: bucket,
//设置Token过期时间
Expires: 3600,
}
//生成一个上传token
token := c.MakeUptoken(policy);
//构建一个uploader
zone := 0
uploader := kodocli.NewUploader(zone, nil)
var ret PutRet
//设置上传文件的路径
filepath := "/Users/dxy/sync/sample2.flv"
//调用PutFileWithoutKey方式上传，没有设置saveasKey以文件的hash命名
res := uploader.PutFileWithoutKey(nil, &ret, token, filepath, nil)
//打印返回的信息
fmt.Println(ret)
//打印出错信息
if res != nil {
fmt.Println("io.Put failed:", res)
return
}
}覆盖上传
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"qiniupkg.com/api.v7/kodocli"
"fmt"
)
var (
//设置上传到的空间
bucket = "yourbucket"
//设置上传文件的key
key = "yourdefinekey"
)
//构造返回值字段
type PutRet struct {
Hash string `json:"hash"`
Key string `json:"key"`
}
func main() {
//初始化AK，SK
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//创建一个Client
c := kodo.New(0, nil)
//设置上传的策略
policy := &kodo.PutPolicy{
Scope: bucket+ ":" + key,
//设置Token过期时间
Expires: 3600,
InsertOnly: 1,
}
//生成一个上传token
token := c.MakeUptoken(policy);
//构建一个uploader
zone := 0
uploader := kodocli.NewUploader(zone, nil)
var ret PutRet
//设置上传文件的路径
filepath := "/Users/dxy/sync/sample2.flv"
//调用PutFile方式上传，这里的key需要和上传指定的key一致
res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
//打印返回的信息
fmt.Println(ret)
//打印出错信息
if res != nil {
fmt.Println("io.Put failed:", res)
return
}
}上传&回调
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"qiniupkg.com/api.v7/kodocli"
"fmt"
)
var (
//设置上传到的空间
bucket = "yourbucket"
//设置上传文件的key
key = "yourdefinekey"
//设置CallbackUrl字段
callbackurl = "http://your.domain.com/callback"
//设置CallbackBody字段
callbackbody = `{"key":$(key), "hash":$(etag),"filesize":$(fsize)}`
)
//构造返回值字段
type PutRet struct {
Hash string `json:"hash"`
Key string `json:"key"`
Filesize int `json:"filesize"`
}
func main() {
//初始化AK，SK
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//创建一个Client
c := kodo.New(0, nil)
//设置上传的策略
policy := &kodo.PutPolicy{
Scope: bucket+ ":" + key,
//设置Token过期时间
Expires: 3600,
CallbackUrl: callbackurl,
CallbackBody: callbackbody,
}
//生成一个上传token
token := c.MakeUptoken(policy);
//构建一个uploader
zone := 0
uploader := kodocli.NewUploader(zone, nil)
var ret PutRet
//设置上传文件的路径
filepath := "/xxx/xxx/sample.flv"
//调用PutFile方式上传，这里的key需要和上传指定的key一致
res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
//打印返回的信息
fmt.Println(ret)
//打印出错信息
if res != nil {
fmt.Println("io.Put failed:", res)
return
}
}上传&预转持续化(以视频转码为例)
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"qiniupkg.com/api.v7/kodocli"
"fmt"
)
var (
//设置上传到的空间
bucket = "yourbucket"
//设置上传文件的key
key = "yourdefinekey"
//设置转码参数
fops = "avthumb/mp4/s/640x360/vb/1.25m"
//设置转码用的队列
pipeline = "yourpipeline"
)
//构造返回值字段
type PutRet struct {
Hash string `json:"hash"`
Key string `json:"key"`
PersistentId string `json:"persistentId"`
}
func main() {
//初始化AK，SK
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//创建一个Client
c := kodo.New(0, nil)
//设置上传的策略
policy := &kodo.PutPolicy{
Scope: bucket+ ":" + key,
//设置Token过期时间
Expires: 3600,
InsertOnly: 1,
PersistentOps: fops,
PersistentPipeline: pipeline,
}
//生成一个上传token
token := c.MakeUptoken(policy);
//构建一个uploader
zone := 0
uploader := kodocli.NewUploader(zone, nil)
var ret PutRet
//设置上传文件的路径
filepath := "/xxx/xxx/sample.flv"
//调用PutFile方式上传，这里的key需要和上传指定的key一致
res := uploader.PutFile(nil, &ret, token, key, filepath, nil)
//打印返回的信息
fmt.Println(ret)
//打印出错信息
if res != nil {
fmt.Println("io.Put failed:", res)
return
}
}可以看到上传成功后的回调行为主要是有上传 Token 中的 policy 来指定。其中policy可以指定的行为不止这些，具体可以参考签权类中的policy字段。
文件下载
生成下载链接
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
)
var(
//指定私有空间的域名
domain = "xxxx.com2.z0.glb.qiniucdn.com"
//指定文件的key
key = "xxx.jpg"
)
//调用封装好的downloadUrl方法生成一个下载链接
func downloadUrl(domain, key string) string {
//调用MakeBaseUrl()方法将domain,key处理成http://domain/key的形式
baseUrl := kodo.MakeBaseUrl(domain, key)
policy := kodo.GetPolicy{}
//生成一个client对象
c := kodo.New(0, nil)
//调用MakePrivateUrl方法返回url
return c.MakePrivateUrl(baseUrl, &policy)
}
func main() {
//初始化AK，SK
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//打印出下载链接
println(downloadUrl(domain, key))
}
空间资源的管理
获取文件的信息
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"fmt"
)
var (
//设置需要操作的空间
bucket = "yourbucket"
//设置需要操作的文件的key
key = "yourkey"
)
func main() {
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//new一个Bucket管理对象
c := kodo.New(0, nil)
p := c.Bucket(bucket)
//调用Stat方法获取文件的信息
entry, err := p.Stat(nil, key)
//打印列取的信息
fmt.Println(entry)
//打印出错时返回的信息
if err != nil {
fmt.Println(err)
}
}移动单个文件
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"fmt"
)
var (
//设置需要操作的空间
bucket = "yourbucket"
//设置需要操作的文件的key
key = "yourkey"
//设置移动后文件的文件名
movekey = "movekey"
)
func main() {
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//new一个Bucket管理对象
c := kodo.New(0, nil)
p := c.Bucket(bucket)
//调用Move方法移动文件
res := p.Move(nil, key, movekey)
//打印返回值以及出错信息
if res == nil {
fmt.Println("Move success")
}else {
fmt.Println("Move failed:",res)
}
}复制单个文件
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"fmt"
)
var (
//设置需要操作的空间
bucket = "yourbucket"
//设置需要操作的文件的key
key = "yourkey"
//设置复制后文件的文件名
copykey = "yourcopykey"
)
func main() {
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//new一个Bucket管理对象
c := kodo.New(0, nil)
p := c.Bucket(bucket)
//调用Copy方法移动文件
res := p.Copy(nil, key, copykey)
//打印返回值以及出错信息
if res == nil {
fmt.Println("Copy success")
}else {
fmt.Println("Copy failed:",res)
}
}删除单个文件
package main
import (
"github.com/qiniu/api.v7/kodo"
"qiniupkg.com/api.v7/conf"
"fmt"
)
var (
//设置需要操作的空间
bucket = "yourbucket"
//设置需要操作的文件的key
key = "yourkey"
)
func main() {
conf.ACCESS_KEY = "ACCESS_KEY"
conf.SECRET_KEY = "SECRET_KEY"
//new一个Bucket管理对象
c := kodo.New(0, nil)
p := c.Bucket(bucket)
//调用Delete方法删除文件
res := p.Delete(nil, key)
//打印返回值以及出错信息
if res == nil {
fmt.Println("Delete success")
}else {
fmt.Println(res)
}
}有疑问加站长微信联系（非本文作者）
