.NET Framework 4.7.2中Microsoft.Data.Services.Client连接池优化咨询

在.NET Framework 4.7.2项目中，使用Microsoft.Data.Services.Client调用内部查询端点的代码示例如下：

var uri = $"http://myEndpoint/someResource?skip=0&take=100";
// MyDataProvider是自动生成的服务引用类，继承自System.Data.Services.Client.DataServiceContext
var result = MyDataProvider.Execute<ProcessOrderWCF>(new Uri(uri), "GET", false)
    ?.ToList();

这段代码功能正常，但在服务器端可复用服务中调用时，每次执行Execute都会新建HTTP连接，高负载场景下会导致服务器性能急剧下降。需要解决减少新建HTTP连接的问题，优先使用现成推荐方案，若无则考虑自定义策略（尽量避免自行实现连接池）。

一、现成方案：复用DataServiceContext实例 #

DataServiceContext本身设计为可复用，内部会依托.NET的ServicePointManager连接池机制实现HTTP连接复用。之前的性能问题大概率是每次调用都新建MyDataProvider实例导致的。

• 核心做法：将MyDataProvider（即DataServiceContext子类）实例设为单例，或在服务范围内复用（比如依赖注入中的单例/请求作用域实例），而非每次调用Execute都新建实例。
• 注意事项：
  • DataServiceContext并非线程安全，不可在多线程环境下共享同一实例，需确保每个线程/请求拥有独立实例，或在单线程场景下复用。
  • 若使用依赖注入，可配置为请求作用域（ASP.NET环境），让同一请求内的所有调用复用同一个DataServiceContext，自然实现连接复用。

二、优化.NET内置连接池配置 #

.NET Framework的ServicePointManager默认维护HTTP连接池，可通过调整参数提升连接复用效率：

• 增大目标端点的最大连接数：

  ServicePointManager.FindServicePoint(new Uri("http://myEndpoint")).ConnectionLimit = 100; // 根据实际负载调整数值
  

• 确保HTTP keep-alive开启（默认已开启，但需服务器端支持）：

  ServicePointManager.SetTcpKeepAlive(true, 30000, 10000); // 间隔30秒发送保活包，超时10秒
  

• 调整连接闲置超时时间，避免连接被过早回收：

  ServicePointManager.FindServicePoint(new Uri("http://myEndpoint")).MaxIdleTime = 60000; // 60秒闲置超时
  

三、自定义策略（无现成方案时） #

如果上述方案无法满足需求，可考虑以下自定义策略：

1. 基于HttpClient的封装替代 #

Microsoft.Data.Services.Client底层依赖HttpWebRequest，而HttpClient本身已优化连接复用。可封装基于HttpClient的OData客户端，替代直接使用DataServiceContext：

// 复用HttpClient单例实例
private static readonly HttpClient _httpClient = new HttpClient();

public async Task<List<ProcessOrderWCF>> GetProcessOrdersAsync(int skip, int take)
{
    var response = await _httpClient.GetAsync($"http://myEndpoint/someResource?skip={skip}&take={take}");
    response.EnsureSuccessStatusCode();
    var content = await response.Content.ReadAsStringAsync();
    // 使用OData兼容的反序列化器转换内容
    return JsonConvert.DeserializeObject<List<ProcessOrderWCF>>(content);
}

• 优点：HttpClient默认复用连接池，无需额外维护。
• 缺点：需自行处理OData查询的序列化/反序列化、请求头配置及错误处理逻辑。

2. 轻量级DataServiceContext对象池（迫不得已时） #

若必须使用DataServiceContext，可实现简单的对象池复用实例：

private readonly ObjectPool<MyDataProvider> _contextPool = new DefaultObjectPool<MyDataProvider>(new DefaultPooledPolicy<MyDataProvider>());

public List<ProcessOrderWCF> ExecuteQuery(int skip, int take)
{
    var context = _contextPool.Get();
    try
    {
        var uri = new Uri($"http://myEndpoint/someResource?skip={skip}&take={take}");
        return context.Execute<ProcessOrderWCF>(uri, "GET", false)?.ToList();
    }
    finally
    {
        // 重置上下文状态后放回池，避免状态污染
        context.DetachAll();
        _contextPool.Return(context);
    }
}

• 注意：放回池前必须重置DataServiceContext的状态（如调用DetachAll()清除跟踪实体），防止不同请求间的状态干扰。

内容的提问来源于stack exchange，提问作者Alberto Chiesa