Trung tâm cá nhân
sách gpt4 ai đã đi

.NET Best Practices: WebAPI trả về IAsyncEnumerable để cải thiện hiệu suất

In lại 作者：撒哈拉 更新时间：2025-02-08 13:15:54 59 4
mua khóa gpt4 Nike

什么是IAsyncEnumerable

IAsyncEnumerable 是 .NET 中用于表示异步数据流的接口.

它允许你逐个异步地获取数据项，而不是将所有数据一次性加载到内存中。这样可以减少内存占用，尤其在处理大量数据时更加高效.

与 IEnumerable 不同，IEnumerable 是同步的，要求所有数据在返回之前就加载完成.

而 IAsyncEnumerable 是异步的，支持在数据流被请求时逐步加载，适合处理从数据库或网络等源异步获取的数据.

Ví dụ:

public async IAsyncEnumerable GetNumbersAsync() { for (int i = 0; i < 10; i++) { await Task.Delay(100); // 模拟异步操作 yield return i; } }

好处

减少内存占用：IAsyncEnumerable 逐步加载数据，避免了需要将所有数据一次性加载到内存中。对于大数据量的查询，能显著减少内存压力.

提升响应性能：在 WebAPI 中，返回 IAsyncEnumerable 可以让客户端在获取部分数据时立即开始处理，而无需等待所有数据都加载完成。这使得响应时间更短，提升用户体验.

避免阻塞操作：使用 async/await 使得 WebAPI 不会被同步阻塞操作所拖慢，能够更好地处理并发请求.

以 WebAPI + EFCore 举例

假设我们需要通过 Entity Framework Core 从数据库中查询大量记录.

如果我们一次性加载所有数据，可能会导致内存占用过高，甚至影响性能。使用 IAsyncEnumerable，我们可以逐个获取数据.

Mã ví dụ:

public class ProductController : ControllerBase { private readonly ApplicationDbContext _context; public ProductController(ApplicationDbContext context) { _context = context; } [HttpGet("products")] public async IAsyncEnumerable GetProductsAsync() { await foreach (var product in _context.Products.AsAsyncEnumerable()) { yield return product; } } }

在这个例子中，AsAsyncEnumerable() 方法将 DbSet 转换成一个异步数据流，await foreach 循环逐个从数据库中异步获取数据并返回，避免了内存占用过多.

以 WebAPI + HTTPClient 举例

在 WebAPI 中，你可能需要调用其他服务或外部 API 来获取数据。使用 IAsyncEnumerable 可以使得调用返回的数据逐步加载，避免等待整个请求完成后再返回.

Mã ví dụ:

public class ExternalApiController : ControllerBase { private readonly HttpClient _httpClient; public ExternalApiController(HttpClient httpClient) { _httpClient = httpClient; } [HttpGet("external-data")] public async IAsyncEnumerable GetExternalDataAsync() { var response = await _httpClient.GetAsync("https://api.example.com/data"); response.EnsureSuccessStatusCode(); var stream = await response.Content.ReadAsStreamAsync(); using (var reader = new StreamReader(stream)) { string? line; while ((line = await reader.ReadLineAsync()) != null) { yield return line; } } } }

在这个例子中，我们通过 HTTPClient 请求外部 API 数据，并使用 IAsyncEnumerable 返回每一行数据，允许客户端逐步处理数据，而无需等待所有数据都加载完毕.

客户端怎么处理 IAsyncEnumerable

客户端接收到 IAsyncEnumerable 数据流后，可以使用异步迭代器 await foreach 来逐步处理数据.

这样可以在数据流逐步传输过程中及时处理和显示数据，而不必等待全部数据加载完成.

C# 客户端代码：
public class ProductClient { private readonly HttpClient _httpClient; public ProductClient(HttpClient httpClient) { _httpClient = httpClient; } public async Task GetProductsAsync() { var response = await _httpClient.GetAsync("https://example.com/products"); response.EnsureSuccessStatusCode(); await foreach (var product in response.Content.ReadFromJsonAsync<>>()) { Console.WriteLine(product.Name); } } }
JavaScript 客户端处理：

在 JavaScript 中，客户端可以使用 fetch API 和流（Streams）来逐步处理数据。WebAPI 返回的数据流可以通过 Response.body.getReader() 来读取并逐步消费.

async function fetchProducts() { const response = await fetch('https://example.com/products'); const reader = response.body.getReader(); const decoder = new TextDecoder(); let done = false; let value = ''; while (!done) { const { done: chunkDone, value: chunk } = await reader.read(); done = chunkDone; value += decoder.decode(chunk, { stream: true }); console.log(value); // 逐步输出数据 } }

通过上述方式，JavaScript 客户端可以逐步处理 WebAPI 返回的异步流，提升用户体验和响应速度.

最后此篇关于.NET最佳实践：webapi返回IAsyncEnumerable提升性能的文章就讲到这里了,如果你想了解更多关于.NET最佳实践：webapi返回IAsyncEnumerable提升性能的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

59 4 0
Bài viết được đề xuất: Tiêm SQL tiêm truy vấn chung
Bài viết được đề xuất: Sử dụng Huggingface
Bài viết được đề xuất: Tôi không hiểu nổi, tại sao DeepSeek lại đột nhiên ngang hàng với GPT?
Bài viết được đề xuất: 12. Cấu hình hoạt động cụm Redis (sơ đồ rất chi tiết, mô tả chi tiết kèm ảnh chụp màn hình)
Sa mạc Sahara
Hồ sơ cá nhân

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá Didi Taxi miễn phí
Mã giảm giá Didi Taxi
Các bài viết nóng hổi trên toàn bộ trang web
Giấy chứng nhận ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com