ZeroMQ 驱动的服务器在一段时间后停止响应答案

【问题标题】：ZeroMQ-driven server stops responding after some timeZeroMQ 驱动的服务器在一段时间后停止响应
【发布时间】：2011-11-21 20:23:39
【问题描述】：

我正在研究如何将 ZeroMQ 与 EventMachine 一起使用。为了进行测试，我在 ruby（回显客户端服务器）中编写了一个小程序，其中我使用了 XREQ 和 XREP 套接字。客户端应用程序正在向服务器发送消息（连续的数字）并将它们作为响应返回。发送间隔为0.1s。一切正常……直到某个时刻。当当前数量达到大约 400 时，服务器只是冻结并且不再响应客户端。我在几台电脑上测试过，还是遇到了这个奇怪的问题。

代码非常简单：

server.rb

require 'rubygems'
require 'bundler/setup'
require 'em-zeromq'

Thread.abort_on_exception = true

ADDRESS = 'tcp://127.0.0.1:2091'

class EMServerHandler
  attr_reader :received
  def on_readable(socket, messages)
    client_identity = messages.shift.copy_out_string #getting client identity from the 1st part of the message
    messages.shift #skip the delimeter
    messages.each do |m|
      msg = m.copy_out_string
      puts "server received from #{client_identity}: " + msg
      socket.send_msg("#{client_identity}",'',"#{msg}") #echo message back to the client
    end
  end
end

trap('INT') do
  EM::stop()
end

puts "Program started (with zmq #{ZMQ::Util.version.join('.')})."

EM.run do
EventMachine.epoll
  ctx = EM::ZeroMQ::Context.new(1)  
  server = ctx.bind(ZMQ::XREP, ADDRESS, EMServerHandler.new, {:identity => "server"})
end

client.rb

require 'rubygems'
require 'bundler/setup'
require 'em-zeromq'

Thread.abort_on_exception = true

ADDRESS = 'tcp://127.0.0.1:2091'

class EMClientHandler
  attr_reader :received
  def on_readable(socket, messages)
    messages.shift #skip the delimeter
    messages.each do |m|
      puts "client recieved: " + m.copy_out_string
    end
  end
end

trap('INT') do
  EM::stop()
end

puts "Program started (with zmq #{ZMQ::Util.version.join('.')})."

EM.run do
  EventMachine.epoll
  ctx = EM::ZeroMQ::Context.new(1)
  puts "client"
  puts "enter client name >> "
  identity = gets.strip
  client = ctx.connect(ZMQ::XREQ, ADDRESS, EMClientHandler.new, {:identity => identity})
  client.send_msg('', "hello from client #{identity}")
  count = 0
  EM::PeriodicTimer.new(0.1) do
    client.send_msg('', "#{count += 1}")
  end
end

请帮我找出原因。

【问题讨论】：

标签： ruby eventmachine zeromq

【解决方案1】：

垃圾收集器正在回收您的 ZeroMQ 上下文。

您需要在EM 循环之外将您的呼叫移至EM::ZeroMQ::Context#new。

见README

【讨论】：

【解决方案2】：

最后我发现这个问题只在使用ruby 1.9.3p0时出现，所以感觉这是那个版本的ruby的错误。使用 ruby 1.9.2，一切都像魅力一样。

【讨论】：