Ruby TCPServer间歇性未接收接口TCP数据包问题求助

我搭建了一个Ruby TCPServer，用于监听多TCP POST请求，服务运行在线程块内，但存在间歇性无法接收TCP数据包的问题——通过tcpdump/Wireshark能捕获到目标数据包，但Ruby服务并未处理这些请求。

丢包示例：

• 来源IP：10.0.225.43
• 发生时间：2022年7月27日20:56:57、20:39:31

当前使用的核心代码：

server = TCPServer.new(7207)
Thread.start(server.accept) do |client|
  # process packet, send to AWS SQS
  raw = ""
  while (line = client.gets)
    raw += line
  end
  sender = client.peeraddr
  text = raw.unpack1("H*")
  message_body = { payload: text, rx_at: Time.current, sender:}
  puts "#{Time.current} : --- New uplink #{message_body}"
  # send message to AWS SQS
  client.close
end

问题根源分析 #

1. 连接监听逻辑错误：原代码只在启动时调用一次server.accept，只能处理第一个连接。后续的连接请求虽然能完成TCP握手（所以tcpdump能抓到包），但服务端根本没去接收这些新连接，自然不会处理数据包。
2. 读取逻辑阻塞风险：client.gets依赖换行符作为读取结束标记，如果客户端发送的数据包不含换行符，这个循环会一直阻塞，线程被挂起无法释放，进一步加剧连接处理不及时的问题。
3. 语法错误：message_body哈希里的sender:缺少对应值，属于语法问题，可能导致处理逻辑崩溃。

修复后的代码 #

server = TCPServer.new(7207)

# 持续监听新连接，每个连接分配独立线程处理
loop do
  Thread.start(server.accept) do |client|
    begin
      raw = ""
      # 按字节读取数据，不依赖换行符，避免阻塞
      while chunk = client.read(4096)
        raw += chunk
      end

      sender = client.peeraddr
      text = raw.unpack1("H*")
      message_body = { payload: text, rx_at: Time.current, sender: sender }
      puts "#{Time.current} : --- New uplink #{message_body}"
      
      # 在这里执行发送消息到AWS SQS的逻辑
    rescue StandardError => e
      puts "#{Time.current} : 处理连接出错: #{e.message}"
    ensure
      client.close rescue nil # 确保连接被关闭，避免资源泄漏
    end
  end
end

关键修复点 #

• 添加循环监听：用loop do包裹连接接收逻辑，让服务端持续处理新的连接请求。
• 替换读取方式：用client.read(4096)替代gets，按固定字节读取，适配无换行符的数据包格式。
• 异常处理：通过begin-rescue-ensure确保即使处理出错，连接也能正常关闭，防止资源泄漏。
• 修正语法错误：补全哈希中sender的对应值，避免逻辑崩溃。

额外优化建议 #

• 线程池控制：如果并发量高，无限制创建线程会耗尽系统资源，可使用concurrent-ruby库的线程池来限制线程数量。
• 设置连接超时：给客户端连接添加接收超时，避免空闲连接占用资源：

  client.setsockopt(Socket::SOL_SOCKET, Socket::SO_RCVTIMEO, [5, 0].pack("l_2")) # 5秒接收超时
  

• 增强日志：记录连接建立时间、数据包大小等细节，方便后续排查问题。

内容的提问来源于stack exchange，提问作者Ruby Dev