前言

IAsyncEnumerable<T>支持返回異步迭代的枚舉器，但在.NET 6之前，即使在API中使用了IAsyncEnumerable<T>，它還是使用同步方式輸出，首先將結(jié)果緩沖到內(nèi)存中，然后再寫(xiě)入響應(yīng)中：

[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(); }

現(xiàn)在，在.NET 6中，我們可以使用異步流。

Demo

1.服務(wù)端

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

IAsyncEnumerable實(shí)例采用異步方式迭代寫(xiě)入響應(yīng)中，不再阻塞請(qǐng)求調(diào)用。

需要注意的是，只有使用System.Text.Json進(jìn)行序列化時(shí)，此功能才會(huì)起作用。

2.客戶(hù)端

同樣，我們可以在客戶(hù)端異步接收響應(yīng)，示例代碼如下：

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}"); }

但是，實(shí)際運(yùn)行效果卻是按照同步方式執(zhí)行的：

這是因?yàn)?#xff0c;我們必須使用System.Text.Json提供的專(zhuān)門(mén)方法處理異步流反序列化：

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

需要將DefaultBufferSize設(shè)置較小的值，保證異步迭代及時(shí)返回。

結(jié)論

EF Core支持IAsyncEnumerable查詢(xún)數(shù)據(jù)：

可以將EF Core從數(shù)據(jù)庫(kù)中獲取的數(shù)據(jù)直接使用異步流的方式傳輸?shù)巾憫?yīng)，無(wú)需大量?jī)?nèi)存緩沖數(shù)據(jù)，提高程序性能。

如果你覺(jué)得這篇文章對(duì)你有所啟發(fā)，請(qǐng)關(guān)注我的個(gè)人公眾號(hào)”My IO“

總結(jié)

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

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。