.NETSDK之如何实现上传文件（四）?

Upload Part本地上传

我们把本地文件分片上传。假设有一个文件，本地路径为 /path/to/file.zip 由于文件比较大，我们将其分片传输到OSS中。

1. using Aliyun.OSS;


2. 
   
3. // 初始化OssClient


4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);


5. 
   
6. // 计算片个数


7. var fi = new FileInfo(fileToUpload);


8. var fileSize = fi.Length;


9. var partCount = fileSize / partSize;


10. if (fileSize % partSize != 0)


11. {


12.      partCount++;


13. }


14. 
    
15. // 开始分片上传


16. try


17. {


18.     var partETags = new List

    ();



19.     using (var fs = File.Open(fileToUpload, FileMode.Open))


20.     {


21.         for (var i = 0; i
    
22.         {


23.             var skipBytes = (long)partSize * i;


24. 
    
25.             //定位到本次上传片应该开始的位置


26.             fs.Seek(skipBytes, 0);


27. 
    
28.             //计算本次上传的片大小，最后一片为剩余的数据大小，其余片都是part size大小。


29.             var size = (partSize
    
30.             var request = new UploadPartRequest(bucketName, objectName, uploadId)


31.             {


32.                 InputStream = fs,


33.                 PartSize = size,


34.                 PartNumber = i + 1


35.             };


36. 
    
37.             //调用UploadPart接口执行上传功能，返回结果中包含了这个数据片的ETag值


38.             var result = _ossClient.UploadPart(request);


39.             partETags.Add(result.PartETag);


40.         }


41.         Console.WriteLine("Put multi part upload succeeded");


42.     }


43. }


44. catch (Exception ex)


45. {


46.     Console.WriteLine("Put multi part upload failed, {0}", ex.Message);


47. }

说明： 完整代码参考
GitHub。

上面程序的核心是调用UploadPart方法来上传每一个分片，但是要注意以下几点：

• UploadPart 方法要求除最后一个Part以外，其他的Part大小都要大于100KB。但是Upload Part接口并不会立即校验上传Part的大小（因为不知道是否为最后一片）；只有当Complete Multipart Upload的时候才会校验。


• OSS会将服务器端收到Part数据的MD5值放在ETag头内返回给用户。


• 为了保证数据在网络传输过程中不出现错误，SDK会自动设置Content-MD5，OSS会计算上传数据的MD5值与SDK计算的MD5值比较，如果不一致返回InvalidDigest错误码。


• Part号码的范围是1~10000。如果超出这个范围，OSS将返回InvalidArgument的错误码。


• 每次上传part时都要把流定位到此次上传片开头所对应的位置。


• 每次上传part之后，OSS的返回结果会包含一个 PartETag 对象，他是上传片的ETag与片编号（PartNumber）的组合，在后续完成分片上传的步骤中会用到它，因此我们需要将其保存起来。一般来讲我们将这些 PartETag 对象保存到List中。

完成分片上传

完成分片上传代码如下：

1. using Aliyun.OSS;


2. 
   
3. // 初始化OssClient


4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);


5. 
   
6. try


7. {


8.     var completeMultipartUploadRequest = new CompleteMultipartUploadRequest(bucketName, key, uploadId);


9.     foreach (var partETag in partETags)


10.     {


11.         completeMultipartUploadRequest.PartETags.Add(partETag);


12.     }


13.     var result = client.CompleteMultipartUpload(completeMultipartUploadRequest);


14.     Console.WriteLine("complete multi part succeeded");


15. }


16. catch (Exception ex)


17. {


18.     Console.WriteLine("complete multi part failed, {0}", ex.Message);


19. }

说明：

• 完整代码参考GitHub。


• 上面代码中的 partETags 就是进行分片上传中保存的partETag的列表，OSS收到用户提交的Part列表后，会逐一验证每个数据Part的有效性。


• 当所有的数据Part验证通过后，OSS会将这些part组合成一个完整的文件。

取消分片上传事件

我们可以用 AbortMultipartUpload 方法取消分片上传。

1. using Aliyun.OSS;


2. 
   
3. // 初始化OssClient


4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);


5. 
   
6. try


7. {


8.     var request = new AbortMultipartUpload(bucketName, key, uploadId);


9.     client.AbortMultipartUpload(request);


10.     Console.WriteLine("Abort multi part succeeded");


11. }


12. catch (Exception ex)


13. {


14.     Console.WriteLine("Abort multi part failed, {0}", ex.Message);


15. }

说明： 完整代码参考请
GitHub。