ZeroMQ 检测到客户端超时，但客户端挂起

Question

我正在尝试编写一个简单的zmq系统来替换http客户端/服务器。当服务器关闭/不可用时，我的客户端超时，但不会重试或停止。我错过了什么？

zmq_client.rb（来自zeromq指南的Han Holl懒惰海盗客户端的修改版本）

require 'rubygems'
require 'zmq'
context = ZMQ::Context.new
socket = context.socket(ZMQ::REQ)
socket.connect('tcp://localhost:5559')
retries = 2
timeout = 10
retries.times do |tries|
  message = "Hello #{tries}"
  raise("Send: #{message} failed") unless socket.send(message)
  puts "Sending string [#{message}]"
  if ZMQ.select( [socket], nil, nil, timeout)
    message = socket.recv
    puts "Received reply [#{message}]"
    break
  else
    puts "timeout"
  end
end
socket.close

zmq_broker.rb（Oleg Sidorov代码的修改版本，可在zeromq指南中找到）

require 'rubygems'
require 'ffi-rzmq'
context = ZMQ::Context.new
frontend = context.socket(ZMQ::ROUTER)
frontend.bind('tcp://*:5559')
poller = ZMQ::Poller.new
poller.register(frontend, ZMQ::POLLIN)
loop do
  poller.poll(:blocking)
  poller.readables.each do |socket|
    if socket === frontend
      loop do
        socket.recv_string(message = '')
        more = socket.more_parts?
        puts "#{message}#{more}"
        socket.send_string(message, more ? ZMQ::SNDMORE : 0)
        break unless more
      end
    end
  end
end

Answer 1

在

第一次超时后尝试再次send时，您应该Send: #{message} failed收到错误，因为您的第二次send将直接发生在第一次send之后，并且 REQ 套接字强制每个send都必须在（成功，而不是超时）recv之后。

在懒惰海盗模式中，您可能需要发送多个请求才能获得回复。0MQ 指南中建议的解决方案是在出现错误后关闭并重新打开 REQ 套接字。客户端不会关闭/重新打开 REQ 套接字。

您可能会发现指南中的"Ruby 中的懒惰海盗客户端"示例很有帮助。