如何从一个红宝石TCPSERVER插槽读取使用读，readpartial和read_nonblock

Question

我从插座读取2部分的问题以及它是如何在Ruby的服务器，比如麒麟或杂种管理

1. 我学到从套接字中读取与读取文件不同，并且没有发送明确的EOF消息，数据层出不穷。那么你怎么知道什么时候停止阅读？例如我的TCPServer在这种情况下，当我通过从浏览器访问http://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 
 

我想知道什么是最好的做法/标准方法由红宝石服务器使用。我看到Unicorn使用kgio库中的read_nonblock库和mongrel使用readpartial（我不确定这些但通过代码，这是我认为是采用的方法。）即使检查\ r \ n服务器如何知道输入完成。 可以解释这应该怎么做（我认为gets不是这种方法 - 它与read,readpartial,​​）。 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