ruby - 如何正确处理持久的 TCP 套接字连接(模拟 HTTP 服务器)？

Question

因此，我正在尝试使用套接字和 Ruby 模拟一些基本的 HTTP 持久连接 - 用于大学类(class)。

重点是构建一个服务器 - 能够处理多个客户端 - 接收文件路径并返回文件内容 - 就像 HTTP GET。

当前的服务器实现循环监听客户端，当有传入连接时触发一个新线程并从此套接字读取文件路径。这非常愚蠢，但在处理非持久连接时工作正常 - 每个连接一个请求。

但他们应该坚持不懈。

这意味着客户端不应该担心关闭连接。在非持久版本中，服务器回应响应并关闭连接 - 再见客户端，再见。但是持久化意味着服务器线程应该循环并等待更多的传入请求，直到......好吧，直到没有更多的请求。服务器怎么知道的？它没有!需要某种超时。我尝试使用 Ruby 的超时来做到这一点，但没有成功。

谷歌搜索一些解决方案 - 除了被彻底建议避免使用超时模块 - 我已经看到很多关于 IO.select 方法的帖子，应该比使用线程和东西更好地处理这个套接字等待问题(这真的听起来很酷，考虑到 Ruby 线程(不)是如何工作的)。我试图在这里了解 IO.select 的工作原理，但仍然无法使其在当前情况下工作。

所以我主要问两件事:

• 如何在服务器端有效地解决这个超时问题，使用一些基于线程的解决方案、低级套接字选项或一些 IO.select 魔法？

• 客户端如何知道服务器端已经关闭了连接？

这是服务器的当前代码:

require 'date'
module Sockettp
  class Server
    def initialize(dir, port = Sockettp::DEFAULT_PORT)
      @dir = dir
      @port = port
    end

    def start
      puts "Starting Sockettp server..."
      puts "Serving #{@dir.yellow} on port #{@port.to_s.green}"

      Socket.tcp_server_loop(@port) do |socket, client_addrinfo|
        handle socket, client_addrinfo
      end
    end

    private
    def handle(socket, addrinfo)
      Thread.new(socket) do |client|
        log "New client connected"
        begin
          loop do
            if client.eof?
              puts "#{'-' * 100} end connection"
              break
            end

            input = client.gets.chomp

            body = content_for(input)

            response = {}

            if body
              response.merge!({
                status: 200,
                body: body
              })
            else
              response.merge!({
                status: 404,
                body: Sockettp::STATUSES[404]
              })
            end

            log "#{addrinfo.ip_address} #{input} -- #{response[:status]} #{Sockettp::STATUSES[response[:status]]}".send(response[:status] == 200 ? :green : :red)

            client.puts(response.to_json)
          end
        ensure
          socket.close
        end
      end
    end

    def content_for(path)
      path = File.join(@dir, path)

      return File.read(path) if File.file?(path)
      return Dir["#{path}/*"] if File.directory?(path)
    end

    def log(msg)
      puts "#{Thread.current} -- #{DateTime.now.to_s} -- #{msg}"
    end
  end
end

更新

我能够使用 IO.select 方法模拟超时行为，但是当结合几个线程来接受新连接和另一个线程来处理请求时，实现感觉不太好。并发使情况变得疯狂和不稳定，除非我能找到使用此解决方案的更好方法，否则我可能不会坚持使用它。

更新 2

似乎超时仍然是处理这个问题的最佳方式。我会坚持下去，直到找到更好的选择。我仍然不知道如何处理僵尸客户端连接。

解决方案

我最终使用了 IO.select(在查看 webrick 代码时受到启发)。你查查最终版here (lib/http/server/client_handler.rb)

Answer 1

你应该实现像心跳包这样的东西。客户端应该在几秒/分钟后发送特殊的数据包，以确保服务器不会超时连接客户端。你只是避免在这个调用中做任何事情。