使用Device Client向IoT Hub发送数据响应慢、TCP连接超限问题咨询

• 当前的DeviceClient初始化方式完全不符合高并发场景的使用规范，是导致TCP连接耗尽的直接原因：
  • 每次调用SendDataToIoTHub方法都会新建一个DeviceClient实例，且用完立即通过using释放，每个DeviceClient底层会独立创建到IoT Hub的AMQP/MQTT/HTTP TCP连接，短时间3000~4000次请求意味着每秒就要创建几十到上百个TCP连接，而TCP连接释放后还会进入TIME_WAIT状态不会立即回收，很快就会触发系统TCP连接数上限。
  • DeviceClient本身是线程安全的设计，官方明确要求单设备对应单DeviceClient长期复用，而非每次请求新建。

方案1：单设备固定DeviceClient复用（适合设备量<1000的场景） #

用并发字典缓存每个设备对应的DeviceClient实例，避免重复创建：

// 全局静态缓存，程序生命周期内复用
private static readonly ConcurrentDictionary<string, DeviceClient> _deviceClientCache = new ConcurrentDictionary<string, DeviceClient>();

public async Task SendDataToIoTHub(Message eventMessage, string deviceId, string deviceKey)
{
    // 设备ID作为缓存键
    var cacheKey = deviceId;
    if (!_deviceClientCache.TryGetValue(cacheKey, out var deviceClient))
    {
        string connectionString = $"HostName={IoTHubHostname};DeviceId={deviceId};SharedAccessKey={deviceKey}";
        // 优先用AMQP协议，支持单TCP连接多路复用多设备消息
        deviceClient = DeviceClient.CreateFromConnectionString(connectionString, TransportType.Amqp);
        _deviceClientCache.TryAdd(cacheKey, deviceClient);
    }

    await deviceClient.SendEventAsync(eventMessage);
}

• 若存在设备密钥更新场景，可以加缓存失效逻辑：捕获到认证错误时删除对应缓存的DeviceClient，下次请求自动重建即可。

方案2：服务端SDK批量发送（适合设备量极大的场景） #

如果对接的设备量过万，不适合缓存大量DeviceClient实例，可以改用IoT Hub服务端SDK的ServiceClient发送消息，不需要为每个设备创建独立DeviceClient：

// 全局复用单个ServiceClient实例，仅需初始化1次
private static readonly ServiceClient _serviceClient = ServiceClient.CreateFromConnectionString(你的IoTHub服务端连接字符串, TransportType.Amqp);

public async Task SendDataToIoTHub(Message eventMessage, string deviceId)
{
    // 直接指定目标设备ID发送，不需要传入设备密钥
    await _serviceClient.SendAsync(deviceId, eventMessage);
}

该方案仅需要维护1个到IoT Hub的TCP连接，完全不存在连接耗尽问题，性能最高，仅需你持有对应IoT Hub的服务端消息发送权限即可。

额外优化建议 #

• 若请求量持续走高，可以添加本地内存队列做缓冲，批量发送消息到IoT Hub，进一步降低IO开销。
• 可以通过SetRetryPolicy方法为客户端配置合理的重试策略，避免网络波动导致的消息发送失败。

内容的提问来源于stack exchange，提问作者Uchit Nair