我正在尝试使用 .NET 4.5 async & await 实现完全异步 blob 下载。

假设整个 blob 可以一次放入内存中，并且我们希望将其保存在 string 中。

代码:

public async Task<string> DownloadTextAsync(ICloudBlob blob)
{
    using (Stream memoryStream = new MemoryStream())
    {
        IAsyncResult asyncResult = blob.BeginDownloadToStream(memoryStream, null, null);
        await Task.Factory.FromAsync(asyncResult, (r) => { blob.EndDownloadToStream(r); });
        memoryStream.Position = 0;

        using (StreamReader streamReader = new StreamReader(memoryStream))
        {
            // is this good enough?
            return streamReader.ReadToEnd();

            // or do we need this?
            return await streamReader.ReadToEndAsync();
        }
    }
}

用法:

CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("StorageAccountConnectionString"));
CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();
CloudBlobContainer container = blobClient.GetContainerReference("container1");
CloudBlockBlob blockBlob = container.GetBlockBlobReference("blob1.txt");

string text = await DownloadTextAsync(blockBlob);

这段代码是否正确并且确实是完全异步的？你会以不同的方式实现吗？

我希望得到一些额外的说明:

1. GetContainerReference 和 GetBlockBlobReference 不需要异步，因为它们还没有联系服务器，对吗？

2. streamReader.ReadToEnd 是否需要异步？

3. 我对 BeginDownloadToStream 的作用有点困惑.. 在调用 EndDownloadToStream 时，我的内存流是否有所有里面的数据？还是流只打开预读？

更新:(从 Storage 2.1.0.0 RC 开始)

现在原生支持异步。

CloudStorageAccount storageAccount = CloudStorageAccount.Parse(CloudConfigurationManager.GetSetting("StorageAccountConnectionString"));
CloudBlobClient blobClient = storageAccount.CreateCloudBlobClient();
CloudBlobContainer container = blobClient.GetContainerReference("container1");
CloudBlockBlob blockBlob = container.GetBlockBlobReference("blob1.txt");

string text = await blockBlob.DownloadTextAsync();

最佳答案

Is this code correct and this is indeed fully asynchronous?

是的。

Would you implement this differently?

是的。特别是 TaskFactory.FromAsync如果你传入 Begin 包装器会更有效率/End方法对而不是传入现有的 IAsyncResult .像这样:

await Task.Factory.FromAsync(blob.BeginDownloadToStream,
    blob.EndDownloadToStream, memoryStream, null);

我也更喜欢将它们包装到单独的扩展方法中，这样我就可以这样调用它:

await blog.DownloadToStreamAsync(memoryStream);

请注意，下一版本的客户端库(2.1，目前在 RC 中)将具有 async -就绪方法，即DownloadToStreamAsync .

GetContainerReference and GetBlockBlobReference don't need to be async since they don't contact the server yet, right?

正确。

Does streamReader.ReadToEnd need to be async or not?

它不会(也不应该)。 Stream async 有点不寻常编程。通常，如果有 async方法那么你应该在你的async中使用它代码，但该准则不适用于 Stream类型。原因是基地 Stream类不知道它的实现是同步的还是异步的，所以它假定它是同步的，并且默认情况下将通过在后台线程上执行同步工作来伪造它的异步操作。真正的异步流(例如 NetworkStream )覆盖它并提供真正的异步操作。同步流(例如 MemoryStream)保持此默认行为。

所以你不想调用ReadToEndAsync在 MemoryStream 上.

I'm a little confused about what BeginDownloadToStream does.. by the time EndDownloadToStream is called, does my memory stream have all the data inside?

是的。操作是DownloadToStream ;也就是说，它将一个 blob 下载到一个流中。由于您正在将 blob 下载到 MemoryStream 中, 到此操作完成时，blob 已完全位于内存中。

关于c# - 使用 .NET 4.5 async 将 Azure blob 异步下载到字符串，等待，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/18217626/