使用负载均衡器F5创建多个HttpClient连接时出现SocketError

问题描述

这是错误日志中的确切异常。

我有一个要求，我应该在其中创建一组服务调用，并等到所有这些调用都成功完成后再继续执行另一组服务调用。

我有两个服务Service1和Service2。 在2个不同的服务器中有2个Service2实例，我们已经设置了F5（负载均衡器）以平均分配负载。

假设我一次要从Service1到Service2进行10个服务调用，F5将在这两个服务器之间共享这10个调用。即5个调用每个服务器的Service2。

但是我观察到，如果这10个调用中的任何一个花费大量时间来完成它应该做的工作（Service2中要完成的工作有些繁重），那么我会抛出一个套接字异常，并且整个过程都将停止

但是，当我不使用F5负载平衡器而仅使用Service2的1个实例时。然后，无论这10个调用中的任何一个花费多长时间，它都不会引发任何异常。

我不确定这是否与F5配置有关，还是与来自.Net代码的F5建立连接的方式有关。

请仔细阅读以下代码，以了解我要执行的操作，并告诉我是否有任何代码更改可以帮助我解决问题。

for (int i=0 ; i< ReqList.Count;i++)
{
  maxTasks++;
  ClassA reqList = new ClassA();
  reqList = ReqList[i];
  List<ClassA> recsByReq = recs.Where(x => x.ReqId == reqList.ReqtId).ToList();
  ClassC service2Input = new ClassC();
  service2Input.DetaiList = listofRecs;
  service2Input.RecList = recsByReq;
  taskList.Add(_service2.Service2MethodCall(service2Input,service2Resource));
  if(maxTasks == 10 || ReqList.Count == 10 || i==ReqList.Count-1)
  {
    Task.WaitAll(taskList.ToArray(),-1);
    maxTasks = 0;
    taskList.Clear();
  }
                

}

Service2MethodCall是我在其中创建HttpClient以便与第二个服务（即Service2）建立连接的地方

public class Service2: IService2 {
  
private ServiceClient GetService2(string resource) 
{
 return new ServiceClient(_service2BaseUrl,TimeSpan.FromMinutes(60)) 
 {
    Resource = resource,};
}
public async Task Service2MethodCall(ClassC service2Input,string resource) 
{
 try 
 {
   var client = GetService2(resource);
   await     client.PostAsync(JsonConvert.SerializeObject(service2Input).ToString());
 } 
 catch (Exception ex) 
 {
   throw new Exception("The Service encountered an error during the Service2 call for Req ID : " +
        service2Input.RecsList.Find(x => x.ReqId != "").ReqId.ToString(),ex);
 }
}
}

PostAsync（）方法为每个调用创建一个带有HttpClientHandler对象的新HttpClient。

public async Task PostAsync(object data) {
  using(var httpClientHandler = new HttpClientHandler()) {
    httpClientHandler.ServerCertificateCustomValidationCallback = (message,cert,chain,sslPolicyErrors) => {
      if (sslPolicyErrors == SslPolicyErrors.None) {
        return true; //Is valid
      }

      if (cert.GetCertHashString().ToUpper() == _acceptedThumbprint.ToUpper()) {
        return true;
      }
      return false;
    };
    using(var client = new HttpClient(httpClientHandler)) {
      client.DefaultRequestHeaders.Accept.Clear();
      client.DefaultRequestHeaders.Accept.Add(ResponseFormatter.MediaType);
      client.Timeout = Timeout.InfiniteTimeSpan;
      Uri uri = BuildUri();
      if (!String.IsNullOrWhiteSpace(SignatureKey)) {
        client.DefaultRequestHeaders.TryAddWithoutValidation("Authorization",RequestFormatter.GenerateAuthHeaderEncodedUserSignature(uri,AuthUserName,SignatureKey,data));
      }
      //_logger.WriteUsage(client.BaseAddress.ToString());
      HttpResponseMessage response = await RequestFormatter.PostAsync(client,uri,data);
      string content = await response.Content.ReadAsStringAsync();
      try {
        response.EnsureSuccessStatusCode();
      }#
      pragma warning disable CS0168 // The variable 'rex' is declared but never used
      catch (HttpRequestException rex)# pragma warning restore CS0168 // The variable 'rex' is declared but never used
      {
        //_logger.WriteUsage("Response for POST to: {0} did not yield a successful status code. Message: {1}" + uri.ToString() + content);
        throw new ApiHttpException(response.StatusCode,content);
      }
    }
  }
}

我是否可以在代码中做一些事情来一劳永逸地避免这种情况？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）