C# Anthropic连接超时的原因及解决方案

using System;
using System.Net.Http;
using System.Threading.Tasks;

public class AnthropicClient
{
    private readonly HttpClient _httpClient;
    private const string ApiEndpoint = "https://api.anthropic.com/v1/complete";
    
    public AnthropicClient()
    {
        _httpClient = new HttpClient
        {
            Timeout = TimeSpan.FromSeconds(30) // 默认超时设置
        };
    }

    public async Task<string> SendRequestAsync(string prompt)
    {
        try
        {
            var content = new StringContent($"{{ \"prompt\": \"{prompt}\" }}");
            var response = await _httpClient.PostAsync(ApiEndpoint, content);
            return await response.Content.ReadAsStringAsync();
        }
        catch (TaskCanceledException ex) when (ex.InnerException is TimeoutException)
        {
            // 处理超时异常
            return "Request timed out";
        }
    }
}

_httpClient.Timeout = TimeSpan.FromSeconds(45);

using Polly;

var retryPolicy = Policy
    .Handle<HttpRequestException>()
    .Or<TaskCanceledException>()
    .WaitAndRetryAsync(3, retryAttempt => 
        TimeSpan.FromSeconds(Math.Pow(2, retryAttempt)));

await retryPolicy.ExecuteAsync(async () => 
{
    // 请求代码
});

var circuitBreaker = Policy
    .Handle<HttpRequestException>()
    .CircuitBreakerAsync(5, TimeSpan.FromMinutes(1));

public async Task<bool> CheckServiceHealthAsync()
{
    try
    {
        var response = await _httpClient.GetAsync("https://api.anthropic.com/health");
        return response.IsSuccessStatusCode;
    }
    catch
    {
        return false;
    }
}

var socketsHandler = new SocketsHttpHandler
{
    PooledConnectionLifetime = TimeSpan.FromMinutes(5),
    PooledConnectionIdleTimeout = TimeSpan.FromMinutes(1)
};

_httpClient = new HttpClient(socketsHandler);

var compressedContent = new GZipContent(originalContent);
_httpClient.DefaultRequestHeaders.Add("Content-Encoding", "gzip");