如何正确使用 C# 中的 Async Await 函数

Question

我仍然无法理解如何使用 Async 方法。我在控制器中有以下代码。

[HttpPost]
public async Task<IActionResult> ManualUpload([Bind("MktRpt")] ManualMktRptFileUpload itemFileUpload)
{
    var manager = new RecyclableMemoryStreamManager();
    using (var stream = manager.GetStream())
    {
       await itemFileUpload.MktRpt.CopyToAsync(stream);
       await _azureStorageService.saveBlob(stream, Path.GetFileName(itemFileUpload.MktRpt.FileName));
    }

    itemFileUpload.status = "Success";
    return View(itemFileUpload);
}

我的服务方式也很简单：

public async Task saveBlob(MemoryStream stream, string filename)
{
    var blockBlob = _container.GetBlockBlobReference(filename);
    await blockBlob.UploadFromStreamAsync(stream);
}

还有一个简单的模型类：

public class ManualMktRptFileUpload
{
    [Required]
    [Display(Name = "Manual Report")]
    public IFormFile MktRpt { get; set; }

    public string status { get; set; } = "Constructed";
}

当我在 Azure 中检查我的 Blob 容器时，文件在那里，但是它是零字节。

我相信这是因为我没有正确等待流传输，但我不知道如何解决它。

Answer 1

我怀疑这真的与异步有关。目前您正在将一个流复制到MemoryStream，但随后将“光标”留在MemoryStream 的末尾...任何试图从中读取的内容都不会看到新数据。

解决方法非常简单：只需在调用 saveBlob 方法之前“倒带”流：

using (var stream = manager.GetStream())
{
   await itemFileUpload.MktRpt.CopyToAsync(stream);
   stream.Position = 0;
   await _azureStorageService.saveBlob(stream, Path.GetFileName(itemFileUpload.MktRpt.FileName));
}

或者，完全避免复制到MemoryStream：

using (var stream = itemFileUpload.MktRpt.OpenReadStream())
{
    await _azureStorageService.saveBlob(stream, Path.GetFileName(itemFileUpload.MktRpt.FileName));
}