在 ruby​​ 套接字上实现超时的最佳方法

Question

我只是一名机械工程师（编程新手），正在开发一个用于监控客户太阳能系统功率输出的 Web 应用程序。我目前正在尝试实现我的应用程序用来打开套接字连接并使用超时和线程查询客户逆变器的脚本。目前，该脚本（通过 cron 设置为每 15 分钟运行一次）非常简单，看起来像这样：

System.all.each do |system|
  @sock = TCPSocket.open(system.ip,51101)
  @query = "\x0A\x05\x03\x00\xB5\x00\x01\x94\x68\x0D"
  @sock.write(@query)      
  @s = @sock.read(9)
  # do stuff with @s
  @sock.close
end

我首先要解决的大问题之一是：每天日落之后，所有客户逆变器都会关闭一天，这个脚本尝试它的第一次 socket.write/read，我相信它“挂起”，因为为了让它再次开始连接和查询，我必须在早上重新启动我的计算机。所以我想在套接字本身和 socket.read 上正确实现超时，这样就不会发生这种情况。从我到目前为止所做的堆栈溢出研究来看，我想也许我应该做如下的事情来完成与上面相同的事情，但是套接字在 2 秒后超时：

@port = 51101
System.all.each do |system|
  @sock = Socket.new(Socket::AF_INET, Socket::SOCK_STREAM, 0)
  @sock_address = Socket.sockaddr_in(@port, system.ip)

  begin
    @sock.connect_nonblock(@sock_address)
    @query = "\x0A\x05\x03\x00\xB5\x00\x01\x94\x68\x0D"
    @sock.write(@query)      
    @s = @sock.read(9)
    # do stuff with @s
    @sock.close
  rescue Errno::EINPROGRESS
    if IO.select(nil, [@sock], nil, 2)
      begin
        @sock.connect_nonblock(@sock_address)
        @query = "\x0A\x05\x03\x00\xB5\x00\x01\x94\x68\x0D"
        @sock.write(@query)      
        @s = @sock.read(9)
        # do stuff with @s
        @sock.close
      rescue Errno::ECONNREFUSED, Errno::EHOSTUNREACH
        # do something
      end
    end
  end
end

但是有很多事情我不这样做不明白这段代码。首先，Errno::EINPROGRESS 何时引发？第二个 @sock.connect_nonblock(@sock_address) 是否出现在第 6 行，因为如果系统已经尝试“太长时间”但不超过 2 秒，此代码将重试连接？另外，从我读到的 Errno::EINPROGRESS 似乎是 Windows 的事情。 Mac 操作系统的等效项是什么？或者这些问题可能完全不是重点。如果我的方向正确，请告诉我。或者您是否可以向我提供一个带注释的片段，演示执行此操作的正确方法。

其次，如果套接字连接得很好，我怎样才能实现 socket.read 的超时，以免一切都挂起（我认为这就是逆变器关闭时实际发生的情况）？我一直读到不应使用 ruby​​ timeout.rb 。我怎样才能让它只尝试读取几秒钟，然后在挂起时关闭套接字？预先非常感谢您。

Answer 1

据我现在的了解，最简单的（不一定是最好的——取决于您的需求）只是为了避免尝试让我的套接字连接尝试超时以及我的 socket.read 超时的问题。由于我的脚本很简单并且我使用的是 Ruby 1.8.7，因此我使用的是 system_timer gem（ruby 的超时库对于 Ruby 1.8.x 来说并不可靠，而 system_timer 解决了 Ruby 1.8.x 的超时问题）。

http://systemtimer.rubyforge.org/

该文档很好。