Ruby TCPSocket 超时是如何定义的？

Question

$ irb
1.9.3-p448 :001 > require 'socket'
 => true 
1.9.3-p448 :002 > TCPSocket.new('www.example.com', 111)

给予

Errno::ETIMEDOUT: 操作超时 - connect(2)

问题：

• 如何定义TCPSocket.new 的超时值？
• 如何正确捕获超时（或者，通常是套接字）异常？

Answer 1

至少从 2.0 开始可以简单地使用：

Socket.tcp("www.ruby-lang.org", 10567, connect_timeout: 5) {}

对于旧版本@falstru 的答案似乎是最好的。

Answer 2

使用begin .. rescue Errno::ETIMEDOUT 捕捉超时：

require 'socket'

begin
  TCPSocket.new('www.example.com', 111)
rescue Errno::ETIMEDOUT
  p 'timeout'
end

要捕获任何套接字异常，请改用SystemCallError。

根据SystemCallError documentation：

SystemCallError 是所有低级平台相关错误的基类。

当前平台上可用的错误是 SystemCallError 并在 Errno 模块中定义。

---

TCPSocket.new 不直接支持超时。

使用Socket::connect_non_blocking 和IO::select 设置超时。

require 'socket'

def connect(host, port, timeout = 5)

  # Convert the passed host into structures the non-blocking calls
  # can deal with
  addr = Socket.getaddrinfo(host, nil)
  sockaddr = Socket.pack_sockaddr_in(port, addr[0][4])

  Socket.new(Socket.const_get(addr[0][0]), Socket::SOCK_STREAM, 0).tap do |socket|
    socket.setsockopt(Socket::IPPROTO_TCP, Socket::TCP_NODELAY, 1)

    begin
      # Initiate the socket connection in the background. If it doesn't fail 
      # immediatelyit will raise an IO::WaitWritable (Errno::EINPROGRESS) 
      # indicating the connection is in progress.
      socket.connect_nonblock(sockaddr)

    rescue IO::WaitWritable
      # IO.select will block until the socket is writable or the timeout
      # is exceeded - whichever comes first.
      if IO.select(nil, [socket], nil, timeout)
        begin
          # Verify there is now a good connection
          socket.connect_nonblock(sockaddr)
        rescue Errno::EISCONN
          # Good news everybody, the socket is connected!
        rescue
          # An unexpected exception was raised - the connection is no good.
          socket.close
          raise
        end
      else
        # IO.select returns nil when the socket is not ready before timeout 
        # seconds have elapsed
        socket.close
        raise "Connection timeout"
      end
    end
  end
end

connect('www.example.com', 111, 2)

以上代码来自“Setting a Socket Connection Timeout in Ruby”。

Answer 3

如果您喜欢避免使用the pitfalls of Timeout 的想法，但希望避免自己处理*_nonblock+select 的实现，您可以使用the tcp_timeout gem。

tcp_timeout gem 猴子补丁 TCPSocket#connect、#read 和 #write，以便它们使用非阻塞 I/O 并具有可以启用的超时。

Answer 4

您可以使用 ruby​​ 的 Timeout 模块进行超时：

reqiure 'socket'
reqiure 'timeout'

begin 
   Timeout.timeout(10) do
      begin
         TCPSocket.new('www.example.com', 111)
      rescue Errno::ENETUNREACH
         retry # or do something on network timeout
      end
   end
rescue Timeout::Error
   puts "timed out"
   # do something on timeout
end

你会在 10 秒后得到：

# timed out
# => nil