构建高性能C# API的终极指南：从异步编程到限流压缩全解析

using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Http;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

var builder = WebApplication.CreateBuilder(args);
var app = builder.Build();
app.MapGet("/hello", () => "Hello, World!");
app.Run();

app.MapGet("/data", async () =>
{
    await Task.Delay(); // 模拟I/O操作
    return Results.Ok("Data retrieved successfully.");
});

public classRateLimitingMiddleware
{
    privatestatic Dictionary<string, DateTime> _requestTimestamps = new();
    privatereadonly RequestDelegate _next;

    public RateLimitingMiddleware(RequestDelegate next) => _next = next;

    public async Task InvokeAsync(HttpContext context)
    {
        var ip = context.Connection.RemoteIpAddress?.ToString();
        if (ip != null && _requestTimestamps.TryGetValue(ip, outvar lastRequest))
        {
            if ((DateTime.UtcNow - lastRequest).TotalSeconds < )
            {
                context.Response.StatusCode = ;
                await context.Response.WriteAsync("Rate limit exceeded.");
                return;
            }
        }
        _requestTimestamps[ip] = DateTime.UtcNow;
        await _next(context);
    }
}

app.MapGet("/cached-data", (IMemoryCache cache) =>
{
    if (!cache.TryGetValue("key", out string value))
    {
        value = "Hello, Cached World!";
        cache.Set("key", value, TimeSpan.FromMinutes());
    }
    return value;
});

using Microsoft.AspNetCore.ResponseCompression;

var builder = WebApplication.CreateBuilder(args);
builder.Services.AddResponseCompression();
var app = builder.Build();
app.UseResponseCompression();
app.MapGet("/compressed", () => "This response is compressed!");
app.Run();

[Benchmark]
public void FetchData()
{
    var result = _client.GetAsync("/data").Result;
}

请求接入层 → 异步处理层 → 缓存加速层 → 限流保护层 → 压缩传输层