我可以（或应该）在Web API控制器中使用IAsyncE的而不是任务

Question

我目前有一个网络 API

• 使用FromSqlRaw（…）获取一行数据。存储库中的ToListAsync（）
• 将此数据作为OK（data. ToArray（））作为任务返回

现在我想知道我是否应该或可以使用IAsyncE的可作为返回类型。这个想法是在存储库和控制器中使用它。然而，在这个（现在的deremit）线程中，它声明不应该使用它。这里提出的解决方案类似于：

FromSqlRaw(...).AsNoTracking().AsAsyncEnumerable()

至于控制器，我希望用< code>ActionResult包装响应，以显式设置返回代码。然而，这目前似乎并不奏效。

我应该只为存储库应用解决方案并将结果用作控制器中的列表还是保持原样？

Answer 1

英寸使用系统时，MVC的. net 6 IAsyncEnumerable处理被更改。Text.Json:

MVC 不再缓冲 IAsyncEnumerable 实例。相反，MVC 依赖于 System.Text.Json 为这些类型添加的支持。

这意味着控制器将立即开始发送输出，客户端可以在收到响应块时开始处理它。

下面是一个借助新的最小API的例子:

endpoint绑定:

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();

// this endpoint return IAsyncEnumerable<TestData>
app.MapGet("/asyncEnumerable/{count}", (int count) => GetLotsOfDataAsyncEnumerable(count));

// and this one returns Task<IEnumerable<TestData>>
app.MapGet("/{count}", async (int count) => await GetLotsOfDataAsync(count));
app.Run();

控制器方法：

async Task<IEnumerable<TestData>> GetLotsOfDataAsync(int count)
{
    var list = new List<TestData>();
    for (int i = 0; i < count; i++)
    {
        await Task.Delay(10);
        list.Add(new TestData($"{i}"));
    }
    return list;
}

async IAsyncEnumerable<TestData> GetLotsOfDataAsyncEnumerable(int count)
{
    for (int i = 0; i < count; i++)
    {
        await Task.Delay(10);
        yield return new TestData($"{i}");
    }
}

class TestData
{
    public string Field { get; }

    public TestData(string field)
    {
        Field = field;
    }
}

count-path变量允许控制我们希望在一次调用中检索多少数据。

我已经在windows机器上使用curl命令对其进行了测试（以下是解释如何使用curl衡量性能的答案），100个条目的结果：

                       /100        /asyncEnumerable/100
     time_namelookup:  0.000045s   0.000034s
        time_connect:  0.000570s   0.000390s
     time_appconnect:  0.000000s   0.000000s
    time_pretransfer:  0.000648s   0.000435s
       time_redirect:  0.000000s   0.000000s
  time_starttransfer:  1.833341s   0.014880s
                       ---------------------
          time_total:  1.833411s  1.673477s

这里要看的重要内容是 time_starttransfer，来自 curl manpage

时间，以秒为单位，从开始到第一个字节即将被传输。这包括time_pretransfer以及服务器计算结果所需的时间。

正如您所看到的,/ asyncEnumerable endpoint立即开始响应，当然，这种endpoint的客户端必须知道这种行为才能很好地利用它。

Answer 2

IAsyncEnumerable为基于拉取的异步数据检索提供了一个接口。换句话说，此API表示一个迭代器，在该迭代器中异步获取下一个项。

这意味着您将分几轮接收数据，每一轮都是异步的。

>

以前的 IAsyncEnumerable 您可以使用 IEnumerable

而任务

让我们将这些知识应用于WebAPI：

• 从HTTP消费者的角度来看，任务之间没有区别

这意味着，如果API作为操作结果类型公开，则API的使用者无法利用IAsyncEnumerable。