C# 中 async/await 调用传统 Begin/End 异步方法 – dudu – 博客园

最近在改进园子的图片上传程序，希望实现用户上传图片时同时将图片文件保存在三个地方：1）服务器本地硬盘；2）又拍云；3）阿里云OSS。并且在保存时使用异步操作。

对于异步保存到本地硬盘，只需用 Steam.CopyToAsync() 将上传文件流异步复制到 FileStream 即可。

对于异步保存至又拍云，只要借助 WebRequest.GetRequestStreamAsync() + Steam.CopyToAsync() 就可以实现。

而阿里云OSS提供了 .NET SDK，使用起来很方便，但是之前并没有提供异步接口，成为异步化的一个障碍。

今天在 OSS .NET SDK 的更新日志中惊喜地发现：“添加异步化接口（支持Put/Get/List/Copy/PartCopy等异步操作）”。于是立马下载下来，可是一使用惊喜瞬间化为乌有 —— 新版 SDK 只提供了传统的 Begin/End 异步接口，却没有提供 async 异步接口。

<span style="color: #0000ff;">public</span> IAsyncResult BeginPutObject(<span style="color: #0000ff;">string</span> bucketName, <span style="color: #0000ff;">string</span> key, Stream content, AsyncCallback callback, <span style="color: #0000ff;">object</span> state);

<span style="color: #0000ff;">public</span> PutObjectResult EndPutObject(IAsyncResult asyncResult);

怀着失落的心情，望着孤零零的没有 await 陪伴的 async，心里有说不出的滋味。。。

<span style="color: #0000ff;">async</span> Task&lt;<span style="color: #0000ff;">bool</span>&gt; IBucket.PutFileAsync(<span style="color: #0000ff;">string</span><span style="color: #000000;"> filePath, Stream uploadStream)</span>

{

filePath = filePath.Substring(1);

uploadStream.Position = 0;

_client.PutObject(_bucketName, filePath, uploadStream);

return true;

}

难道这次只能实现半吊子的异步化吗？好不容易等来 OSS .NET SDK 支持异步化，难道只是空欢喜一场吗？真有些不甘心啊！

这时，心中突然闪过一个念头：有没有可能直接用 async/await 调用 Begin/End 异步方法？也许微软早就为我们准备好了馅饼？

于是，在网上搜寻了一番，发现了一线希望 —— 用 Task.Factory.FromAsync() 是可能实现的。

可是，一堆 FromAsync 方法看着就让人晕，只能一点点去试。

开始用的是 Task.Factory.FromAsync<PutObjectResult> ，但参数总对不上，比如：

<span style="color: #0000ff;">await</span> Task.Factory.FromAsync&lt;PutObjectResult&gt;<span style="color: #000000;">(</span>

_client.BeginPutObject,

_client.EndPutObject,

_bucketName, filePath, uploadStream,

null);

编译出错：

No overload for method 'FromAsync' takes 6 arguments

后来改为下面这样，总算编译通过了：

<span style="color: #0000ff;">await</span> Task.Factory.FromAsync&lt;PutObjectResult&gt;<span style="color: #000000;">(</span>

_client.BeginPutObject(_bucketName, filePath, uploadStream, null, null),

x => { return _client.EndPutObject(x); });

而且运行程序，图片都能成功上传到阿里云OSS中，但总是报这样的错误：

failed: System.ArgumentException : retryableAsyncResult should not be null

at Aliyun.OpenServices.OpenStorageService.Utilities.OssUtils.EndOperationHelper(IServiceClient serviceClient, IAsyncResult asyncResult)

这个错误说明 callback 调用没成功。

在这个地方折腾了很长时间，后来瞎猫碰着死耗子，把 Task.Factory.FromAsync<PutObjectResult> 改为 Task<PutObjectResult>.Factory.FromAsync 问题就解决了。代码如下：

<span style="color: #0000ff;">async</span> Task&lt;<span style="color: #0000ff;">bool</span>&gt; IBucket.PutFileAsync(<span style="color: #0000ff;">string</span><span style="color: #000000;"> filePath, Stream uploadStream)</span>

{