5

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

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

当前的服务器实现循环侦听客户端，当有传入连接时触发一个新线程并从此套接字读取文件路径。它非常愚蠢，但在使用非持久连接时效果很好 - 每个连接一个请求。

但他们应该坚持不懈。

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

谷歌搜索一些解决方案——除了被彻底建议避免使用 Timeout 模块——我看过很多关于 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

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

解决方案

我最终使用了 IO.select（在查看 webrick 代码时受到启发）。你查一下这里的最终版本（lib/http/server/client_handler.rb）

4

1 回答 1

0

您应该实现诸如心跳包之类的东西。客户端应在几秒/分钟后发送特殊数据包，以确保服务器不会使客户端的连接超时。您只需避免在此调用中执行任何操作。

于 2013-04-18T10:08:03.073 回答