Go SDK历史版本

最近更新时间: 2019-12-16 17:22:39

七牛云存储的 GO 语言版本 SDK（本文以下称 GO-SDK）是对七牛云存储API协议的一层封装，以提供一套对于 GO 开发者而言简单易用的原生 GO 函数。GO 开发者在对接 GO-SDK 时无需理解七牛云存储 API 协议的细节，原则上也不需要对 HTTP 协议和原理做非常深入的了解，但如果拥有基础的 HTTP 知识，对于出错场景的处理可以更加高效。

GO-SDK 以开源方式提供。开发者可以随时从本文档提供的下载地址查看和下载 SDK 的源代码。

由于 GO 语言的通用性，GO-SDK 被设计为同时适合服务器端和客户端使用。服务端是指开发者自己的业务服务器，客户端是指开发者的客户终端。服务端因为有七牛颁发的 AccessKey/SecretKey，可以做很多客户端做不了的事情，比如删除文件、移动/复制文件等操作。一般而言，客服端操作文件需要获得服务端的授权。客户端上传文件需要获得服务端颁发的上传凭证，客户端下载文件（包括下载处理过的文件，比如下载图片的缩略图）需要获得服务端颁发的下载凭证。但开发者也可以将 bucket 设置为公开，此时文件有永久有效的访问地址，不需要业务服务器的授权，这对网站的静态文件（如图片、js、css、html）托管非常方便。

从 v5.0.0 版本开始，我们对 SDK 的内容进行了精简。所有管理操作，比如：创建/删除 bucket、为 bucket 绑定域名（publish）、设置数据处理的样式分隔符、新增数据处理样式等都去除了，统一建议到开发者平台来完成。另外，此前服务端还有自己独有的上传 API，现在也推荐统一成基于客户端上传的工作方式。

从内容上来说，GO-SDK 主要包含如下几方面的内容：

公共库: api/conf
客户端上传文件：api/io
客户端断点续上传：api/resumable/io
数据处理：api/fop
服务端操作：api/auth/digest (授权)，api/rs(资源管理，uptoken/dntoken颁发)，api/rsf(批量获取文件列表)

安装

在命令行下执行

go get -u github.com/qiniu/api.v7

初始化

要接入七牛云存储，您需要拥有一对有效的 Access Key 和 Secret Key 用来进行签名认证。可以通过如下步骤获得：

开通七牛开发者帐号
登录七牛开发者自助平台，查看 Access Key 和 Secret Key 。

在获取到 Access Key 和 Secret Key 之后，您可以在您的程序中调用如下两行代码进行初始化对接，要确保 ACCESS_KEY 和 SECRET_KEY 在服务端调用 api/auth/digest，api/rs，api/rsf之前均已赋值：

import ."github.com/qiniu/api.v6/conf"

ACCESS_KEY = "<YOUR_APP_ACCESS_KEY>"
SECRET_KEY = "<YOUR_APP_SECRET_KEY>"

上传文件

为了尽可能地改善终端用户的上传体验，七牛云存储首创了客户端直传功能。一般云存储的上传流程是：

客户端（终端用户） => 业务服务器 => 云存储服务

这样多了一次上传的流程，和本地存储相比，会相对慢一些。但七牛引入了客户端直传，将整个上传过程调整为：

客户端（终端用户） => 七牛 => 业务服务器

客户端（终端用户）直接上传到七牛的服务器，通过DNS智能解析，七牛会选择到离终端用户最近的ISP服务商节点，速度会比本地存储快很多。文件上传成功以后，七牛的服务器使用回调功能，只需要将非常少的数据（比如Key）传给应用服务器，应用服务器进行保存即可。

注意：如果您只是想要上传已存在您电脑本地或者是服务器上的文件到七牛云存储，可以直接使用七牛提供的 qshell 上传工具。
文件上传有两种方式，一种是以普通方式直传文件，简称普通上传，另一种方式是断点续上传，断点续上传在网络条件很一般的情况下也能有出色的上传速度，而且对大文件的传输非常友好。

上传流程

在七牛云存储中，整个上传流程大体分为这样几步：

业务服务器颁发上传凭证给客户端（终端用户）
客户端凭借上传凭证上传文件到七牛
在七牛获得完整数据后，发起一个 HTTP 请求回调到业务服务器
业务服务器保存相关信息，并返回一些信息给七牛
七牛原封不动地将这些信息转发给客户端（终端用户）

需要注意的是，回调到业务服务器的过程是可选的，它取决于业务服务器颁发的上传凭证。如果没有回调，七牛会返回一些标准的信息（比如文件的 hash）给客户端。如果上传发生在业务服务器，以上流程可以自然简化为：

业务服务器生成 uptoken（不设置回调，自己回调到自己这里没有意义）
凭借上传凭证上传文件到七牛
善后工作，比如保存相关的一些信息

生成上传授权uptoken

uptoken是一个字符串，业务服务器根据(rs.PutPolicy)的结构体的各个参数来生成上传凭证的代码如下（调用如下代码前，请确保Access Key 和 Secret Key已经被正确初始化）:

func uptoken(bucketName string) string {
    putPolicy := rs.PutPolicy {
        Scope:         bucketName,
        //CallbackUrl: callbackUrl,   
        //CallbackBody:callbackBody,    
        //ReturnUrl:   returnUrl,  
        //ReturnBody:  returnBody,    
        //AsyncOps:    asyncOps,    
        //EndUser:     endUser,    
        //Expires:     expires,   
    }
    return  putPolicy.Token(nil)
}

参阅 rs.PutPolicy

上传代码

上传文件到七牛（通常是客户端完成，但也可以发生在业务服务器）。
由于七牛的服务器支持自动生成key，所以本SDK提供的上传函数有两种展现方式，一种是有key的，一种是无key，让服务端自动生成key。
普通上传的文件和二进制，最后一个参数都是PutExtra类型，是用来细化上传功能用的，PutExtra的成员及其意义如下：

type PutExtra struct {
    Params   map[string]string    //可选，用户自定义参数，必须以 "x:" 开头
                                  //若不以x:开头，则忽略
    MimeType string               //可选，当为 "" 时候，服务端自动判断 
    Crc32    uint32
    CheckCrc uint32
            // CheckCrc == 0: 表示不进行 crc32 校验
            // CheckCrc == 1: 对于 Put 等同于 CheckCrc = 2；对于 PutFile 会自动计算 crc32 值
            // CheckCrc == 2: 表示进行 crc32 校验，且 crc32 值就是上面的 Crc32 变量
}

直接上传内存中的数据，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器端生成的上传口令
// key       为文件存储的标识
// r         为io.Reader类型，用于从其读取数据
// extra     为上传文件的额外信息,可为空， 详情见 io.PutExtra, 可选
err = io.Put(nil, &ret, uptoken, key, r, extra)

if err != nil {
//上传产生错误
    log.Print("io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.Put, io.PutExtra

直接上传内存中的数据，且不提供key参数，此时key由七牛服务器自动生成，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器端生成的上传口令
// r         为io.Reader类型，用于从其读取数据
// extra     为上传文件的额外信息,可为空， 详情见 io.PutExtra, 可选
err = io.PutWithoutKey(nil, &ret, uptoken, r, extra)

if err != nil {
//上传产生错误
    log.Print("io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.Put, io.PutExtra

上传本地文件，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// localFile 为本地文件名
// extra     为上传文件的额外信息，详情见 io.PutExtra，可选
err = io.PutFile(nil, &ret, uptoken, key, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("io.PutFile failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.PutFile, io.PutExtra, io.PutRet

上传本地文件，且不提供 key 参数，此时 key 由七牛服务器自动生成代码:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器生成的上传口令
// localFile 为本地文件名
// extra     为上传文件的额外信息，详情见 io.PutExtra，可选
err = io.PutFileWithoutKey(nil, &ret, uptoken, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("io.PutFile failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.PutFile, io.PutExtra, io.PutRet

断点续上传、分块并行上传

除了基本的上传外，七牛还支持你将文件切成若干块（除最后一块外，每个块固定为4M大小），每个块可独立上传，互不干扰；每个分块块内则能够做到断点上续传。

断点续上传函数，最后一个选项是 resumable.io.PutExtra结构体，来细化上传用的，其成员及其含义如下：

type PutExtra struct {
    CallbackParams  string  // 当 uptoken 指定了 CallbackUrl，则 CallbackParams 必须非空
    Bucket          string
    CustomMeta      string  // 可选。用户自定义 Meta，不能超过 256 字节
    MimeType        string  // 可选。在 uptoken 没有指定 DetectMime 时，用户客户端可自己指定 MimeType
    ChunkSize    int    // 可选。每次上传的Chunk大小
    TryTimes    int    // 可选。尝试次数
    Progresses    []BlkputRet // 可选。上传进度
    Notify        func(blkIdx int, blkSize int, ret *BlkputRet) // 可选。进度提示（注意多个block是并行传输的）
    NotifyErr    func(blkIdx int, blkSize int, err error)
}

我们先看支持的断点续上传、分块并行上传的基本样例：

上传二进制流

var err error
var ret io.PutRet
var extra = &rio.PutExtra {
    //CallbackParams: callbackParams,
    //Bucket:         bucket,
    //CustomMeta:     customMeta,
    //MimeType:       mieType,
    //ChunkSize:      chunkSize,
    //TryTimes:       tryTimes,    
    //Progresses:     progresses,
    //Notify:         notify,        
    //NotifyErr:      NotifyErr,
}

// ret       变量用于存取返回的信息，详情见 resumable.io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// r         为io.ReaderAt,用于读取数据
// fsize     数据总字节数
// extra     为上传文件的额外信息, 详情见 resumable.io.PutExtra
err = rio.Put(nil, ret, uptoken, key, r, fsize, extra)

if err != nil {
//上传产生错误
    log.Print("resumable.io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash)

参阅: resumable.io.Put, resumable.io.PutExtra, rs.PutPolicy

上传本地文件

var err error
var ret rio.PutRet
var extra = &rio.PutExtra {
    //CallbackParams: callbackParams,
    //Bucket:         bucket,
    //CustomMeta:     customMeta,
    //MimeType:       mieType,
    //ChunkSize:      chunkSize,
    //TryTimes:       tryTimes,    
    //Progresses:     progresses,
    //Notify:         notify,        
    //NotifyErr:      NotifyErr,
}

// ret       变量用于存取返回的信息，详情见 resumable.io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// localFile 为本地文件名
// extra     为上传文件的额外信息,可为空， 详情见 resumable.io.PutExtra
err = rio.PutFile(nil, ret, uptoken, key, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("resumable.io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash)

参阅: resumable.io.PutFile, resumable.io.PutExtra, rs.PutPolicy

相比普通上传，断点上续传代码没有变复杂。基本上就只是将 io.PutExtra 改为 resumable.io.PutExtra ， io.PutFile 改为 resumable.io.PutFile 。

但实际上 resumable.io.PutExtra 多了不少配置项，其中最重要的是两个回调函数： Notify 与 NotifyErr ，它们用来通知使用者有更多的数据被传输成功，或者有些数据传输失败。在 Notify 回调函数中，比较常见的做法是将传输的状态进行持久化，以便于在软件退出后下次再进来还可以继续进行断点续上传。但不传入 Notify 回调函数并不表示不能断点续上传，只要程序没有退出，上传失败自动进行续传和重试操作。

上传策略

上传凭证实际上是用 AccessKey/SecretKey 进行数字签名的上传策略(rs.PutPolicy)，它控制着整个上传流程的行为。让我们快速过一遍你都能够决策啥：

Expires 指定上传凭证有效期（默认1小时）。一个上传凭证可以被用于多次上传（只要它还没有过期）。
Scope 限定客户端的权限。如果 scope 是 bucket，则客户端只能新增文件到指定的 bucket，不能修改文件。如果 scope 为 bucket:key，则客户端可以修改指定的文件。
CallbackUrl 设定业务服务器的回调地址，这样业务服务器才能感知到上传行为的发生。可选。
AsyncOps 可指定上传完成后，需要自动执行哪些数据处理。这是因为有些数据处理操作（比如音视频转码）比较慢，如果不进行预转可能第一次访问的时候效果不理想，预转可以很大程度改善这一点。
ReturnBody 可调整返回给客户端的数据包（默认情况下七牛返回文件内容的 hash ，也就是下载该文件时的 etag ）。这只在没有 CallbackUrl 时有效。
Escape 为真（非0）时，表示客户端传入的 CallbackParams 中含有转义符。通过这个特性，可以很方便地把上传文件的某些元信息如 fsize （文件大小）、 ImageInfo.width/height （图片宽度/高度）、 exif （图片EXIF信息）等传给业务服务器。
DetectMime 为真（非0）时，表示服务端忽略客户端传入的 MimeType ，自己自行检测。

关于上传策略更完整的说明，请参考上传凭证。

下载文件

七牛云存储上的资源下载分为公有资源下载和私有资源下载。

私有（private）是 Bucket（空间）的一个属性，一个私有 Bucket 中的资源为私有资源，私有资源不可匿名下载。

新创建的空间（Bucket）缺省为私有，也可以将某个 Bucket 设为公有，公有 Bucket 中的资源为公有资源，公有资源可以匿名下载。

公有资源下载

如果在给bucket绑定了域名的话，可以通过以下地址访问：

[GET] http://<domain>/<key>

其中可以到七牛开发者平台绑定。步骤：首先选择需要绑定的空间，其次在空间设置标签下，点击域名绑定项，即可申请绑定自定义域名。域名可以使用自己的一级域名或是由七牛提供的二级域名(<bucket>.qiniudn.com)。 注意： 尖括号不是必需，代表替换项。

私有资源下载

如果某个 bucket 是私有的，那么这个 bucket 中的所有文件只能通过一个的临时有效的 downloadUrl 访问：

[GET] http://<domain>/<key>?token=<dnToken>

注意： 尖括号不是必需，代表替换项。
其中 dntoken 是由业务服务器签发的一个临时[下载凭证][downloadTokenHref]，deadline 是 dntoken 的有效期。dntoken不需要生成，GO-SDK 提供了生成完整 downloadUrl 的方法（包含了 dntoken），示例代码如下：

func downloadUrl(domain, key string) string {
    baseUrl := rs.MakeBaseUrl(domain, key)
    policy := rs.GetPolicy{}
    return  policy.MakeRequest(baseUrl, nil)
}

生成 downloadUrl 后，服务端下发 downloadUrl 给客户端。客户端收到 downloadUrl 后，和公有资源类似，直接用任意的 HTTP 客户端就可以下载该资源了。唯一需要注意的是，在 downloadUrl 失效却还没有完成下载时，需要重新向服务器申请授权。

无论公有资源还是私有资源，下载过程中客户端并不需要七牛 GO-SDK 参与其中。

参阅: rs.GetPolicy, rs.GetPolicy.MakeRequest, rs.MakeBaseUrl

HTTPS支持

几乎所有七牛云存储 API 都同时支持 HTTP 和 HTTPS，但 HTTPS 下载有些需要注意的点。如果你的资源希望支持 HTTPS 下载，有如下限制：

不能用 xxx.qiniudn.com 这样的二级域名，只能用 dn-xxx.qbox.me 域名。样例： https://dn-abc.qbox.me/1.txt
使用自定义域名是付费的。我们并不建议使用自定义域名，但如确有需要，请联系我们的销售人员。

断点续下载

无论是公有资源还是私有资源，获得的下载 url 支持标准的 HTTP 断点续传协议。考虑到多数语言都有相应的断点续下载支持的成熟方法，七牛 GO-SDK 并不提供断点续下载相关代码。

资源管理

资源管理包括对存储在七牛云存储上的文件进行查看、复制、移动和删除处理。
该节调用的函数第一个参数都为 logger ，用于记录log，如果无需求，可以设置为nil。具体接口可以查阅 github.com/qiniu/rpc

获取文件信息

函数 rs.Client.Stat 可获取文件信息。

var ret  rs.Entry
ret, err = rsCli.Stat(nil, bucket, key)
if err != nil {
//产生错误
    log.Println("rs.Stat failed:", err)
    return
}
//处理返回值
log.Println(ret)

若有错误发生，则返回的err包含错误信息。若没错误返回的 ret 变量包含文件信息。
ret 是为 rs.Entry 类型的结构体，其成员如下：

type Entry struct {
    Hash     string \`json:"hash"\`
    Fsize    int64  \`json:"fsize"\`
    PutTime  int64  \`json:"putTime"\`
    MimeType string \`json:"mimeType"\`
    Customer string \`json:"customer"\`
}

参阅: rs.Entry, rs.Client.Stat

删除文件

函数 rs.Client.Delete 可删除指定的文件。

err = rsCli.Delete(nil, bucket, key)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

若无错误发生则返回的err为nil，否则err包含错误信息。
参阅: rs.Client.Delete

复制文件

函数 rs.Client.Copy 可用来复制文件。

err = rsCli.Copy(nil, bucketSrc, keySrc, bucketDest, keyDest)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

参阅: rs.Client.Move rs.Client.Copy

移动文件

函数 rs.Client.Move 可用来移动文件。

err = rsCli.Move(nil, bucketSrc, keySrc, bucketDest, keyDest)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

参阅: rs.Client.Move

批量获取文件信息

函数 rs.Client.BatchStat 可批量获取文件信息。

entryPathes := []rs.EntryPath {
    rs.EntryPath {
        Bucket: bucket1,
        Key: key1,
    },
    rs.EntryPath {
        Bucket: bucket2,
        Key: key2,
    },
}
var batchStatRets []rs.BatchStatItemRet
batchStatRets, err = rsCli.BatchStat(nil, entryPathes) // []rs.BatchStatItemRet, error
if err != nil {
//产生错误
    log.Println("rs.BatchStat failed:", err)
    return
}
//处理返回值
for _, item := range batchStatRets {
    log.Println(item)
}

其中 entryPathes 为 rs.EntryPath 结构体的数组切片。结构体 rs.EntryPath 中填写每个文件对应的bucket和key：

type EntryPath struct {
    Bucket string
    Key string
}

rs.BatchStat 会将文件信息(及成功/失败信息)，返回给由结构体 rs.BatchStatItemRet 组成的数组切片 batchStatRets 变量中。

type BatchStatItemRet struct {
    Data  Entry       \`json:"data"\`
    Error string      \`json:"error"\`
    Code  int         \`json:"code"\`
}

参阅: rs.EntryPath, rs.BatchStatItemRet, rs.Client.BatchStat

批量删除文件

函数 rs.Client.BatchDelete 可进行批量删除文件。

entryPathes := []rs.EntryPath {
    rs.EntryPath {
        Bucket: bucket1,
        Key: key1,
    },
    rs.EntryPath {
        Bucket: bucket2,
        Key: key2,
    },
}
var batchDeleteRets []rs.BatchItemRet
batchDeleteRets, err = rsCli.BatchDelete(nil, entryPathes)
if err != nil {
//产生错误
    log.Println("rs.BatchMove failed:", err)
    return
}
for _, item := range batchDeleteRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

和批量查看一样， entryPathes 为 rs.EntryPath 结构体的数组切片。 rs.BatchDelete 会将删除操作的成功/失败信息返回给由结构体 rs.BatchItemRet 组成的数组切片 batchDeleteRets 变量中。其中 rs.BatchItemRet 结构体信息如下：

type BatchItemRet struct {
    Error string      \`json:"error"\`
    Code  int         \`json:"code"\`
}

参阅: rs.EntryPath, rs.Client.BatchDelete, rs.BatchItemRet

批量复制文件

函数 rs.Client.BatchCopy 可进行批量复制文件。

// 每个复制操作都含有源文件和目标文件
entryPairs := []rs.EntryPathPair {
    rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket1,
            Key: key1,
        },
        Dest: rs.EntryPath {
            Bucket: bucket2,
            Key: key2,
        },
    }, rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket3,
            Key: key3,
        },
        Dest: rs.EntryPath {
            Bucket: bucket4,
            Key: key4,
        },
    },
}
var batchCopyRets []rs.BatchItemRet
batchCopyRets, err = rsCli.BatchCopy(nil, entryPairs)
if err != nil {
//产生错误
    log.Println("rs.BatchCopy failed:", err)
    return
}
for _, item := range batchCopyRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

批量复制需要指明每个操作的源路径和目标路径， entryPairs 是一个 rs.EntryPathPair 结构体的数组切片。结构体 rs.EntryPathPair 结构如下：

type EntryPathPair struct {
    Src EntryPath
    Dest EntryPath
}

同样， rs.BatchCopy 会将复制操作的成功/失败信息返回给由结构体 rs.BatchItemRet 组成的数组切片 batchCopyRets 变量中

参阅: rs.BatchItemRet, rs.EntryPathPair, rs.Client.BatchCopy

批量移动文件

批量移动和批量很类似，唯一的区别就是调用 rs.Client.BatchMove

// 每个复制操作都含有源文件和目标文件
entryPairs := []rs.EntryPathPair {
    rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket1,
            Key: key1,
        },
        Dest: rs.EntryPath {
            Bucket: bucket2,
            Key: key2,
        },
    }, rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket3,
            Key: key3,
        },
        Dest: rs.EntryPath {
            Bucket: bucket4,
            Key: key4,
        },
    },
}
var batchMoveRets []rs.BatchItemRet
batchCopyRets, err = rsCli.BatchMove(nil, entryPairs)
if err != nil {
//产生错误
    log.Println("rs.BatchMove failed:", err)
    return
}
for _, item := range batchMoveRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

参阅: rs.EntryPathPair, rs.Client.BatchMove

高级批量操作

批量操作不仅仅支持同时进行多个相同类型的操作，同时也支持不同的操作。

ops := []string {
    rs.URIStat(bucket, key1),
    rs.URICopy(bucket, key1, bucket, key2), // 复制key1到key2
    rs.URIDelete(bucket, key1), // 删除key1
    rs.URIMove(bucket, key2, bucket, key1), //将key2移动到key1
}

rets := new([]rs.BatchItemRet)
err = rsCli.Batch(nil, rets, ops)
if err != nil {
//产生错误
    log.Println("rs.Batch failed:", err)
    return
}
for _, ret := range *rets {
    log.Println(ret.Code, ret.Error)
}

参阅: rs.URIStat, rs.URICopy, rs.URIMove, rs.URIDelete, rs.Client.Batch

数据处理

七牛支持在云端对图像，视频，音频等富媒体进行个性化处理。

查看图像属性

GO-SDK支持生成查看图片信息的URL，示意如下：

func makeImageInfoUrl(imageUrl string) string {
    ii := fop.ImageInfo{}
    return ii.MakeRequest(imageUrl)
}

还可以已另一种方式，在程序中处理返回的图片信息：

infoRet, err = ii.Call(nil, imageUrl)
if err != nil {
//产生错误
    log.Println("fop getImageInfo failed:", err)
    return
}
log.Println(infoRet.Height, infoRet.Width, infoRet.ColorModel,
    infoRet.Format)

参阅: fop.ImageInfoRet, fop.ImageInfo

查看图片EXIF信息

同样，本SDK也支持直接生成查看exif的URL：

func makeExifUrl(imageUrl string) string {
    e := fop.Exif{}
    return e.MakeRequest(imageUrl)
}

也可以在程序中处理exif的信息：

exifRet, err = ie.Call(nil, imageUrl)
if err != nil {
//产生错误
    log.Println("fop getExif failed:", err)
    return
}

//处理返回结果
for _, item := range exifRet {
    log.Println(item.Type, item.Val)
}

参阅: fop.Exif, fop.ExifRet, fop.ExifValType

生成图片预览

可以根据给定的文件URL和缩略图规格来生成缩略图的URL，代码：

func makeViewUrl(imageUrl string) string {
    var view = fop.ImageView {
        //Mode int      // 缩略模式
        //Width int     // Width = 0 表示不限定宽度
        //Height int    // Height = 0 表示不限定高度
        //Quality int   // 质量, 1-100
        //Format string // 输出格式，如jpg, gif, png, tif等等
    }
    return view.MakeRequest(imageUrl)
}

参阅: fop.ImageView

高级资源管理(rsf)

批量获取文件列表

根据指定的前缀，获取对应前缀的文件列表，正常使用情景如下：

func listAll(l rpc.Logger, rs *rsf.Client, bucketName string, prefix string) {

    var entries []rsf.ListItem
    var marker = ""
    var err error
    var limit = 1000

    for err == nil {
        entries, marker, err = rs.ListPrefix(l, bucketName,
            prefix, marker, limit)
        for _, item := range entries {
            //处理 item
            log.Print("item:", item)
        }
    }
    if err != io.EOF {
        //非预期的错误
        log.Print("listAll failed:", err)
    }
}

参阅: rsf.ListPreFix

API参考手册

贡献代码

Fork
创建您的特性分支 git checkout -b my-new-feature
提交您的改动 git commit -am 'Added some feature'
将您的修改记录提交到远程 git 仓库 git push origin my-new-feature
然后到 github 网站的该 git 远程仓库的 my-new-feature 分支下发起 Pull Request

许可证

基于 MIT 协议发布:

www.opensource.org/licenses/MIT

最近更新时间: 2019-12-16 17:22:39

GO-SDK 以开源方式提供。开发者可以随时从本文档提供的下载地址查看和下载 SDK 的源代码。

从内容上来说，GO-SDK 主要包含如下几方面的内容：

公共库: api/conf
客户端上传文件：api/io
客户端断点续上传：api/resumable/io
数据处理：api/fop
服务端操作：api/auth/digest (授权)，api/rs(资源管理，uptoken/dntoken颁发)，api/rsf(批量获取文件列表)

安装

在命令行下执行

go get -u github.com/qiniu/api.v7

初始化

要接入七牛云存储，您需要拥有一对有效的 Access Key 和 Secret Key 用来进行签名认证。可以通过如下步骤获得：

开通七牛开发者帐号
登录七牛开发者自助平台，查看 Access Key 和 Secret Key 。

import ."github.com/qiniu/api.v6/conf"

ACCESS_KEY = "<YOUR_APP_ACCESS_KEY>"
SECRET_KEY = "<YOUR_APP_SECRET_KEY>"

上传文件

为了尽可能地改善终端用户的上传体验，七牛云存储首创了客户端直传功能。一般云存储的上传流程是：

客户端（终端用户） => 业务服务器 => 云存储服务

这样多了一次上传的流程，和本地存储相比，会相对慢一些。但七牛引入了客户端直传，将整个上传过程调整为：

客户端（终端用户） => 七牛 => 业务服务器

上传流程

在七牛云存储中，整个上传流程大体分为这样几步：

业务服务器颁发上传凭证给客户端（终端用户）
客户端凭借上传凭证上传文件到七牛
在七牛获得完整数据后，发起一个 HTTP 请求回调到业务服务器
业务服务器保存相关信息，并返回一些信息给七牛
七牛原封不动地将这些信息转发给客户端（终端用户）

业务服务器生成 uptoken（不设置回调，自己回调到自己这里没有意义）
凭借上传凭证上传文件到七牛
善后工作，比如保存相关的一些信息

生成上传授权uptoken

func uptoken(bucketName string) string {
    putPolicy := rs.PutPolicy {
        Scope:         bucketName,
        //CallbackUrl: callbackUrl,   
        //CallbackBody:callbackBody,    
        //ReturnUrl:   returnUrl,  
        //ReturnBody:  returnBody,    
        //AsyncOps:    asyncOps,    
        //EndUser:     endUser,    
        //Expires:     expires,   
    }
    return  putPolicy.Token(nil)
}

参阅 rs.PutPolicy

上传代码

type PutExtra struct {
    Params   map[string]string    //可选，用户自定义参数，必须以 "x:" 开头
                                  //若不以x:开头，则忽略
    MimeType string               //可选，当为 "" 时候，服务端自动判断 
    Crc32    uint32
    CheckCrc uint32
            // CheckCrc == 0: 表示不进行 crc32 校验
            // CheckCrc == 1: 对于 Put 等同于 CheckCrc = 2；对于 PutFile 会自动计算 crc32 值
            // CheckCrc == 2: 表示进行 crc32 校验，且 crc32 值就是上面的 Crc32 变量
}

直接上传内存中的数据，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器端生成的上传口令
// key       为文件存储的标识
// r         为io.Reader类型，用于从其读取数据
// extra     为上传文件的额外信息,可为空， 详情见 io.PutExtra, 可选
err = io.Put(nil, &ret, uptoken, key, r, extra)

if err != nil {
//上传产生错误
    log.Print("io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.Put, io.PutExtra

直接上传内存中的数据，且不提供key参数，此时key由七牛服务器自动生成，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器端生成的上传口令
// r         为io.Reader类型，用于从其读取数据
// extra     为上传文件的额外信息,可为空， 详情见 io.PutExtra, 可选
err = io.PutWithoutKey(nil, &ret, uptoken, r, extra)

if err != nil {
//上传产生错误
    log.Print("io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.Put, io.PutExtra

上传本地文件，代码如下:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// localFile 为本地文件名
// extra     为上传文件的额外信息，详情见 io.PutExtra，可选
err = io.PutFile(nil, &ret, uptoken, key, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("io.PutFile failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.PutFile, io.PutExtra, io.PutRet

上传本地文件，且不提供 key 参数，此时 key 由七牛服务器自动生成代码:

var err error
var ret io.PutRet
var extra = &io.PutExtra {
    //Params:    params,
    //MimeType:  mieType,
    //Crc32:     crc32,
    //CheckCrc:  CheckCrc,
}

// ret       变量用于存取返回的信息，详情见 io.PutRet
// uptoken   为业务服务器生成的上传口令
// localFile 为本地文件名
// extra     为上传文件的额外信息，详情见 io.PutExtra，可选
err = io.PutFileWithoutKey(nil, &ret, uptoken, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("io.PutFile failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash, ret.Key)

参阅: io.PutFile, io.PutExtra, io.PutRet

断点续上传、分块并行上传

断点续上传函数，最后一个选项是 resumable.io.PutExtra结构体，来细化上传用的，其成员及其含义如下：

type PutExtra struct {
    CallbackParams  string  // 当 uptoken 指定了 CallbackUrl，则 CallbackParams 必须非空
    Bucket          string
    CustomMeta      string  // 可选。用户自定义 Meta，不能超过 256 字节
    MimeType        string  // 可选。在 uptoken 没有指定 DetectMime 时，用户客户端可自己指定 MimeType
    ChunkSize    int    // 可选。每次上传的Chunk大小
    TryTimes    int    // 可选。尝试次数
    Progresses    []BlkputRet // 可选。上传进度
    Notify        func(blkIdx int, blkSize int, ret *BlkputRet) // 可选。进度提示（注意多个block是并行传输的）
    NotifyErr    func(blkIdx int, blkSize int, err error)
}

我们先看支持的断点续上传、分块并行上传的基本样例：

上传二进制流

var err error
var ret io.PutRet
var extra = &rio.PutExtra {
    //CallbackParams: callbackParams,
    //Bucket:         bucket,
    //CustomMeta:     customMeta,
    //MimeType:       mieType,
    //ChunkSize:      chunkSize,
    //TryTimes:       tryTimes,    
    //Progresses:     progresses,
    //Notify:         notify,        
    //NotifyErr:      NotifyErr,
}

// ret       变量用于存取返回的信息，详情见 resumable.io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// r         为io.ReaderAt,用于读取数据
// fsize     数据总字节数
// extra     为上传文件的额外信息, 详情见 resumable.io.PutExtra
err = rio.Put(nil, ret, uptoken, key, r, fsize, extra)

if err != nil {
//上传产生错误
    log.Print("resumable.io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash)

参阅: resumable.io.Put, resumable.io.PutExtra, rs.PutPolicy

上传本地文件

var err error
var ret rio.PutRet
var extra = &rio.PutExtra {
    //CallbackParams: callbackParams,
    //Bucket:         bucket,
    //CustomMeta:     customMeta,
    //MimeType:       mieType,
    //ChunkSize:      chunkSize,
    //TryTimes:       tryTimes,    
    //Progresses:     progresses,
    //Notify:         notify,        
    //NotifyErr:      NotifyErr,
}

// ret       变量用于存取返回的信息，详情见 resumable.io.PutRet
// uptoken   为业务服务器生成的上传口令
// key       为文件存储的标识
// localFile 为本地文件名
// extra     为上传文件的额外信息,可为空， 详情见 resumable.io.PutExtra
err = rio.PutFile(nil, ret, uptoken, key, localFile, extra)

if err != nil {
//上传产生错误
    log.Print("resumable.io.Put failed:", err)
    return
}

//上传成功，处理返回值
log.Print(ret.Hash)

参阅: resumable.io.PutFile, resumable.io.PutExtra, rs.PutPolicy

相比普通上传，断点上续传代码没有变复杂。基本上就只是将 io.PutExtra 改为 resumable.io.PutExtra ， io.PutFile 改为 resumable.io.PutFile 。

上传策略

上传凭证实际上是用 AccessKey/SecretKey 进行数字签名的上传策略(rs.PutPolicy)，它控制着整个上传流程的行为。让我们快速过一遍你都能够决策啥：

Expires 指定上传凭证有效期（默认1小时）。一个上传凭证可以被用于多次上传（只要它还没有过期）。
Scope 限定客户端的权限。如果 scope 是 bucket，则客户端只能新增文件到指定的 bucket，不能修改文件。如果 scope 为 bucket:key，则客户端可以修改指定的文件。
CallbackUrl 设定业务服务器的回调地址，这样业务服务器才能感知到上传行为的发生。可选。
AsyncOps 可指定上传完成后，需要自动执行哪些数据处理。这是因为有些数据处理操作（比如音视频转码）比较慢，如果不进行预转可能第一次访问的时候效果不理想，预转可以很大程度改善这一点。
ReturnBody 可调整返回给客户端的数据包（默认情况下七牛返回文件内容的 hash ，也就是下载该文件时的 etag ）。这只在没有 CallbackUrl 时有效。
Escape 为真（非0）时，表示客户端传入的 CallbackParams 中含有转义符。通过这个特性，可以很方便地把上传文件的某些元信息如 fsize （文件大小）、 ImageInfo.width/height （图片宽度/高度）、 exif （图片EXIF信息）等传给业务服务器。
DetectMime 为真（非0）时，表示服务端忽略客户端传入的 MimeType ，自己自行检测。

关于上传策略更完整的说明，请参考上传凭证。

下载文件

七牛云存储上的资源下载分为公有资源下载和私有资源下载。

私有（private）是 Bucket（空间）的一个属性，一个私有 Bucket 中的资源为私有资源，私有资源不可匿名下载。

新创建的空间（Bucket）缺省为私有，也可以将某个 Bucket 设为公有，公有 Bucket 中的资源为公有资源，公有资源可以匿名下载。

公有资源下载

如果在给bucket绑定了域名的话，可以通过以下地址访问：

[GET] http://<domain>/<key>

私有资源下载

如果某个 bucket 是私有的，那么这个 bucket 中的所有文件只能通过一个的临时有效的 downloadUrl 访问：

[GET] http://<domain>/<key>?token=<dnToken>

func downloadUrl(domain, key string) string {
    baseUrl := rs.MakeBaseUrl(domain, key)
    policy := rs.GetPolicy{}
    return  policy.MakeRequest(baseUrl, nil)
}

无论公有资源还是私有资源，下载过程中客户端并不需要七牛 GO-SDK 参与其中。

参阅: rs.GetPolicy, rs.GetPolicy.MakeRequest, rs.MakeBaseUrl

HTTPS支持

几乎所有七牛云存储 API 都同时支持 HTTP 和 HTTPS，但 HTTPS 下载有些需要注意的点。如果你的资源希望支持 HTTPS 下载，有如下限制：

不能用 xxx.qiniudn.com 这样的二级域名，只能用 dn-xxx.qbox.me 域名。样例： https://dn-abc.qbox.me/1.txt
使用自定义域名是付费的。我们并不建议使用自定义域名，但如确有需要，请联系我们的销售人员。

var ret  rs.Entry
ret, err = rsCli.Stat(nil, bucket, key)
if err != nil {
//产生错误
    log.Println("rs.Stat failed:", err)
    return
}
//处理返回值
log.Println(ret)

若有错误发生，则返回的err包含错误信息。若没错误返回的 ret 变量包含文件信息。
ret 是为 rs.Entry 类型的结构体，其成员如下：

type Entry struct {
    Hash     string \`json:"hash"\`
    Fsize    int64  \`json:"fsize"\`
    PutTime  int64  \`json:"putTime"\`
    MimeType string \`json:"mimeType"\`
    Customer string \`json:"customer"\`
}

参阅: rs.Entry, rs.Client.Stat

删除文件

函数 rs.Client.Delete 可删除指定的文件。

err = rsCli.Delete(nil, bucket, key)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

若无错误发生则返回的err为nil，否则err包含错误信息。
参阅: rs.Client.Delete

复制文件

函数 rs.Client.Copy 可用来复制文件。

err = rsCli.Copy(nil, bucketSrc, keySrc, bucketDest, keyDest)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

参阅: rs.Client.Move rs.Client.Copy

移动文件

函数 rs.Client.Move 可用来移动文件。

err = rsCli.Move(nil, bucketSrc, keySrc, bucketDest, keyDest)
if err != nil {
//产生错误
    log.Println("rs.Copy failed:", err)
    return
}

参阅: rs.Client.Move

批量获取文件信息

函数 rs.Client.BatchStat 可批量获取文件信息。

entryPathes := []rs.EntryPath {
    rs.EntryPath {
        Bucket: bucket1,
        Key: key1,
    },
    rs.EntryPath {
        Bucket: bucket2,
        Key: key2,
    },
}
var batchStatRets []rs.BatchStatItemRet
batchStatRets, err = rsCli.BatchStat(nil, entryPathes) // []rs.BatchStatItemRet, error
if err != nil {
//产生错误
    log.Println("rs.BatchStat failed:", err)
    return
}
//处理返回值
for _, item := range batchStatRets {
    log.Println(item)
}

其中 entryPathes 为 rs.EntryPath 结构体的数组切片。结构体 rs.EntryPath 中填写每个文件对应的bucket和key：

type EntryPath struct {
    Bucket string
    Key string
}

rs.BatchStat 会将文件信息(及成功/失败信息)，返回给由结构体 rs.BatchStatItemRet 组成的数组切片 batchStatRets 变量中。

type BatchStatItemRet struct {
    Data  Entry       \`json:"data"\`
    Error string      \`json:"error"\`
    Code  int         \`json:"code"\`
}

参阅: rs.EntryPath, rs.BatchStatItemRet, rs.Client.BatchStat

批量删除文件

函数 rs.Client.BatchDelete 可进行批量删除文件。

entryPathes := []rs.EntryPath {
    rs.EntryPath {
        Bucket: bucket1,
        Key: key1,
    },
    rs.EntryPath {
        Bucket: bucket2,
        Key: key2,
    },
}
var batchDeleteRets []rs.BatchItemRet
batchDeleteRets, err = rsCli.BatchDelete(nil, entryPathes)
if err != nil {
//产生错误
    log.Println("rs.BatchMove failed:", err)
    return
}
for _, item := range batchDeleteRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

type BatchItemRet struct {
    Error string      \`json:"error"\`
    Code  int         \`json:"code"\`
}

参阅: rs.EntryPath, rs.Client.BatchDelete, rs.BatchItemRet

批量复制文件

函数 rs.Client.BatchCopy 可进行批量复制文件。

// 每个复制操作都含有源文件和目标文件
entryPairs := []rs.EntryPathPair {
    rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket1,
            Key: key1,
        },
        Dest: rs.EntryPath {
            Bucket: bucket2,
            Key: key2,
        },
    }, rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket3,
            Key: key3,
        },
        Dest: rs.EntryPath {
            Bucket: bucket4,
            Key: key4,
        },
    },
}
var batchCopyRets []rs.BatchItemRet
batchCopyRets, err = rsCli.BatchCopy(nil, entryPairs)
if err != nil {
//产生错误
    log.Println("rs.BatchCopy failed:", err)
    return
}
for _, item := range batchCopyRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

批量复制需要指明每个操作的源路径和目标路径， entryPairs 是一个 rs.EntryPathPair 结构体的数组切片。结构体 rs.EntryPathPair 结构如下：

type EntryPathPair struct {
    Src EntryPath
    Dest EntryPath
}

同样， rs.BatchCopy 会将复制操作的成功/失败信息返回给由结构体 rs.BatchItemRet 组成的数组切片 batchCopyRets 变量中

参阅: rs.BatchItemRet, rs.EntryPathPair, rs.Client.BatchCopy

批量移动文件

批量移动和批量很类似，唯一的区别就是调用 rs.Client.BatchMove

// 每个复制操作都含有源文件和目标文件
entryPairs := []rs.EntryPathPair {
    rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket1,
            Key: key1,
        },
        Dest: rs.EntryPath {
            Bucket: bucket2,
            Key: key2,
        },
    }, rs.EntryPathPair {
        Src: rs.EntryPath {
            Bucket: bucket3,
            Key: key3,
        },
        Dest: rs.EntryPath {
            Bucket: bucket4,
            Key: key4,
        },
    },
}
var batchMoveRets []rs.BatchItemRet
batchCopyRets, err = rsCli.BatchMove(nil, entryPairs)
if err != nil {
//产生错误
    log.Println("rs.BatchMove failed:", err)
    return
}
for _, item := range batchMoveRets {
//遍历每个操作的返回结果
    log.Println(item.Code, item.Error)
}

参阅: rs.EntryPathPair, rs.Client.BatchMove

高级批量操作

批量操作不仅仅支持同时进行多个相同类型的操作，同时也支持不同的操作。

ops := []string {
    rs.URIStat(bucket, key1),
    rs.URICopy(bucket, key1, bucket, key2), // 复制key1到key2
    rs.URIDelete(bucket, key1), // 删除key1
    rs.URIMove(bucket, key2, bucket, key1), //将key2移动到key1
}

rets := new([]rs.BatchItemRet)
err = rsCli.Batch(nil, rets, ops)
if err != nil {
//产生错误
    log.Println("rs.Batch failed:", err)
    return
}
for _, ret := range *rets {
    log.Println(ret.Code, ret.Error)
}

参阅: rs.URIStat, rs.URICopy, rs.URIMove, rs.URIDelete, rs.Client.Batch

数据处理

七牛支持在云端对图像，视频，音频等富媒体进行个性化处理。

查看图像属性

GO-SDK支持生成查看图片信息的URL，示意如下：

func makeImageInfoUrl(imageUrl string) string {
    ii := fop.ImageInfo{}
    return ii.MakeRequest(imageUrl)
}

还可以已另一种方式，在程序中处理返回的图片信息：

infoRet, err = ii.Call(nil, imageUrl)
if err != nil {
//产生错误
    log.Println("fop getImageInfo failed:", err)
    return
}
log.Println(infoRet.Height, infoRet.Width, infoRet.ColorModel,
    infoRet.Format)

参阅: fop.ImageInfoRet, fop.ImageInfo

查看图片EXIF信息

同样，本SDK也支持直接生成查看exif的URL：

func makeExifUrl(imageUrl string) string {
    e := fop.Exif{}
    return e.MakeRequest(imageUrl)
}

也可以在程序中处理exif的信息：

exifRet, err = ie.Call(nil, imageUrl)
if err != nil {
//产生错误
    log.Println("fop getExif failed:", err)
    return
}

//处理返回结果
for _, item := range exifRet {
    log.Println(item.Type, item.Val)
}

参阅: fop.Exif, fop.ExifRet, fop.ExifValType

生成图片预览

可以根据给定的文件URL和缩略图规格来生成缩略图的URL，代码：

func makeViewUrl(imageUrl string) string {
    var view = fop.ImageView {
        //Mode int      // 缩略模式
        //Width int     // Width = 0 表示不限定宽度
        //Height int    // Height = 0 表示不限定高度
        //Quality int   // 质量, 1-100
        //Format string // 输出格式，如jpg, gif, png, tif等等
    }
    return view.MakeRequest(imageUrl)
}

参阅: fop.ImageView

高级资源管理(rsf)

批量获取文件列表

根据指定的前缀，获取对应前缀的文件列表，正常使用情景如下：

func listAll(l rpc.Logger, rs *rsf.Client, bucketName string, prefix string) {

    var entries []rsf.ListItem
    var marker = ""
    var err error
    var limit = 1000

    for err == nil {
        entries, marker, err = rs.ListPrefix(l, bucketName,
            prefix, marker, limit)
        for _, item := range entries {
            //处理 item
            log.Print("item:", item)
        }
    }
    if err != io.EOF {
        //非预期的错误
        log.Print("listAll failed:", err)
    }
}

参阅: rsf.ListPreFix

API参考手册

贡献代码

Fork
创建您的特性分支 git checkout -b my-new-feature
提交您的改动 git commit -am 'Added some feature'
将您的修改记录提交到远程 git 仓库 git push origin my-new-feature
然后到 github 网站的该 git 远程仓库的 my-new-feature 分支下发起 Pull Request

许可证

基于 MIT 协议发布:

www.opensource.org/licenses/MIT

Go SDK历史版本

本页内容

Go SDK历史版本

本页内容