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

上传回调


OSS在上传文件完成的时，可以提供 回调（Callback）给应用服务器。用户只需要在发送给OSS的请求中携带相应的回调参数，即能实现回调。支持上传回调接口有：PutObject、PostObject、CompleteMultipartUpload。您想了解上传回调的更详细信息，请参考 上传回调。下面以 PutObject 为例说明上传回调的用法。

1. using Aliyun.OSS;
3. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);
5. public static void PutObjectCallback(string bucketName)
6. {
7.     const string key = "PutObjectProgress";
8.     const string callbackUrl = "http://callback.oss-demo.com:23450";
9.     const string callbackBody = "bucket=${bucket}&object=${object}&etag=${etag}&size=${size}&mimeType=${mimeType}&" +
10.                                 "my_var1=${x:var1}&my_var2=${x:var2}";
12.     try
13.     {
14.         string responseContent = "";
15.         var metadata = BuildCallbackMetadata(callbackUrl, callbackBody);
16.         using (var fs = File.Open(fileToUpload, FileMode.Open))
17.         {
18.             var putObjectRequest = new PutObjectRequest(bucketName, key, fs, metadata);
19.             var result = client.PutObject(putObjectRequest);
20.             responseContent = GetCallbackResponse(result);
21.         }
22.         Console.WriteLine("Put object:{0} succeeded, callback response content:{1}", key, responseContent);
23.     }
24.     catch (OssException ex)
25.     {
26.         Console.WriteLine("Failed with error code: {0}; Error info: {1}. \nRequestID:{2}\tHostID:{3}",
27.             ex.ErrorCode, ex.Message, ex.RequestId, ex.HostId);
28.     }
29.     catch (Exception ex)
30.     {
31.         Console.WriteLine("Failed with error info: {0}", ex.Message);
32.     }
33. }
35. private static string GetCallbackResponse(PutObjectResult putObjectResult)
36. {
37.     string callbackResponse = null;
38.     using (var stream = putObjectResult.ResponseStream)
39.     {
40.         var buffer = new byte[4 * 1024];
41.         var bytesRead = stream.Read(buffer, 0, buffer.Length);
42.         callbackResponse = Encoding.Default.GetString(buffer, 0, bytesRead);
43.     }
44.     return callbackResponse;
45. }

说明：

• PutObject、CompleteMultipartUpload、ResumableUploadObject支持上传回调，完整代码请参考GitHub。
• 上传回调的调试方法和错误排除，请参考上传回调错误及排除。

1. using Aliyun.OSS;
3. var client = new OssClient(endpoint, accessKeyId, accessKeySecret);
5. public static void PutObjectProgress(string bucketName)
6. {
7.     const string key = "PutObjectProgress";
8.     try
9.     {
10.         using (var fs = File.Open(fileToUpload, FileMode.Open))
11.         {
12.             var putObjectRequest = new PutObjectRequest(bucketName, key, fs);
13.             putObjectRequest.StreamTransferProgress += streamProgressCallback;
14.             client.PutObject(putObjectRequest);
15.         }
16.         Console.WriteLine("Put object:{0} succeeded", key);
17.     }
18.     catch (OssException ex)
19.     {
20.         Console.WriteLine("Failed with error code: {0}; Error info: {1}. \nRequestID:{2}\tHostID:{3}",
21.             ex.ErrorCode, ex.Message, ex.RequestId, ex.HostId);
22.     }
23.     catch (Exception ex)
24.     {
25.         Console.WriteLine("Failed with error info: {0}", ex.Message);
26.     }
27. }
29. private static void streamProgressCallback(object sender, StreamTransferProgressArgs args)
30. {
31.     System.Console.WriteLine("ProgressCallback - TotalBytes:{0}, TransferredBytes:{1}",
32.         args.TotalBytes, args.TransferredBytes);
33. }

说明： PutObject、AppendObject、UploadPart、ResumableUploadObject、GetObject都支持进度功能，完整代码请参考 GitHub。