ruby - Rubyでソケットタイムアウトを設定するにはどうすればよいですか?

Question

Rubyソケットでブロック操作のタイムアウトをどのように設定しますか?

Answer 1

私が見つけた解決策は、Timeout::timeoutを使用することです。

require 'timeout'
    ...
begin 
    timeout(5) do
        message, client_address = some_socket.recvfrom(1024)
    end
rescue Timeout::Error
    puts "Timed out!"
end

Answer 2

timeout オブジェクトは良い解決策です。

これは、非同期 I/O の例です (本質的に非ブロッキングであり、アプリケーションのフローに対して非同期に発生します)。

IO.select(read_array
[, write_array
[, error_array
[, timeout]]] ) => array or nil

同じ効果を得るために使用できます。

require 'socket'

strmSock1 = TCPSocket::new( "www.dn.se", 80 )
strmSock2 = TCPSocket::new( "www.svd.se", 80 )
# Block until one or more events are received
#result = select( [strmSock1, strmSock2, STDIN], nil, nil )
timeout=5

timeout=100
result = select( [strmSock1, strmSock2], nil, nil,timeout )
puts result.inspect
if result

  for inp in result[0]
    if inp == strmSock1 then
      # data avail on strmSock1
      puts "data avail on strmSock1"
    elsif inp == strmSock2 then
      # data avail on strmSock2
      puts "data avail on strmSock2"
    elsif inp == STDIN
      # data avail on STDIN
      puts "data avail on STDIN"
    end
  end
end

Answer 3

ノンブロッキングアプローチが進むべき道だと思います。
上記の記事を試してみましたが、それでもハングすることができました。
この記事のノンブロッキングネットワーキングと上記のジョンケのアプローチにより、正しい道を歩むことができました。私のサーバーは最初の接続でブロックしていたので、少し低いレベルにする必要がありました.
ソケット rdoc は connect_nonblock に詳細を与えることができます

def self.open(host, port, timeout=10)
 addr = Socket.getaddrinfo(host, nil)
 sock = Socket.new(Socket.const_get(addr[0][0]), Socket::SOCK_STREAM, 0)

 begin
  sock.connect_nonblock(Socket.pack_sockaddr_in(port, addr[0][3]))
 rescue Errno::EINPROGRESS
  resp = IO.select([sock],nil, nil, timeout.to_i)
  if resp.nil?
    raise Errno::ECONNREFUSED
  end
  begin
    sock.connect_nonblock(Socket.pack_sockaddr_in(port, addr[0][3]))
  rescue Errno::EISCONN
  end
 end
 sock
end

良いテストを受けるために。単純なソケット サーバーを起動し、ctrl-z を実行してバックグラウンドにします。

IO.select は、10 秒以内に入力ストリームにデータが入ってくることを期待しています。そうでない場合、これは機能しない可能性があります。

これは、TCPSocket の open メソッドの適切な代替となるはずです。