针对你遇到的「多线程下net-http-persistent连接重置过多」问题，核心根源是net-http-persistent的连接池并非线程安全，多线程共用同一个Faraday实例时，会导致连接竞争、重复创建新连接，最终触发后端的连接限制或本地的连接重置错误。结合你需要持久化连接+异步请求的需求，这里给出几个可落地的解决方案：

1. 为每个线程分配独立的Faraday实例（推荐） #

通过线程局部存储（Thread-local storage）确保每个线程拥有专属的Faraday+net-http-persistent实例，这样每个线程的连接池独立，不会出现跨线程的连接竞争。

代码示例 #

# 封装线程专属的Faraday客户端
def thread_safe_faraday_client
  Thread.current[:faraday_client] ||= Faraday.new(url: "https://your-backend-store.com") do |faraday|
    # 配置net-http-persistent适配器
    faraday.adapter :net_http_persistent do |persistent|
      # 设置连接池大小，根据后端允许的最大并发连接数调整
      persistent.connection_pool_size = 6
      # 配置超时参数，避免连接挂起
      persistent.open_timeout = 10
      persistent.read_timeout = 30
      # 可选：开启调试日志，查看连接复用情况
      # persistent.debug_output = $stdout
    end

    # 添加重试中间件，自动处理连接重置等临时错误
    faraday.request :retry,
      max: 3,                  # 最多重试3次
      interval: 0.5,           # 初始重试间隔0.5秒
      backoff_factor: 2,       # 每次重试间隔翻倍
      exceptions: [Errno::ECONNRESET, Faraday::ConnectionFailed, Faraday::TimeoutError]
  end
end

# 多线程执行请求的示例
entries = (1..20).map { |i| { data: "entry_#{i}" } }
threads = entries.map do |entry|
  Thread.new do
    begin
      response = thread_safe_faraday_client.post(
        "/entries",
        entry.to_json,
        { "Content-Type" => "application/json" }
      )
      puts "Successfully added entry: #{entry[:data]} (status: #{response.status})"
    rescue Faraday::Error => e
      puts "Failed to add entry #{entry[:data]}: #{e.message}"
    end
  end
end

threads.each(&:join)

为什么这能解决问题？ #

每个线程的Faraday实例维护自己的连接池，线程间不会共享连接，既保证了持久化连接的复用（单线程内的请求会复用同一连接），又避免了多线程竞争导致的连接重置。

2. 严格限制连接池大小并优化后端配置 #

即使使用线程专属实例，也要确保所有线程的连接池总大小不超过后端存储系统允许的最大连接数。比如后端允许100个并发连接，你有10个工作线程，那么每个线程的连接池大小设为10即可。

同时，建议检查后端存储系统的连接超时配置：

• 调整后端的keepalive_timeout，确保持久化连接不会被过早关闭
• 增大后端的最大连接数限制（如果有调整权限）

3. 更换为支持异步+持久化的线程安全适配器 #

如果不想维护线程专属实例，可以尝试使用faraday-httpclient适配器，它原生支持线程安全的持久化连接，且对异步场景更友好：

代码示例 #

require 'faraday/httpclient'

Faraday.new(url: "https://your-backend-store.com") do |faraday|
  faraday.adapter :httpclient do |client|
    client.connection_timeout = 10
    client.receive_timeout = 30
    # httpclient默认启用持久化连接，且线程安全
    client.keep_alive_timeout = 300 # 设置连接保持时间
  end

  # 同样添加重试中间件处理临时错误
  faraday.request :retry,
    max: 3,
    exceptions: [Errno::ECONNRESET, Faraday::ConnectionFailed]
end

关键注意事项 #

• 不要跨线程共享Faraday实例：除非适配器明确标注线程安全，否则共享实例必然导致连接竞争问题
• 监控连接复用情况：开启net-http-persistent的调试日志，查看日志中是否有Reusing connection的字样，验证连接是否被正确复用
• 避免过度重试：重试次数过多可能导致后端压力过大，结合业务场景调整重试策略

内容的提问来源于stack exchange，提问作者Carla Urrea Stabile