ruby - 如何使用 read、readpartial 和 read_nonblock 从 ruby​​ 中的 TCPServer 套接字读取

Question

我有一个关于从套接字读取以及如何在 Unicorn 或 Mongrel 等 Ruby 服务器上进行管理的两部分问题

1. 我了解到，从套接字读取与读取文件不同，并且没有发送明显的 EOF 消息，并且数据是无穷无尽的流。那么你怎么知道什么时候停止阅读呢？例如，在这种情况下，当我通过浏览器访问我的服务器时，我的 TCPServerhttp://localhost:9799会在没有更多数据要读取后挂起，并且也不会抛出 EOFError。

require 'socket'

READ_CHUNK = 1024
socket = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM)
addr = Socket.pack_sockaddr_in(9799, '127.0.0.1')
socket.bind(addr)
socket.listen(Socket::SOMAXCONN)
socket.setsockopt(:SOCKET, :REUSEADDR, true)

puts "Server is listening on port = 9799"
loop do 
    connection, addr_info = socket.accept
    data_buffer = ""

    loop do
        begin
            connection.read_nonblock(READ_CHUNK, data_buffer)
            puts "Buffer = #{data_buffer}"
        rescue Errno::EAGAIN => e
            IO.select([connection])         
            retry
        rescue EOFError
            break
        end
    end
    connection.write("HTTP/1.1 200 \r\n")
    connection.write("Content-Type: text/html\r\n")
    connection.write("Status 200 \r\n")
    connection.write("Connection: close \r\n")
    connection.write("Hello World \r\n")
    connection.close
end

我想知道 Ruby 服务器使用的最佳实践/标准方法是什么。我看到 Unicorn 使用来自kgio库的 read_nonblock 而 mongrel 使用 readpartial （我不确定这些，但通过代码，我觉得这是采用的方法。）即使检查 \r\n 服务器如何知道输入完成。可以解释应该如何做到这一点（我认为gets这不是方法 - 它带有read, readpartial, read_nonblock）。

2）。我真的很感激关于如何在独角兽或乘客等服务器中实现这一点的几行

谢谢你。

Answer 1

它在这里的独角兽中完成 https://github.com/defunkt/unicorn/blob/master/lib/unicorn/http_request.rb#L69-L71

有add_parse方法（阅读上述方法的评论） https://github.com/defunkt/unicorn/blob/master/ext/unicorn_http/unicorn_http.rl#L760-L778

也看看这里的一些解释http://www.ruby-forum.com/topic/2267632#1014288

这是您使用 http_parser.rb https://gist.github.com/4136962的工作代码

gem install http_parser.rb

require 'socket'
require "http/parser"


READ_CHUNK = 1024 * 4
socket = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM)
addr = Socket.pack_sockaddr_in(9799, '127.0.0.1')
socket.bind(addr)
socket.listen(Socket::SOMAXCONN)
socket.setsockopt(:SOCKET, :REUSEADDR, true)

puts "Server is listening on port = 9799"
loop do
    connection, addr_info = socket.accept

    parser = Http::Parser.new
    begin
      data = connection.readpartial(READ_CHUNK)
      puts "Buffer = #{data}"
      parser << data
    end until parser.headers

    connection.write("HTTP/1.1 200 \r\n")
    connection.write("Content-Type: text/html\r\n")
    connection.write("Status 200 \r\n")
    connection.write("Connection: close \r\n")
    connection.write("\r\n\r\n")
    connection.write("Hello World \r\n")
    connection.close
end