前言

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“

總結

以上是生活随笔為你收集整理的.NET 6新特性试用 | 异步流的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。