.NET-SDK之如何实现上传文件（四）?

Upload Part本地上传


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

1. using Aliyun.OSS;
3. // 初始化OssClient
4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);
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. }
15. // 开始分片上传
16. try
17. {
18.     var partETags = new List<PartETag>();
19.     using (var fs = File.Open(fileToUpload, FileMode.Open))
20.     {
21.         for (var i = 0; i < partCount; i++)
22.         {
23.             var skipBytes = (long)partSize * i;
25.             //定位到本次上传片应该开始的位置
26.             fs.Seek(skipBytes, 0);
28.             //计算本次上传的片大小，最后一片为剩余的数据大小，其余片都是part size大小。
29.             var size = (partSize < fileSize - skipBytes) ? partSize : (fileSize - skipBytes);
30.             var request = new UploadPartRequest(bucketName, objectName, uploadId)
31.             {
32.                 InputStream = fs,
33.                 PartSize = size,
34.                 PartNumber = i + 1
35.             };
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 方法要求除最后一个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;
3. // 初始化OssClient
4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);
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组合成一个完整的文件。

1. using Aliyun.OSS;
3. // 初始化OssClient
4. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);
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。