¿Cómo configuro el tiempo de espera del socket en Ruby?

network-programming

Question

¿Cómo se configura el tiempo de espera para bloquear operaciones en un socket Ruby?

Answer 1

Creo que el enfoque de no bloqueo es el camino a seguir.
Probé el artículo mencionado anteriormente y aún así pude colgarlo.
este artículo que no bloquea las redes y el enfoque anterior de jonke me llevaron por el camino correcto. Mi servidor estaba bloqueando en la conexión inicial, así que necesitaba que fuera un nivel un poco más bajo.
el socket rdoc puede dar más detalles en 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

para obtener una buena prueba. iniciar un servidor de socket simple y luego hacer un ctrl-z para fondo

IO.select espera que los datos entren en la secuencia de entrada en 10 segundos. esto puede no funcionar si ese no es el caso.

Debería ser un buen reemplazo para el método abierto de TCPSocket.

Answer 2

El objeto de tiempo de espera es una buena solución.

Este es un ejemplo de E / S asíncrona (de naturaleza no bloqueante y se produce de forma asíncrona al flujo de la aplicación).

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

Puede usarse para obtener el mismo efecto.

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

La solución que encontré que parece funcionar es usar Timeout :: timeout :

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