.NET 6新特性试用 | 异步流

Posted 2021-12-18 dotNET跨平台

前言

IAsyncEnumerable<T>支持返回异步迭代的枚举器，但在.NET 6之前，即使在API中使用了IAsyncEnumerable<T>，它还是使用同步方式输出，首先将结果缓冲到内存中，然后再写入响应中：

[HttpGet]
public IAsyncEnumerable<WeatherForecast> Get()

    var rng = new Random();
    async IAsyncEnumerable<WeatherForecast> streamWeatherForecastsAsync()
    
        for (int index = 1; index <= 5; index++)
        
            WeatherForecast weatherForecast = new WeatherForecast
            
                Date = $"DateTime.Now:ss.fff",
                TemperatureC = rng.Next(-20, 55),
                Summary = Summaries[rng.Next(Summaries.Length)]
            ;

            await Task.Delay(1000);

            yield return weatherForecast;
        ;
    ;

    return streamWeatherForecastsAsync();

现在，在.NET 6中，我们可以使用异步流。

Demo

1.服务端

采用上面相同的代码，可以看到不同的返回效果：

IAsyncEnumerable实例采用异步方式迭代写入响应中，不再阻塞请求调用。

需要注意的是，只有使用System.Text.Json进行序列化时，此功能才会起作用。

2.客户端

同样，我们可以在客户端异步接收响应，示例代码如下：

HttpClient httpClient = new();

var response = await httpClient.GetAsync(
    "https://localhost:7211/WeatherForecast",
    HttpCompletionOption.ResponseHeadersRead
);

var weatherForecasts = await response.Content
    .ReadFromJsonAsync<IAsyncEnumerable<WeatherForecast>>();

await foreach (var weatherForecast in weatherForecasts)

    Console.WriteLine($"[DateTime.Now:ss.fff] weatherForecast.Date");

但是，实际运行效果却是按照同步方式执行的：

这是因为，我们必须使用System.Text.Json提供的专门方法处理异步流反序列化：

var responseStream = await response.Content.ReadAsStreamAsync();
var weatherForecasts = JsonSerializer.DeserializeAsyncEnumerable<WeatherForecast>(responseStream,
        new JsonSerializerOptions
        
            PropertyNameCaseInsensitive = true,
            DefaultBufferSize = 50
        );

需要将DefaultBufferSize设置较小的值，保证异步迭代及时返回。

结论

EF Core支持IAsyncEnumerable查询数据：

可以将EF Core从数据库中获取的数据直接使用异步流的方式传输到响应，无需大量内存缓冲数据，提高程序性能。

如果你觉得这篇文章对你有所启发，请关注我的个人公众号”My IO“