欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

C#實現(xiàn)Http請求的多種方案

 更新時間:2025年07月24日 11:02:18   作者:code_shenbing  
在現(xiàn)代應用中,HTTP 請求是與 API 服務交互的核心方式,本文將系統(tǒng)講解 C# 實現(xiàn) HTTP 請求的多種方案,涵蓋從基礎(chǔ)用法到企業(yè)級高性能實踐(支持 .NET 5+),需要的朋友可以參考下

一、基礎(chǔ) HTTP 請求方法

1. ??HttpClient 基礎(chǔ)用法?

// GET 請求示例
async Task<string> GetDataAsync(string url)
{
    using var httpClient = new HttpClient();
    HttpResponseMessage response = await httpClient.GetAsync(url);
    response.EnsureSuccessStatusCode();
    return await response.Content.ReadAsStringAsync();
}
 
// POST 請求示例
async Task PostDataAsync(string url, object data)
{
    using var httpClient = new HttpClient();
    var json = JsonSerializer.Serialize(data);
    var content = new StringContent(json, Encoding.UTF8, "application/json");
    var response = await httpClient.PostAsync(url, content);
    response.EnsureSuccessStatusCode();
}

警告:不要每次請求創(chuàng)建新 HttpClient!這會導致:

  • 端口耗盡 (TIME_WAIT 狀態(tài))
  • DNS 更新延遲
  • 連接池無法復用

二、高性能 HTTP 客戶端實踐

1. ??IHttpClientFactory 最佳實踐?

// 1. Startup 注冊服務
services.AddHttpClient("FinanceAPI", client => {
    client.BaseAddress = new Uri("https://api.finance.com");
    client.Timeout = TimeSpan.FromSeconds(15);
    client.DefaultRequestHeaders.Add("Accept", "application/json");
});
 
// 2. 控制器中使用
public class DataController : Controller
{
    private readonly IHttpClientFactory _factory;
    
    public DataController(IHttpClientFactory factory) => _factory = factory;
 
    public async Task<IActionResult> GetStockData()
    {
        var client = _factory.CreateClient("FinanceAPI");
        var response = await client.GetAsync("/stocks/MSFT");
        // ...
    }
}

2. ??HTTP/2 連接復用?

var handler = new SocketsHttpHandler
{
    PooledConnectionLifetime = TimeSpan.FromMinutes(5),
    EnableMultipleHttp2Connections = true
};
 
var client = new HttpClient(handler)
{
    DefaultRequestVersion = HttpVersion.Version20,
    DefaultVersionPolicy = HttpVersionPolicy.RequestVersionExact
};

3. ??流式處理大響應?

// 避免大響應阻塞內(nèi)存
async Task ProcessLargeResponse(string url)
{
    using var client = new HttpClient();
    using var response = await client.GetAsync(url, HttpCompletionOption.ResponseHeadersRead);
    using var stream = await response.Content.ReadAsStreamAsync();
    
    await using var buffer = new BufferedStream(stream);
    using var reader = new StreamReader(buffer);
    
    while (!reader.EndOfStream)
    {
        var line = await reader.ReadLineAsync();
        ProcessLine(line);  // 逐行處理
    }
}

三、高級場景實現(xiàn)

1. ??自定義重試策略?

// 指數(shù)退避重試器
async Task<T> ExecuteWithRetry<T>(Func<Task<T>> action, int maxRetries = 3)
{
    int retryCount = 0;
    while (true)
    {
        try
        {
            return await action();
        }
        catch (HttpRequestException ex) when (ex.StatusCode == HttpStatusCode.TooManyRequests)
        {
            if (retryCount++ >= maxRetries) throw;
            var delay = TimeSpan.FromSeconds(Math.Pow(2, retryCount));
            await Task.Delay(delay);
        }
    }
}
 
// 使用示例
var data = await ExecuteWithRetry(() => GetDataAsync("https://unstable-api.com/data"));

2. ??動態(tài)請求頭簽名?

// 安全 API 調(diào)用簽名
async Task SendSignedRequest(string url)
{
    var handler = new CustomSignatureHandler();
    var client = new HttpClient(handler);
    // ... 正常調(diào)用
}
 
class CustomSignatureHandler : DelegatingHandler
{
    protected override async Task<HttpResponseMessage> SendAsync(
        HttpRequestMessage request,
        CancellationToken cancelToken)
    {
        // 1. 獲取時間戳
        var timestamp = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds();
        
        // 2. 生成簽名
        var signData = $"{request.Method}{request.RequestUri}{timestamp}{API_SECRET}";
        var signature = HMACSHA256.Hash(signData);
        
        // 3. 添加安全頭
        request.Headers.Add("X-Timestamp", timestamp.ToString());
        request.Headers.Add("X-Signature", Convert.ToBase64String(signature));
        
        return await base.SendAsync(request, cancelToken);
    }
}

四、性能優(yōu)化策略

1. 連接管理優(yōu)化

??參數(shù)????推薦值????作用??
MaxConnectionsPerServer50-100控制單個主機最大連接數(shù)
PooledConnectionIdleTimeout1-2 分鐘空閑連接保持時間
PooledConnectionLifetime5-10 分鐘連接最大存活時間

2. 響應處理優(yōu)化技巧

// 高效 JSON 反序列化
async Task<T> ParseJsonResponse<T>(HttpResponseMessage response)
{
    // 使用流式 API 避免大對象分配
    await using var stream = await response.Content.ReadAsStreamAsync();
    return await JsonSerializer.DeserializeAsync<T>(stream, new JsonSerializerOptions
    {
        PropertyNameCaseInsensitive = true,
        DefaultBufferSize = 8192  // 8KB 緩沖區(qū)
    });
}
 
// 使用 ArrayPool 處理二進制響應
async Task ProcessBinaryResponse(string url)
{
    var response = await _httpClient.GetAsync(url);
    var buffer = ArrayPool<byte>.Shared.Rent(1024 * 64);
    
    try
    {
        await using var stream = await response.Content.ReadAsStreamAsync();
        int bytesRead;
        while ((bytesRead = await stream.ReadAsync(buffer)) > 0)
        {
            ProcessChunk(new ReadOnlySpan<byte>(buffer, 0, bytesRead));
        }
    }
    finally
    {
        ArrayPool<byte>.Shared.Return(buffer);
    }
}

五、常見問題解決方案

1. DNS 更新問題

// 強制刷新 DNS 緩存
var handler = new SocketsHttpHandler
{
    PooledConnectionLifetime = TimeSpan.FromMinutes(5),  // 設(shè)置連接生命周期
    PooledConnectionIdleTimeout = TimeSpan.FromSeconds(30)
};

2. 證書驗證處理

// 開發(fā)環(huán)境忽略證書錯誤(生產(chǎn)環(huán)境禁用?。?
var handler = new HttpClientHandler
{
    ServerCertificateCustomValidationCallback = (_, _, _, _) => true
};

3. 多部分表單上傳

async Task UploadFile(string url, string filePath)
{
    using var content = new MultipartFormDataContent();
    using var fileStream = File.OpenRead(filePath);
    
    content.Add(new StreamContent(fileStream), "file", "data.zip");
    content.Add(new StringContent("2024-report"), "description");
    
    var response = await _httpClient.PostAsync(url, content);
    response.EnsureSuccessStatusCode();
}

六、性能監(jiān)控與診斷

1. HttpClient 指標監(jiān)控

# 查看連接池狀態(tài)
dotnet-counters monitor -n MyApp System.Net.Http

2. 請求跟蹤

// 添加日志記錄器
services.AddHttpClient("LoggingClient")
    .ConfigurePrimaryHttpMessageHandler(() => new LoggingHandler(new SocketsHttpHandler()));
 
class LoggingHandler : DelegatingHandler
{
    protected override async Task<HttpResponseMessage> SendAsync(
        HttpRequestMessage request, CancellationToken cancellationToken)
    {
        var stopwatch = Stopwatch.StartNew();
        try 
        {
            return await base.SendAsync(request, cancellationToken);
        }
        finally
        {
            _logger.LogInformation($"{request.Method} {request.RequestUri} took {stopwatch.ElapsedMilliseconds}ms");
        }
    }
}

最佳實踐總結(jié)??:

  1. ??連接管理??:始終重用 HttpClient,通過工廠管理生命周期
  2. ??協(xié)議選擇??:啟用 HTTP/2 提升并發(fā)性能(尤其在高延遲網(wǎng)絡)
  3. ??資源控制??:流式處理響應,避免大內(nèi)存分配
  4. ??彈性策略??:實現(xiàn)重試/熔斷機制(推薦使用 Polly)
  5. ??監(jiān)控保障??:持續(xù)跟蹤請求延遲和錯誤率

??性能對比??:

??場景??原始方式優(yōu)化方式提升幅度
1000次連續(xù)請求28秒9.2秒3倍
10MB JSON 響應1.2秒0.4秒3倍
高并發(fā)連接350 QPS1200 QPS3.4倍

以上就是C#實現(xiàn)Http請求的多種方案的詳細內(nèi)容,更多關(guān)于C#實現(xiàn)Http請求的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

最新評論