ruby 中进程间通信有哪些可用的消息解决方案？

Question

我有一个使用delayed_job的rails应用程序。我需要我的工作相互沟通，以处理诸如“任务 5 已完成”或“这是任务 5 需要处理的事项列表”之类的事情。

现在我有一个专门用于此目的的特殊表，并且我总是在事务内访问该表。运行良好。我想为其构建一个更干净的 api/dsl，但首先想检查是否已经有现有的解决方案。奇怪的是，我没有找到任何东西，我要么谷歌搜索完全错误，要么任务太简单（在事务中设置和获取值）以至于没有人将其抽象出来。

我错过了什么吗？

澄清：我不是在寻找新的排队系统，而是在寻找一种后台任务相互通信的方法。基本上只是安全地共享变量。以下框架是否提供此功能？遗憾的是，延迟的工作没有。

用例：“并行执行这 5 项任务，然后当它们全部完成后，执行最后一项任务。”因此，5 个任务中的每一个都会检查它是否是最后一个任务，如果是，则触发最后一个任务。

Answer 1

我使用 resque。另外还有很多插件，这应该使进程间通信变得更容易。

使用 redis 还有另一个优点：您可以使用发布-订阅通道在工作人员/服务之间进行通信。

另一种方法（但未经我测试）：http://www.zeromq.org/，它也有 < a href="http://www.zeromq.org/bindings%3aruby" rel="nofollow">Ruby 绑定。如果您喜欢测试新东西，请尝试 Zeromq。

---

更新

澄清/解释/扩展我上面的评论：

为什么我应该从DelayedJobs切换到Resque是提到的优势，我有队列和消息在一个系统中，因为 Redis 提供了这一点。

更多来源：

• https://github.com/blog/542-introducing-resque
• < a href="https://github.com/defunkt/resque#readme" rel="nofollow">https://github.com/defunkt/resque#readme

如果我必须留在 DJ 我会延长使用 redis 或 zeromq/0mq（此处仅为示例）的工作线程类在我现有的后台作业中获取消息传递。

我不会尝试使用ActiveRecord/MySQL进行消息传递（实际上甚至没有排队！），因为此数据库不是用于此用途的最佳性能系统尤其是当应用程序有太多后台工作人员、巨大的队列以及短时间内无数的消息交换时。

如果它是一个具有较少工作人员的小型应用程序，您也可以通过 DB 实现简单的消息传递，但在这里我更喜欢 memcache；消息是短暂的数据块，只能在内存中处理。

共享变量永远不会是一个好的解决方案。想象一下您的应用程序和工作人员可以运行的多台机器。如何确保它们之间保存变量传输？

好吧，有人可能会提到DRb（分布式红宝石），但它似乎不再被真正使用。 （到目前为止还没有见过现实世界的例子）

如果你想尝试一下 DRb，请阅读

我个人的偏好顺序：消息（真实）>数据库驱动的消息传递>变量共享

Answer 2

• memcached
• rabbitmq

Answer 3

您可以使用管道：

reader, writer = IO.pipe

fork do
  loop do
    payload = { name: 'Kris' }
    writer.puts Marshal.dump(payload)
    sleep(0.5)
  end
end

loop do
  begin
    Timeout::timeout(1) do
      puts Marshal.load(reader.gets) # => { name: 'Kris' }
    end
  rescue Timeout::Error
    # no-op, no messages to receive
  end
end

• 一种方式
• 作为字节流读取

管道表示为一对，即读取器和写入器。要获得双向通信，您需要两组管道。