Merge pull request #19 from aliyun/crc-md5

CRC

oss/bucket.go

@@ -5,11 +5,11 @@ import (
 	"crypto/md5"
 	"encoding/base64"
 	"encoding/xml"
-	"hash"
 	"hash/crc64"
 	"io"
 	"io/ioutil"
 	"net/http"
+	"net/url"
 	"os"
 	"strconv"
 )
@@ -33,20 +33,18 @@ type Bucket struct {
 //
 func (bucket Bucket) PutObject(objectKey string, reader io.Reader, options ...Option) error {
 	opts := addContentType(options, objectKey)
-	resp, err := bucket.do("PUT", objectKey, "", "", opts, reader)
+
+	request := &PutObjectRequest{
+		ObjectKey: objectKey,
+		Reader:    reader,
+	}
+	resp, err := bucket.DoPutObject(request, opts)
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-
-	if bucket.getConfig().IsEnableCRC {
-		err = checkCRC(resp, "PutObject")
-		if err != nil {
-			return err
-		}
-	}
+	defer resp.Body.Close()
 
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	return err
 }
 
 //
@@ -67,68 +65,68 @@ func (bucket Bucket) PutObjectFromFile(objectKey, filePath string, options ...Op
 
 	opts := addContentType(options, filePath, objectKey)
 
-	resp, err := bucket.do("PUT", objectKey, "", "", opts, fd)
+	request := &PutObjectRequest{
+		ObjectKey: objectKey,
+		Reader:    fd,
+	}
+	resp, err := bucket.DoPutObject(request, opts)
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	if bucket.getConfig().IsEnableCRC {
-		err = checkCRC(resp, "PutObjectFromFile")
-		if err != nil {
-			return err
-		}
-	}
-
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	return err
 }
 
 //
-// GetObject 下载文件。
+// DoPutObject 上传文件。
 //
-// objectKey 下载的文件名称。
-// options   对象的属性限制项，可选值有Range、IfModifiedSince、IfUnmodifiedSince、IfMatch、
-// IfNoneMatch、AcceptEncoding，详细请参考
-// https://help.aliyun.com/document_detail/oss/api-reference/object/GetObject.html
+// request  上传请求。
+// options  上传选项。
 //
-// io.ReadCloser  reader，读取数据后需要close。error为nil时有效。
+// Response 上传请求返回值。
 // error  操作无错误为nil，非nil为错误信息。
 //
-func (bucket Bucket) GetObject(objectKey string, options ...Option) (io.ReadCloser, error) {
-	resp, err := bucket.do("GET", objectKey, "", "", options, nil)
+func (bucket Bucket) DoPutObject(request *PutObjectRequest, options []Option) (*Response, error) {
+	isOptSet, _, _ := isOptionSet(options, HTTPHeaderContentType)
+	if !isOptSet {
+		options = addContentType(options, request.ObjectKey)
+	}
+
+	resp, err := bucket.do("PUT", request.ObjectKey, "", "", options, request.Reader)
 	if err != nil {
 		return nil, err
 	}
-	return resp.body, nil
+
+	if bucket.getConfig().IsEnableCRC {
+		err = checkCRC(resp, "DoPutObject")
+		if err != nil {
+			return resp, err
+		}
+	}
+
+	err = checkRespCode(resp.StatusCode, []int{http.StatusOK})
+
+	return resp, err
 }
 
 //
-// GetObjectWithCRC 下载文件同时计算CRC。
+// GetObject 下载文件。
 //
 // objectKey 下载的文件名称。
 // options   对象的属性限制项，可选值有Range、IfModifiedSince、IfUnmodifiedSince、IfMatch、
 // IfNoneMatch、AcceptEncoding，详细请参考
 // https://help.aliyun.com/document_detail/oss/api-reference/object/GetObject.html
 //
-// io.ReadCloser  body，文件内容，读取数据后需要close。error为nil时有效。
-// hash.Hash64 clientCRCCalculator，读取数据的CRC计算器。数据读取介绍通过clientCRCCalculator.Sum64()获取。
-// int64 serverCRC 服务器端存储数据的CRC值。
+// io.ReadCloser  reader，读取数据后需要close。error为nil时有效。
 // error  操作无错误为nil，非nil为错误信息。
 //
-func (bucket Bucket) GetObjectWithCRC(objectKey string, options ...Option) (body io.ReadCloser, clientCRCCalculator hash.Hash64, serverCRC uint64, err error) {
-	resp, err := bucket.do("GET", objectKey, "", "", options, nil)
+func (bucket Bucket) GetObject(objectKey string, options ...Option) (io.ReadCloser, error) {
+	result, err := bucket.DoGetObject(&GetObjectRequest{objectKey}, options)
 	if err != nil {
-		return
-	}
-
-	body = resp.body
-	hasRange, _, _ := isOptionSet(options, HTTPHeaderRange)
-	if bucket.getConfig().IsEnableCRC && !hasRange {
-		serverCRC = resp.serverCRC
-		clientCRCCalculator = crc64.New(crcTable())
-		body = ioutil.NopCloser(io.TeeReader(body, clientCRCCalculator))
+		return nil, err
 	}
-	return
+	return result.Response.Body, nil
 }
 
 //
@@ -141,11 +139,12 @@ func (bucket Bucket) GetObjectWithCRC(objectKey string, options ...Option) (body
 // error  操作无错误时返回error为nil，非nil为错误说明。
 //
 func (bucket Bucket) GetObjectToFile(objectKey, filePath string, options ...Option) error {
-	resp, err := bucket.do("GET", objectKey, "", "", options, nil)
+	// 读取Object内容
+	result, err := bucket.DoGetObject(&GetObjectRequest{objectKey}, options)
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
+	defer result.Response.Body.Close()
 
 	// 如果文件不存在则创建，存在则清空
 	fd, err := os.OpenFile(filePath, os.O_CREATE|os.O_TRUNC|os.O_WRONLY, 0660)
@@ -154,24 +153,17 @@ func (bucket Bucket) GetObjectToFile(objectKey, filePath string, options ...Opti
 	}
 	defer fd.Close()
 
-	// 读取数据同时计算CRC
-	body := resp.body
-	var crc hash.Hash64
-	hasRange, _, _ := isOptionSet(options, HTTPHeaderRange)
-	if bucket.getConfig().IsEnableCRC && !hasRange {
-		crc = crc64.New(crcTable())
-		body = ioutil.NopCloser(io.TeeReader(body, crc))
-	}
-
-	_, err = io.Copy(fd, body)
+	// 存储数据到文件
+	_, err = io.Copy(fd, result.Response.Body)
 	if err != nil {
 		return err
 	}
 
 	// 比较CRC值
+	hasRange, _, _ := isOptionSet(options, HTTPHeaderRange)
 	if bucket.getConfig().IsEnableCRC && !hasRange {
-		resp.clientCRC = crc.Sum64()
-		err = checkCRC(resp, "GetObjectToFile")
+		result.Response.ClientCRC = result.ClientCRC.Sum64()
+		err = checkCRC(result.Response, "GetObjectToFile")
 		if err != nil {
 			return err
 		}
@@ -180,6 +172,36 @@ func (bucket Bucket) GetObjectToFile(objectKey, filePath string, options ...Opti
 	return nil
 }
 
+//
+// DoGetObject 下载文件
+//
+// request 下载请求
+// options    对象的属性限制项。详见GetObject的options。
+//
+// GetObjectResult 下载请求返回值。
+// error  操作无错误为nil，非nil为错误信息。
+//
+func (bucket Bucket) DoGetObject(request *GetObjectRequest, options []Option) (*GetObjectResult, error) {
+	resp, err := bucket.do("GET", request.ObjectKey, "", "", options, nil)
+	if err != nil {
+		return nil, err
+	}
+
+	result := &GetObjectResult{
+		Response: resp,
+	}
+
+	hasRange, _, _ := isOptionSet(options, HTTPHeaderRange)
+	if bucket.getConfig().IsEnableCRC && !hasRange {
+		crcCalc := crc64.New(crcTable())
+		resp.Body = ioutil.NopCloser(io.TeeReader(resp.Body, crcCalc))
+		result.ServerCRC = resp.ServerCRC
+		result.ClientCRC = crcCalc
+	}
+
+	return result, nil
+}
+
 //
 // CopyObject 同一个bucket内拷贝Object。
 //
@@ -195,14 +217,14 @@ func (bucket Bucket) GetObjectToFile(objectKey, filePath string, options ...Opti
 //
 func (bucket Bucket) CopyObject(srcObjectKey, destObjectKey string, options ...Option) (CopyObjectResult, error) {
 	var out CopyObjectResult
-	options = append(options, CopySource(bucket.BucketName, srcObjectKey))
+	options = append(options, CopySource(bucket.BucketName, url.QueryEscape(srcObjectKey)))
 	resp, err := bucket.do("PUT", destObjectKey, "", "", options, nil)
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -243,19 +265,19 @@ func (bucket Bucket) CopyObjectFrom(srcBucketName, srcObjectKey, destObjectKey s
 
 func (bucket Bucket) copy(srcObjectKey, destBucketName, destObjectKey string, options ...Option) (CopyObjectResult, error) {
 	var out CopyObjectResult
-	options = append(options, CopySource(bucket.BucketName, srcObjectKey))
+	options = append(options, CopySource(bucket.BucketName, url.QueryEscape(srcObjectKey)))
 	headers := make(map[string]string)
 	err := handleOptions(headers, options)
 	if err != nil {
 		return out, err
 	}
-	resp, err := bucket.Client.Conn.Do("PUT", destBucketName, destObjectKey, "", "", headers, nil)
+	resp, err := bucket.Client.Conn.Do("PUT", destBucketName, destObjectKey, "", "", headers, nil, 0)
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -272,26 +294,65 @@ func (bucket Bucket) copy(srcObjectKey, destBucketName, destObjectKey string, op
 // appendPosition  object追加的起始位置。
 // destObjectProperties  第一次追加时指定新对象的属性，如CacheControl、ContentDisposition、ContentEncoding、
 // Expires、ServerSideEncryption、ObjectACL。
-// int64 下次追加的开始位置，error为nil空时有效。
 //
+// int64 下次追加的开始位置，error为nil空时有效。
 // error 操作无错误为nil，非nil为错误信息。
 //
 func (bucket Bucket) AppendObject(objectKey string, reader io.Reader, appendPosition int64, options ...Option) (int64, error) {
-	var nextAppendPosition int64
-	params := "append&position=" + strconv.Itoa(int(appendPosition))
-	opts := addContentType(options, objectKey)
-	resp, err := bucket.do("POST", objectKey, params, params, opts, reader)
-	if err != nil {
-		return nextAppendPosition, err
+	request := &AppendObjectRequest{
+		ObjectKey: objectKey,
+		Reader:    reader,
+		Position:  appendPosition,
 	}
-	defer resp.body.Close()
 
-	napint, err := strconv.Atoi(resp.headers.Get(HTTPHeaderOssNextAppendPosition))
+	result, err := bucket.DoAppendObject(request, options)
+
+	return result.NextPosition, err
+}
+
+//
+// DoAppendObject 追加上传。
+//
+// request 追加上传请求。
+// options 追加上传选项。
+//
+// AppendObjectResult 追加上传请求返回值。
+// error  操作无错误为nil，非nil为错误信息。
+//
+func (bucket Bucket) DoAppendObject(request *AppendObjectRequest, options []Option) (*AppendObjectResult, error) {
+	params := "append&position=" + strconv.FormatInt(request.Position, 10)
+	headers := make(map[string]string)
+
+	opts := addContentType(options, request.ObjectKey)
+	handleOptions(headers, opts)
+
+	var initCRC uint64
+	isCRCSet, initCRCStr, _ := isOptionSet(options, initCRC64)
+	if isCRCSet {
+		initCRC, _ = strconv.ParseUint(initCRCStr, 10, 64)
+	}
+
+	handleOptions(headers, opts)
+	resp, err := bucket.Client.Conn.Do("POST", bucket.BucketName, request.ObjectKey, params, params, headers, request.Reader, initCRC)
 	if err != nil {
-		return nextAppendPosition, err
+		return nil, err
 	}
-	nextAppendPosition = int64(napint)
-	return nextAppendPosition, nil
+	defer resp.Body.Close()
+
+	nextPosition, _ := strconv.ParseInt(resp.Headers.Get(HTTPHeaderOssNextAppendPosition), 10, 64)
+	result := &AppendObjectResult{
+		NextPosition: nextPosition,
+		CRC:          resp.ServerCRC,
+	}
+
+	if bucket.getConfig().IsEnableCRC && isCRCSet {
+		err = checkCRC(resp, "AppendObject")
+		if err != nil {
+			return result, err
+		}
+	}
+
+	return result, nil
 }
 
 //
@@ -306,8 +367,8 @@ func (bucket Bucket) DeleteObject(objectKey string) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -346,10 +407,10 @@ func (bucket Bucket) DeleteObjects(objectKeys []string, options ...Option) (Dele
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
 	if !dxml.Quiet {
-		if err = xmlUnmarshal(resp.body, &out); err == nil {
+		if err = xmlUnmarshal(resp.Body, &out); err == nil {
 			err = decodeDeleteObjectsResult(&out)
 		}
 	}
@@ -407,9 +468,9 @@ func (bucket Bucket) ListObjects(options ...Option) (ListObjectsResult, error) {
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	if err != nil {
 		return out, err
 	}
@@ -448,9 +509,9 @@ func (bucket Bucket) GetObjectDetailedMeta(objectKey string, options ...Option)
 	if err != nil {
 		return nil, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	return resp.headers, nil
+	return resp.Headers, nil
 }
 
 //
@@ -469,9 +530,9 @@ func (bucket Bucket) GetObjectMeta(objectKey string) (http.Header, error) {
 	if err != nil {
 		return nil, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	return resp.headers, nil
+	return resp.Headers, nil
 }
 
 //
@@ -497,8 +558,8 @@ func (bucket Bucket) SetObjectACL(objectKey string, objectACL ACLType) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -515,9 +576,9 @@ func (bucket Bucket) GetObjectACL(objectKey string) (GetObjectACLResult, error)
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -530,14 +591,13 @@ func (bucket Bucket) do(method, objectName, urlParams, subResource string,
 		return nil, err
 	}
 	return bucket.Client.Conn.Do(method, bucket.BucketName, objectName,
-		urlParams, subResource, headers, data)
+		urlParams, subResource, headers, data, 0)
 }
 
 func (bucket Bucket) getConfig() *Config {
 	return bucket.Client.Config
 }
 
-// Private
 func addContentType(options []Option, keys ...string) []Option {
 	typ := TypeByExtension("")
 	for _, key := range keys {

oss/client.go

@@ -93,8 +93,8 @@ func (client Client) CreateBucket(bucketName string, options ...Option) error {
 		return err
 	}
 
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -119,9 +119,9 @@ func (client Client) ListBuckets(options ...Option) (ListBucketsResult, error) {
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -158,8 +158,8 @@ func (client Client) DeleteBucket(bucketName string) error {
 		return err
 	}
 
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -178,10 +178,10 @@ func (client Client) GetBucketLocation(bucketName string) (string, error) {
 	if err != nil {
 		return "", err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
 	var LocationConstraint string
-	err = xmlUnmarshal(resp.body, &LocationConstraint)
+	err = xmlUnmarshal(resp.Body, &LocationConstraint)
 	return LocationConstraint, err
 }
 
@@ -200,8 +200,8 @@ func (client Client) SetBucketACL(bucketName string, bucketACL ACLType) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -218,9 +218,9 @@ func (client Client) GetBucketACL(bucketName string) (GetBucketACLResult, error)
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -255,8 +255,8 @@ func (client Client) SetBucketLifecycle(bucketName string, rules []LifecycleRule
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -272,8 +272,8 @@ func (client Client) DeleteBucketLifecycle(bucketName string) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -290,9 +290,9 @@ func (client Client) GetBucketLifecycle(bucketName string) (GetBucketLifecycleRe
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -338,8 +338,8 @@ func (client Client) SetBucketReferer(bucketName string, referers []string, allo
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -356,9 +356,9 @@ func (client Client) GetBucketReferer(bucketName string) (GetBucketRefererResult
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -404,8 +404,8 @@ func (client Client) SetBucketLogging(bucketName, targetBucket, targetPrefix str
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -420,8 +420,8 @@ func (client Client) DeleteBucketLogging(bucketName string) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -438,9 +438,9 @@ func (client Client) GetBucketLogging(bucketName string) (GetBucketLoggingResult
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -476,8 +476,8 @@ func (client Client) SetBucketWebsite(bucketName, indexDocument, errorDocument s
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -492,8 +492,8 @@ func (client Client) DeleteBucketWebsite(bucketName string) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -510,9 +510,9 @@ func (client Client) GetBucketWebsite(bucketName string) (GetBucketWebsiteResult
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -553,8 +553,8 @@ func (client Client) SetBucketCORS(bucketName string, corsRules []CORSRule) erro
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusOK})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusOK})
 }
 
 //
@@ -569,8 +569,8 @@ func (client Client) DeleteBucketCORS(bucketName string) error {
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -588,9 +588,9 @@ func (client Client) GetBucketCORS(bucketName string) (GetBucketCORSResult, erro
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -608,9 +608,9 @@ func (client Client) GetBucketInfo(bucketName string) (GetBucketInfoResult, erro
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -689,6 +689,17 @@ func EnableCRC(isEnableCRC bool) ClientOption {
 	}
 }
 
+//
+// UserAgent 指定UserAgent，默认如下aliyun-sdk-go/1.2.0 (windows/-/amd64;go1.5.2)。
+//
+// userAgent user agent字符串。
+//
+func UserAgent(userAgent string) ClientOption {
+	return func(client *Client) {
+		client.Config.UserAgent = userAgent
+	}
+}
+
 //
 // Proxy 设置代理服务器，默认不使用代理。
 //
@@ -724,5 +735,5 @@ func AuthProxy(proxyHost, proxyUser, proxyPassword string) ClientOption {
 func (client Client) do(method, bucketName, urlParams, subResource string,
 	headers map[string]string, data io.Reader) (*Response, error) {
 	return client.Conn.Do(method, bucketName, "", urlParams,
-		subResource, headers, data)
+		subResource, headers, data, 0)
 }

oss/client_test.go

@@ -534,6 +534,9 @@ func (s *OssClientSuite) TestSetBucketLifecycle(c *C) {
 	err = client.SetBucketLifecycle(bucketNameTest, rules)
 	c.Assert(err, IsNil)
 
+	// eliminate effect of cache
+	time.Sleep(5 * time.Second)
+
 	res, err = client.GetBucketLifecycle(bucketNameTest)
 	c.Assert(err, IsNil)
 	c.Assert(len(res.Rules), Equals, 2)
@@ -860,6 +863,9 @@ func (s *OssClientSuite) TestSetBucketWebsite(c *C) {
 	err = client.SetBucketWebsite(bucketNameTest, indexWebsite, errorWebsite)
 	c.Assert(err, IsNil)
 
+	// eliminate effect of cache
+	time.Sleep(5 * time.Second)
+
 	res, err = client.GetBucketWebsite(bucketNameTest)
 	c.Assert(err, IsNil)
 	c.Assert(res.IndexDocument.Suffix, Equals, indexWebsite)
@@ -1319,6 +1325,10 @@ func (s *OssClientSuite) TestClientOption(c *C) {
 	c.Assert(client.Conn.config.IsAuthProxy, Equals, true)
 	c.Assert(client.Conn.config.ProxyUser, Equals, proxyUser)
 	c.Assert(client.Conn.config.ProxyPassword, Equals, proxyPasswd)
+
+	client, err = New(endpoint, accessID, accessKey, UserAgent("go sdk user agent"))
+
+	c.Assert(client.Conn.config.UserAgent, Equals, "go sdk user agent")
 }
 
 // _TestProxy

oss/conn.go

@@ -7,7 +7,6 @@ import (
 	"encoding/xml"
 	"fmt"
 	"hash"
-	"hash/crc64"
 	"io"
 	"io/ioutil"
 	"net"
@@ -25,25 +24,16 @@ type Conn struct {
 	url    *urlMaker
 }
 
-// Response Http response from oss
-type Response struct {
-	statusCode int
-	headers    http.Header
-	body       io.ReadCloser
-	clientCRC  uint64
-	serverCRC  uint64
-}
-
 // Do 处理请求，返回响应结果。
 func (conn Conn) Do(method, bucketName, objectName, urlParams, subResource string,
-	headers map[string]string, data io.Reader) (*Response, error) {
+	headers map[string]string, data io.Reader, initCRC uint64) (*Response, error) {
 	uri := conn.url.getURL(bucketName, objectName, urlParams)
 	resource := conn.url.getResource(bucketName, objectName, subResource)
-	return conn.doRequest(method, uri, resource, headers, data)
+	return conn.doRequest(method, uri, resource, headers, data, initCRC)
 }
 
 func (conn Conn) doRequest(method string, uri *url.URL, canonicalizedResource string,
-	headers map[string]string, data io.Reader) (*Response, error) {
+	headers map[string]string, data io.Reader, initCRC uint64) (*Response, error) {
 	httpTimeOut := conn.config.HTTPTimeout
 	method = strings.ToUpper(method)
 	if !conn.config.IsUseProxy {
@@ -59,7 +49,7 @@ func (conn Conn) doRequest(method string, uri *url.URL, canonicalizedResource st
 		Host:       uri.Host,
 	}
 
-	fd, crc := conn.handleBody(req, data)
+	fd, crc := conn.handleBody(req, data, initCRC)
 	if fd != nil {
 		defer func() {
 			fd.Close()
@@ -135,7 +125,7 @@ func (conn Conn) doRequest(method string, uri *url.URL, canonicalizedResource st
 }
 
 // handle request body
-func (conn Conn) handleBody(req *http.Request, body io.Reader) (*os.File, hash.Hash64) {
+func (conn Conn) handleBody(req *http.Request, body io.Reader, initCRC uint64) (*os.File, hash.Hash64) {
 	var file *os.File
 	var crc hash.Hash64
 	reader := body
@@ -180,7 +170,7 @@ func (conn Conn) handleBody(req *http.Request, body io.Reader) (*os.File, hash.H
 	}
 
 	if reader != nil && conn.config.IsEnableCRC {
-		crc = crc64.New(crcTable())
+		crc = NewCRC(crcTable(), initCRC)
 		reader = io.TeeReader(reader, crc)
 	}
 
@@ -225,17 +215,17 @@ func (conn Conn) handleResponse(resp *http.Response, crc hash.Hash64) (*Response
 			err = srvErr
 		}
 		return &Response{
-			statusCode: resp.StatusCode,
-			headers:    resp.Header,
-			body:       ioutil.NopCloser(bytes.NewReader(respBody)), // restore the body
+			StatusCode: resp.StatusCode,
+			Headers:    resp.Header,
+			Body:       ioutil.NopCloser(bytes.NewReader(respBody)), // restore the body
 		}, err
 	} else if statusCode >= 300 && statusCode <= 307 {
 		// oss use 3xx, but response has no body
 		err := fmt.Errorf("oss: service returned %d,%s", resp.StatusCode, resp.Status)
 		return &Response{
-			statusCode: resp.StatusCode,
-			headers:    resp.Header,
-			body:       resp.Body,
+			StatusCode: resp.StatusCode,
+			Headers:    resp.Header,
+			Body:       resp.Body,
 		}, err
 	}
 
@@ -246,11 +236,11 @@ func (conn Conn) handleResponse(resp *http.Response, crc hash.Hash64) (*Response
 
 	// 2xx, successful
 	return &Response{
-		statusCode: resp.StatusCode,
-		headers:    resp.Header,
-		body:       resp.Body,
-		clientCRC:  cliCRC,
-		serverCRC:  srvCRC,
+		StatusCode: resp.StatusCode,
+		Headers:    resp.Header,
+		Body:       resp.Body,
+		ClientCRC:  cliCRC,
+		ServerCRC:  srvCRC,
 	}, nil
 }
 

oss/crc.go

@@ -0,0 +1,44 @@
+package oss
+
+import (
+	"hash"
+	"hash/crc64"
+)
+
+// digest represents the partial evaluation of a checksum.
+type digest struct {
+	crc uint64
+	tab *crc64.Table
+}
+
+// NewCRC creates a new hash.Hash64 computing the CRC-64 checksum
+// using the polynomial represented by the Table.
+func NewCRC(tab *crc64.Table, init uint64) hash.Hash64 { return &digest{init, tab} }
+
+// Size returns the number of bytes Sum will return.
+func (d *digest) Size() int { return crc64.Size }
+
+// BlockSize returns the hash's underlying block size.
+// The Write method must be able to accept any amount
+// of data, but it may operate more efficiently if all writes
+// are a multiple of the block size.
+func (d *digest) BlockSize() int { return 1 }
+
+// Reset resets the Hash to its initial state.
+func (d *digest) Reset() { d.crc = 0 }
+
+// Write (via the embedded io.Writer interface) adds more data to the running hash.
+// It never returns an error.
+func (d *digest) Write(p []byte) (n int, err error) {
+	d.crc = crc64.Update(d.crc, d.tab, p)
+	return len(p), nil
+}
+
+// Sum64 returns crc64 value.
+func (d *digest) Sum64() uint64 { return d.crc }
+
+// Sum returns hash value.
+func (d *digest) Sum(in []byte) []byte {
+	s := d.Sum64()
+	return append(in, byte(s>>56), byte(s>>48), byte(s>>40), byte(s>>32), byte(s>>24), byte(s>>16), byte(s>>8), byte(s))
+}

oss/crc_test.go

@@ -3,6 +3,7 @@ package oss
 import (
 	"crypto/md5"
 	"encoding/base64"
+	"hash/crc64"
 	"io"
 	"io/ioutil"
 	"os"
@@ -72,13 +73,65 @@ func (s *OssCrcSuite) TearDownTest(c *C) {
 	c.Assert(err, IsNil)
 }
 
+// TestCRCGolden 测试OSS实现的CRC64
+func (s *OssCrcSuite) TestCRCGolden(c *C) {
+	type crcTest struct {
+		out uint64
+		in  string
+	}
+
+	var crcGolden = []crcTest{
+		{0x0, ""},
+		{0x3420000000000000, "a"},
+		{0x36c4200000000000, "ab"},
+		{0x3776c42000000000, "abc"},
+		{0x336776c420000000, "abcd"},
+		{0x32d36776c4200000, "abcde"},
+		{0x3002d36776c42000, "abcdef"},
+		{0x31b002d36776c420, "abcdefg"},
+		{0xe21b002d36776c4, "abcdefgh"},
+		{0x8b6e21b002d36776, "abcdefghi"},
+		{0x7f5b6e21b002d367, "abcdefghij"},
+		{0x8ec0e7c835bf9cdf, "Discard medicine more than two years old."},
+		{0xc7db1759e2be5ab4, "He who has a shady past knows that nice guys finish last."},
+		{0xfbf9d9603a6fa020, "I wouldn't marry him with a ten foot pole."},
+		{0xeafc4211a6daa0ef, "Free! Free!/A trip/to Mars/for 900/empty jars/Burma Shave"},
+		{0x3e05b21c7a4dc4da, "The days of the digital watch are numbered.  -Tom Stoppard"},
+		{0x5255866ad6ef28a6, "Nepal premier won't resign."},
+		{0x8a79895be1e9c361, "For every action there is an equal and opposite government program."},
+		{0x8878963a649d4916, "His money is twice tainted: 'taint yours and 'taint mine."},
+		{0xa7b9d53ea87eb82f, "There is no reason for any individual to have a computer in their home. -Ken Olsen, 1977"},
+		{0xdb6805c0966a2f9c, "It's a tiny change to the code and not completely disgusting. - Bob Manchek"},
+		{0xf3553c65dacdadd2, "size:  a.out:  bad magic"},
+		{0x9d5e034087a676b9, "The major problem is with sendmail.  -Mark Horton"},
+		{0xa6db2d7f8da96417, "Give me a rock, paper and scissors and I will move the world.  CCFestoon"},
+		{0x325e00cd2fe819f9, "If the enemy is within range, then so are you."},
+		{0x88c6600ce58ae4c6, "It's well we cannot hear the screams/That we create in others' dreams."},
+		{0x28c4a3f3b769e078, "You remind me of a TV show, but that's all right: I watch it anyway."},
+		{0xa698a34c9d9f1dca, "C is as portable as Stonehedge!!"},
+		{0xf6c1e2a8c26c5cfc, "Even if I could be Shakespeare, I think I should still choose to be Faraday. - A. Huxley"},
+		{0xd402559dfe9b70c, "The fugacity of a constituent in a mixture of gases at a given temperature is proportional to its mole fraction.  Lewis-Randall Rule"},
+		{0xdb6efff26aa94946, "How can you write a big system without C++?  -Paul Glick"},
+	}
+
+	var tab = crc64.MakeTable(crc64.ISO)
+
+	for i := 0; i < len(crcGolden); i++ {
+		golden := crcGolden[i]
+		crc := NewCRC(tab, 0)
+		io.WriteString(crc, golden.in)
+		sum := crc.Sum64()
+
+		c.Assert(sum, Equals, golden.out)
+	}
+}
+
 // TestEnableCRCAndMD5 开启MD5和CRC校验
 func (s *OssCrcSuite) TestEnableCRCAndMD5(c *C) {
 	objectName := objectNamePrefix + "tecam"
 	fileName := "../sample/BingWallpaper-2015-11-07.jpg"
 	newFileName := "BingWallpaper-2015-11-07-2.jpg"
-	objectValue := "大江东去，浪淘尽，千古风流人物。 故垒西边，人道是、三国周郎赤壁。 乱石穿空，惊涛拍岸，卷起千堆雪。 江山如画，一时多少豪杰。" +
-		"遥想公谨当年，小乔初嫁了，雄姿英发。 羽扇纶巾，谈笑间、樯橹灰飞烟灭。故国神游，多情应笑我，早生华发，人生如梦，一尊还酹江月。"
+	objectValue := "空山新雨后，天气晚来秋。明月松间照，清泉石上流。竹喧归浣女，莲动下渔舟。随意春芳歇，王孙自可留。"
 
 	client, err := New(endpoint, accessID, accessKey, EnableCRC(true), EnableMD5(true), MD5ThresholdCalcInMemory(200*1024))
 	c.Assert(err, IsNil)
@@ -97,12 +150,12 @@ func (s *OssCrcSuite) TestEnableCRCAndMD5(c *C) {
 	body.Close()
 
 	// GetObjectWithCRC
-	body, calcCRC, srvCRC, err := bucket.GetObjectWithCRC(objectName)
+	getResult, err := bucket.DoGetObject(&GetObjectRequest{objectName}, nil)
 	c.Assert(err, IsNil)
-	str, err := readBody(body)
+	str, err := readBody(getResult.Response.Body)
 	c.Assert(err, IsNil)
 	c.Assert(str, Equals, objectValue)
-	c.Assert(calcCRC.Sum64(), Equals, srvCRC)
+	c.Assert(getResult.ClientCRC.Sum64(), Equals, getResult.ServerCRC)
 
 	// PutObjectFromFile
 	err = bucket.PutObjectFromFile(objectName, fileName)
@@ -121,7 +174,23 @@ func (s *OssCrcSuite) TestEnableCRCAndMD5(c *C) {
 
 	// AppendObject
 	var nextPos int64
-	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+
+	err = bucket.DeleteObject(objectName)
+	c.Assert(err, IsNil)
+
+	request := &AppendObjectRequest{
+		ObjectKey: objectName,
+		Reader:    strings.NewReader(objectValue),
+		Position:  0,
+	}
+	appendResult, err := bucket.DoAppendObject(request, []Option{InitCRC(0)})
+	c.Assert(err, IsNil)
+	request.Position = appendResult.NextPosition
+	appendResult, err = bucket.DoAppendObject(request, []Option{InitCRC(appendResult.CRC)})
 	c.Assert(err, IsNil)
 
 	err = s.bucket.DeleteObject(objectName)
@@ -159,8 +228,7 @@ func (s *OssCrcSuite) TestDisableCRCAndMD5(c *C) {
 	objectName := objectNamePrefix + "tdcam"
 	fileName := "../sample/BingWallpaper-2015-11-07.jpg"
 	newFileName := "BingWallpaper-2015-11-07-3.jpg"
-	objectValue := "大江东去，浪淘尽，千古风流人物。 故垒西边，人道是、三国周郎赤壁。 乱石穿空，惊涛拍岸，卷起千堆雪。 江山如画，一时多少豪杰。" +
-		"遥想公谨当年，小乔初嫁了，雄姿英发。 羽扇纶巾，谈笑间、樯橹灰飞烟灭。故国神游，多情应笑我，早生华发，人生如梦，一尊还酹江月。"
+	objectValue := "中岁颇好道，晚家南山陲。兴来每独往，胜事空自知。行到水穷处，坐看云起时。偶然值林叟，谈笑无还期。"
 
 	client, err := New(endpoint, accessID, accessKey, EnableCRC(false), EnableMD5(false))
 	c.Assert(err, IsNil)
@@ -179,9 +247,9 @@ func (s *OssCrcSuite) TestDisableCRCAndMD5(c *C) {
 	body.Close()
 
 	// GetObjectWithCRC
-	body, _, _, err = bucket.GetObjectWithCRC(objectName)
+	getResult, err := bucket.DoGetObject(&GetObjectRequest{objectName}, nil)
 	c.Assert(err, IsNil)
-	str, err := readBody(body)
+	str, err := readBody(getResult.Response.Body)
 	c.Assert(err, IsNil)
 	c.Assert(str, Equals, objectValue)
 
@@ -202,7 +270,23 @@ func (s *OssCrcSuite) TestDisableCRCAndMD5(c *C) {
 
 	// AppendObject
 	var nextPos int64
-	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+	nextPos, err = bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+
+	err = bucket.DeleteObject(objectName)
+	c.Assert(err, IsNil)
+
+	request := &AppendObjectRequest{
+		ObjectKey: objectName,
+		Reader:    strings.NewReader(objectValue),
+		Position:  0,
+	}
+	appendResult, err := bucket.DoAppendObject(request, []Option{InitCRC(0)})
+	c.Assert(err, IsNil)
+	request.Position = appendResult.NextPosition
+	appendResult, err = bucket.DoAppendObject(request, []Option{InitCRC(appendResult.CRC)})
 	c.Assert(err, IsNil)
 
 	err = s.bucket.DeleteObject(objectName)
@@ -235,12 +319,11 @@ func (s *OssCrcSuite) TestDisableCRCAndMD5(c *C) {
 	c.Assert(err, IsNil)
 }
 
-// TestDisableCRCAndMD5 关闭MD5和CRC校验
+// TestSpecifyContentMD5 指定MD5
 func (s *OssCrcSuite) TestSpecifyContentMD5(c *C) {
 	objectName := objectNamePrefix + "tdcam"
 	fileName := "../sample/BingWallpaper-2015-11-07.jpg"
-	objectValue := "大江东去，浪淘尽，千古风流人物。 故垒西边，人道是、三国周郎赤壁。 乱石穿空，惊涛拍岸，卷起千堆雪。 江山如画，一时多少豪杰。" +
-		"遥想公谨当年，小乔初嫁了，雄姿英发。 羽扇纶巾，谈笑间、樯橹灰飞烟灭。故国神游，多情应笑我，早生华发，人生如梦，一尊还酹江月。"
+	objectValue := "积雨空林烟火迟，蒸藜炊黍饷东菑。漠漠水田飞白鹭，阴阴夏木啭黄鹂。山中习静观朝槿，松下清斋折露葵。野老与人争席罢，海鸥何事更相疑。"
 
 	mh := md5.Sum([]byte(objectValue))
 	md5B64 := base64.StdEncoding.EncodeToString(mh[:])
@@ -262,7 +345,23 @@ func (s *OssCrcSuite) TestSpecifyContentMD5(c *C) {
 
 	// AppendObject
 	var nextPos int64
-	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos, ContentMD5(md5B64))
+	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos)
+	c.Assert(err, IsNil)
+
+	err = s.bucket.DeleteObject(objectName)
+	c.Assert(err, IsNil)
+
+	request := &AppendObjectRequest{
+		ObjectKey: objectName,
+		Reader:    strings.NewReader(objectValue),
+		Position:  0,
+	}
+	appendResult, err := s.bucket.DoAppendObject(request, []Option{InitCRC(0)})
+	c.Assert(err, IsNil)
+	request.Position = appendResult.NextPosition
+	appendResult, err = s.bucket.DoAppendObject(request, []Option{InitCRC(appendResult.CRC)})
 	c.Assert(err, IsNil)
 
 	err = s.bucket.DeleteObject(objectName)
@@ -284,3 +383,16 @@ func (s *OssCrcSuite) TestSpecifyContentMD5(c *C) {
 	err = s.bucket.DeleteObject(objectName)
 	c.Assert(err, IsNil)
 }
+
+// TestCopyObjectToOrFromNegative
+func (s *OssCrcSuite) TestAppendObjectNegative(c *C) {
+	objectName := objectNamePrefix + "taoncrc"
+	objectValue := "空山不见人，但闻人语响。返影入深林，复照青苔上。"
+
+	nextPos, err := s.bucket.AppendObject(objectName, strings.NewReader(objectValue), 0, InitCRC(0))
+	c.Assert(err, IsNil)
+
+	nextPos, err = s.bucket.AppendObject(objectName, strings.NewReader(objectValue), nextPos, InitCRC(0))
+	c.Assert(err, NotNil)
+	c.Assert(strings.HasPrefix(err.Error(), "oss: the crc"), Equals, true)
+}

oss/error.go

@@ -75,8 +75,8 @@ func (e CRCCheckError) Error() string {
 }
 
 func checkCRC(resp *Response, operation string) error {
-	if resp.clientCRC == resp.serverCRC {
+	if resp.ClientCRC == resp.ServerCRC {
 		return nil
 	}
-	return CRCCheckError{resp.clientCRC, resp.serverCRC, operation, resp.headers.Get(HTTPHeaderOssRequestID)}
+	return CRCCheckError{resp.ClientCRC, resp.ServerCRC, operation, resp.Headers.Get(HTTPHeaderOssRequestID)}
 }

oss/model.go

@@ -0,0 +1,60 @@
+package oss
+
+import (
+	"hash"
+	"io"
+	"net/http"
+)
+
+// Response Http response from oss
+type Response struct {
+	StatusCode int
+	Headers    http.Header
+	Body       io.ReadCloser
+	ClientCRC  uint64
+	ServerCRC  uint64
+}
+
+// PutObjectRequest The request of DoPutObject
+type PutObjectRequest struct {
+	ObjectKey string
+	Reader    io.Reader
+}
+
+// GetObjectRequest The request of DoGetObject
+type GetObjectRequest struct {
+	ObjectKey string
+}
+
+// GetObjectResult The result of DoGetObject
+type GetObjectResult struct {
+	Response  *Response
+	ClientCRC hash.Hash64
+	ServerCRC uint64
+}
+
+// AppendObjectRequest  The requtest of DoAppendObject
+type AppendObjectRequest struct {
+	ObjectKey string
+	Reader    io.Reader
+	Position  int64
+}
+
+// AppendObjectResult The result of DoAppendObject
+type AppendObjectResult struct {
+	NextPosition int64
+	CRC          uint64
+}
+
+// UploadPartRequest The request of DoUploadPart
+type UploadPartRequest struct {
+	InitResult *InitiateMultipartUploadResult
+	Reader     io.Reader
+	PartSize   int64
+	PartNumber int
+}
+
+// UploadPartResult The result of DoUploadPart
+type UploadPartResult struct {
+	Part UploadPart
+}

oss/multipart.go

@@ -28,9 +28,9 @@ func (bucket Bucket) InitiateMultipartUpload(objectKey string, options ...Option
 	if err != nil {
 		return imur, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &imur)
+	err = xmlUnmarshal(resp.Body, &imur)
 	return imur, err
 }
 
@@ -53,26 +53,17 @@ func (bucket Bucket) InitiateMultipartUpload(objectKey string, options ...Option
 // error 操作成功error为nil，非nil为错误信息。
 //
 func (bucket Bucket) UploadPart(imur InitiateMultipartUploadResult, reader io.Reader,
-	size int64, partNumber int) (UploadPart, error) {
-	var part = UploadPart{}
-	params := "partNumber=" + strconv.Itoa(partNumber) + "&uploadId=" + imur.UploadID
-	opts := []Option{ContentLength(size)}
-	resp, err := bucket.do("PUT", imur.Key, params, params, opts, &io.LimitedReader{R: reader, N: size})
-	if err != nil {
-		return part, err
+	partSize int64, partNumber int) (UploadPart, error) {
+	request := &UploadPartRequest{
+		InitResult: &imur,
+		Reader:     reader,
+		PartSize:   partSize,
+		PartNumber: partNumber,
 	}
-	defer resp.body.Close()
 
-	if bucket.getConfig().IsEnableCRC {
-		err = checkCRC(resp, "UploadPart")
-		if err != nil {
-			return part, err
-		}
-	}
+	result, err := bucket.DoUploadPart(request)
 
-	part.ETag = resp.headers.Get(HTTPHeaderEtag)
-	part.PartNumber = partNumber
-	return part, nil
+	return result.Part, err
 }
 
 //
@@ -98,23 +89,49 @@ func (bucket Bucket) UploadPartFromFile(imur InitiateMultipartUploadResult, file
 	defer fd.Close()
 	fd.Seek(startPosition, os.SEEK_SET)
 
-	params := "partNumber=" + strconv.Itoa(partNumber) + "&uploadId=" + imur.UploadID
-	resp, err := bucket.do("PUT", imur.Key, params, params, nil, &io.LimitedReader{R: fd, N: partSize})
+	request := &UploadPartRequest{
+		InitResult: &imur,
+		Reader:     fd,
+		PartSize:   partSize,
+		PartNumber: partNumber,
+	}
+
+	result, err := bucket.DoUploadPart(request)
+
+	return result.Part, err
+}
+
+//
+// DoUploadPart 上传分片。
+//
+// request 上传分片请求。
+//
+// UploadPartResult 上传分片请求返回值。
+// error  操作无错误为nil，非nil为错误信息。
+//
+func (bucket Bucket) DoUploadPart(request *UploadPartRequest) (*UploadPartResult, error) {
+	params := "partNumber=" + strconv.Itoa(request.PartNumber) + "&uploadId=" + request.InitResult.UploadID
+	opts := []Option{ContentLength(request.PartSize)}
+	resp, err := bucket.do("PUT", request.InitResult.Key, params, params, opts,
+		&io.LimitedReader{R: request.Reader, N: request.PartSize})
 	if err != nil {
-		return part, err
+		return &UploadPartResult{}, err
+	}
+	defer resp.Body.Close()
+
+	part := UploadPart{
+		ETag:       resp.Headers.Get(HTTPHeaderEtag),
+		PartNumber: request.PartNumber,
 	}
-	defer resp.body.Close()
 
 	if bucket.getConfig().IsEnableCRC {
-		err = checkCRC(resp, "UploadPartFromFile")
+		err = checkCRC(resp, "DoUploadPart")
 		if err != nil {
-			return part, err
+			return &UploadPartResult{part}, err
 		}
 	}
 
-	part.ETag = resp.headers.Get(HTTPHeaderEtag)
-	part.PartNumber = partNumber
-	return part, nil
+	return &UploadPartResult{part}, nil
 }
 
 //
@@ -146,9 +163,9 @@ func (bucket Bucket) UploadPartCopy(imur InitiateMultipartUploadResult, srcBucke
 	if err != nil {
 		return part, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	if err != nil {
 		return part, err
 	}
@@ -186,9 +203,9 @@ func (bucket Bucket) CompleteMultipartUpload(imur InitiateMultipartUploadResult,
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -205,8 +222,8 @@ func (bucket Bucket) AbortMultipartUpload(imur InitiateMultipartUploadResult) er
 	if err != nil {
 		return err
 	}
-	defer resp.body.Close()
-	return checkRespCode(resp.statusCode, []int{http.StatusNoContent})
+	defer resp.Body.Close()
+	return checkRespCode(resp.StatusCode, []int{http.StatusNoContent})
 }
 
 //
@@ -224,9 +241,9 @@ func (bucket Bucket) ListUploadedParts(imur InitiateMultipartUploadResult) (List
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	return out, err
 }
 
@@ -252,9 +269,9 @@ func (bucket Bucket) ListMultipartUploads(options ...Option) (ListMultipartUploa
 	if err != nil {
 		return out, err
 	}
-	defer resp.body.Close()
+	defer resp.Body.Close()
 
-	err = xmlUnmarshal(resp.body, &out)
+	err = xmlUnmarshal(resp.Body, &out)
 	if err != nil {
 		return out, err
 	}

oss/option.go

@@ -23,6 +23,7 @@ const (
 	deleteObjectsQuiet = "delete-objects-quiet"
 	routineNum         = "x-routine-num"
 	checkpointConfig   = "x-cp-config"
+	initCRC64          = "init-crc64"
 )
 
 type (
@@ -223,6 +224,11 @@ func Routines(n int) Option {
 	return addArg(routineNum, strconv.Itoa(n))
 }
 
+// InitCRC AppendObject CRC的校验的初始值
+func InitCRC(initCRC uint64) Option {
+	return addArg(initCRC64, strconv.FormatUint(initCRC, 10))
+}
+
 func setHeader(key, value string) Option {
 	return func(params map[string]optionValue) error {
 		if value == "" {