在 webapi 中使用异步等待的最佳实践

Question

我有 .NET 核心 Web API 作为服务层。服务层有所有的 EF 代码。

如果有带有此代码的基本控制器

protected Task<IActionResult> NewTask(Func<IActionResult> callback)
{
    return Task.Factory.StartNew(() =>
    {
        try
        {
            return callback();
        }
        catch (Exception ex)
        {
            Logger.LogError(ex.ToString());
            throw;
        }
    });
}

在控制器操作中，我将所有对服务的调用包装在上述方法中，例如：

[HttpGet("something")]
public async Task<IActionResult> GetSomething(int somethingId)
{
    return await NewTask(() =>
    {
        var result = _somethingService.GetSomething(somethingId);

        if (result != null)
            return Ok(result);
        else
            return NotFound("Role not found");
    });
}

考虑到明天我可能有多个服务调用或调用其他 Web 服务，这是正确的模式吗？请指教。

Answer 1

我希望我的 api 从异步等待中受益。上述模式将满足这些需求

不，它没有。在线程池上运行同步工作给您带来了同步和异步代码的缺点，而两者都没有。

某项服务有一些使用实体框架核心的 crud 操作

目前，您的操作方法就是我所说的“假异步”——它看起来是异步的（例如，使用 await），但实际上只是在后台线程上运行阻塞代码。在 ASP.NET 上，您需要真正的异步，这意味着您必须始终保持异步。有关为什么这在 ASP.NET 上不好的更多信息，请参阅我的 intro to async on ASP.NET article 的前半部分（它主要处理 ASP.NET 非核心，但第一部分讨论同步与异步请求对任何类型的服务器都有效)。

要实现真正的异步，您应该从最低级别开始 - 在这种情况下，您的 EFCore 调用。它们都支持异步。因此，请将 API 调用（如 x.FirstOrDefault()）替换为 await x.FirstOrDefaultAsync()（所有创建/更新/删除等都相同）。

然后让async/await从那里自然生长；编译器会指导你。您最终会在 somethingService 上使用异步方法，这些方法可以这样使用：

[HttpGet("something")]
public async Task<IActionResult> GetSomething(int somethingId)
{
  var result = await _somethingService.GetSomethingAsync(somethingId);
  if (result != null)
    return Ok(result);
  else
    return NotFound("Role not found");
}

Answer 2

好的，首先，您应该停止使用Task.Factory.StartNew，而仅当您需要在线程池线程上运行繁重的CPU 密集型工作时才使用Task.Run。在你的情况下，你根本不需要那个。另外你应该记住，你应该只在调用方法时使用Task.Run，而不是在方法的实现中使用。你可以阅读更多关于here的信息。

当您实际调用数据库并且想要使用异步时，您真正想要的是在您的服务中进行异步工作（我不确定您是否甚至需要在您的情况下使用服务） /await 而不仅仅是在后台线程上运行一些东西。

基本上你的服务应该是这样的（如果你确定你需要一个服务）：

class PeopleService
{
    public async Task<Person> GetPersonByIdAsync(int id)
    {
        Person randomPerson = await DataContext.People.FirstOrDefaultAsync(x => x.Id == id);
        return randomPerson;
    }
}

如您所见，您的服务现在对数据库进行异步调用，这基本上就是您的模式应该是的。您可以将此应用于所有操作（添加/删除/等）

使您的服务异步后，您应该能够轻松地使用操作中的数据。

您的操作应如下所示：

[HttpGet("something")]
public async Task<IActionResult> GetPerson(int id)
{
    var result = await PeopleService.GetPersonByIdAsync(id);

    if (result != null)
        return Ok(result);
    else
        return NotFound("Role not found");
}