面对Azure耐用功能的超时问题

Question

我正在使用Azure耐用功能来执行一些批处理处理操作。阅读，过程中的某些内容，通知 预计将执行这些操作的次数为10次

• ，读，处理
• ，通知读，通知
• ，处理，通知
• 〜10
• 次
• 。
• ..

读 这个数字更大，说100 我收到此错误消息： “超时到期。从池中获得连接之前经过的超时期。这可能发生了，因为使用了所有汇集的连接并达到了最大池尺寸。”

负责使用的连接的功能处理程序如下所示：

public async Task<HttpResponseMessage> HandleAsync(string uri, string body, int retryCount)
{
    Ensure.That(uri, nameof(uri)).IsNotNull();
    Ensure.That(uri, nameof(uri)).IsNotEmptyOrWhiteSpace();
    Ensure.That(body, nameof(body)).IsNotNull();
    Ensure.That(body, nameof(body)).IsNotEmptyOrWhiteSpace();
    var iteration = 0;
    HttpResponseMessage response;
    do
    {
        var client = _httpClientFactory.CreateClient();
        var (key, value) = _tokenProvider.GetAuthenticationHeader(_appSetting.PayloadConfig).GetAwaiter().GetResult();
        client.DefaultRequestHeaders.Add(key, value);
        client.DefaultRequestHeaders.Add("api-version","1.0");

        var msg = new HttpRequestMessage(HttpMethod.Post, uri);
        msg.Headers.Add("Accept", "*/*");
        msg.Content = new StringContent(body);
        msg.Content.Headers.ContentType = new MediaTypeHeaderValue("application/json");

        response = await client.SendAsync(msg);
        iteration++;
    } while (!response.IsSuccessStatusCode && iteration < retryCount);
    await response.EnsureSuccessStatusCodeAsync();
    return response;
}

如何解决此问题以避免这种饥饿？

我尝试的是编辑此池的最大连接数

private HttpClient Client
        {
            get
            {
                var socketsHandler = new SocketsHttpHandler
                {
                    PooledConnectionLifetime = TimeSpan.FromMinutes(10),
                    PooledConnectionIdleTimeout = TimeSpan.FromMinutes(5),
                    MaxConnectionsPerServer = 100
                };
                
                var _httpClient = new HttpClient(socketsHandler);
                return _httpClient;
            }
        }

，但是使用客户端

public async Task<HttpResponseMessage> HandleAsync(string uri, string body, int retryCount)
        {
            Ensure.That(uri, nameof(uri)).IsNotNull();
            Ensure.That(uri, nameof(uri)).IsNotEmptyOrWhiteSpace();
            Ensure.That(body, nameof(body)).IsNotNull();
            Ensure.That(body, nameof(body)).IsNotEmptyOrWhiteSpace();
            var iteration = 0;
            HttpResponseMessage response;
            do
            {
                var (key, value) = _tokenProvider.GetAuthenticationHeader(_appSetting.PayloadConfig).GetAwaiter().GetResult();
                Client.DefaultRequestHeaders.Add(key, value);
                Client.DefaultRequestHeaders.Add("api-version","1.0");

                var msg = new HttpRequestMessage(HttpMethod.Post, uri);
                msg.Headers.Add("Accept", "*/*");
                msg.Content = new StringContent(body);
                msg.Content.Headers.ContentType = new MediaTypeHeaderValue("application/json");

                response = await Client.SendAsync(msg);
                iteration++;
            } while (!response.IsSuccessStatusCode && iteration < retryCount);
            await response.EnsureSuccessStatusCodeAsync();
            return response;
        }

，我仍面临同一问题
谁能在这里引导我

Answer 1

我建议您每次都不会使用var client = _httpclientfactory.createclient（）;来创建HTTPCLIENT。
将其移出循环。
并且不要使用Defaultrequestheaders，只需将其设置为请求。