Ruby TCPSocket продолжает терять связь - PullRequest
Новая
       11

Ruby TCPSocket продолжает терять связь

0 голосов
/ 21 сентября 2009

У меня есть клиент и сервер. Я запускаю сервер и запускаю клиент, и в первый раз он работает нормально. Во второй раз, когда я запускаю клиент (без перезапуска сервера), клиент зависает. Кто-нибудь может увидеть, что не так?

У меня есть клиент: 


# Code example originated from p069dtclient.rb at http://rubylearning.com/satishtalim/ruby_socket_programming.html
    require 'socket'
    x = 0;

    streamSock = TCPSocket.new( 'localhost', 20000 )
    while x &lt 10
      streamSock.send( "Hello #{x}",0 )
      str = streamSock.recv( 100 )
      puts "#{x} " + str
      x=x+1
    end
    streamSock.close

и сервер: 


    # p068dtserver.rb
    require "socket"
    dts = TCPServer.new('localhost', 20000)
    s = dts.accept
    print(s, " is accepted\n")
    loopCount = 0;
    loop do
      Thread.start(s) do
      loopCount = loopCount + 1
        lineRcvd = s.recv(1024)
        if ( !lineRcvd.empty? )
          puts("#{loopCount} Received: #{lineRcvd}")
          s.write(Time.now)
        end
      end
    end
    s.close
    print(s, " is gone\n")

1 Ответ

2 голосов
/ 21 сентября 2009

Каждое подключение к серверу требует отдельного вызова для принятия. Происходит то, что вы принимаете первое, работаете с ним, а затем эффективно завершаете работу, оставляя сокет в состоянии прослушивания. Это означает, что соединения будут открыты, но не приняты, поэтому они зависают, как вы описали.

Возможно, вам лучше использовать более надежную серверную среду. EventMachine (http://rubyeventmachine.com/) немного сложнее в освоении, но гораздо эффективнее, чем накатить собственное решение.

Вот быстрое исправление, которое может помочь: 

require "socket"
dts = TCPServer.new('localhost', 20000)
while (s = dts.accept)
  print(s, " is accepted\n")
  loopCount = 0;
  loop do
    Thread.start(s) do
    loopCount = loopCount + 1
      lineRcvd = s.recv(1024)
      if ( !lineRcvd.empty? )
        puts("#{loopCount} Received: #{lineRcvd}")
        s.write(Time.now)
      end
    end
  end
  s.close
  print(s, " is gone\n")
end

Теперь вызов accept заключен в цикл, поэтому можно обрабатывать более одного соединения.

...