如何在“内部”生成一个 EventMachine？ Rails 应用程序？

Question

我有一个 Rails 应用程序，并且希望为其添加某种 WebSocket 支持。从各种谷歌搜索来看，最好的基于 Ruby 的 WebSocket 解决方案似乎是在 EventMachine 上运行的 em-websocket。

我想知道是否有一种方法可以将 EventMachine 反应器“集成”到 Rails 中？初始化代码放在哪里？这是实现这一目标的正确方法吗？

我见过 this 示例，它依靠 Sinatra 来执行 EventMachine GET request，但这并不完全是我想要的。

任何帮助表示赞赏。

Answer 1

您无法在 Rails 本身内部运行 Eventmachine 引擎，因为它是一个持久运行循环，会永久阻塞您的 Rails 进程之一。通常所做的是有一个使用 Eventmachine 的副进程，Rails 通过套接字与其通信以发送通知。

Juggernaut 就是这种情况的一个例子，它实现了一个 Websocket 客户端和一个 Rails 钩子来向其发送通知它。此后，该项目已弃用 Ruby 版本，转而使用 JavaScript Node.js 版本，但这仍然是如何使用 Eventmachine 的一个非常全面的示例。

Answer 2

如果您在瘦服务器中运行 Rails 应用程序（bundle exec Thin Start），瘦服务器会为您运行 EventMachine，然后您的 Rails 应用程序可以在您需要的任何地方执行 EM 代码。

例如：

具有该代码的库初始化程序：

EM.next_tick do
  EM.add_periodic_timer(20) do
    puts 'from Event Machine in rails code'
  end
end

不会阻止 Rails 进程应用程序。

Answer 3

不知道这是否是你所追求的。但是如果您想提供某种套接字消息系统。

看看 Faye。它为 Node.js 和 Rack 提供消息服务器。 Ryan Bates 还为此提供了 railscast ，这应该可以简化实现。

希望有帮助。

Answer 4

我花了相当多的时间来研究这个问题。 EventMachine 需要在 Rails 安装中作为线程运行（除非您使用 Thin），并且对于 Passenger 有一些特殊的注意事项。我在这里编写了我们的实现：http://www.hiringthing。 com/2011/11/04/eventmachine-with-rails.html

更新

我们将此配置提取到名为 Momentarily 的 gem 中。来源在这里 https://github.com/eatenbyagrue/momentarily

Answer 5

我尝试使用 em-synchrony 在光纤中启动反应器。在 Rails 应用程序中，您可能可以在初始化程序中启动它，因为听起来您只想让反应器运行以响应 Websocket 请求。正如其他答案所建议的，我认为您想要与您的反应器建立套接字通信，或者使用异步客户端之一来连接您的反应器和 Rails 代码都可以读取和写入以交换数据的数据存储。

我的一些同事整理了一些在 ruby​​ 代码中按需启动 EM 反应器的示例，以便在 EventMachine 中运行测试。我会尝试用它作为一个可能的例子； 使用 eventmachine 进行抓取和测试

Answer 6

我会考虑研究抽筋。它是一个构建在 EventMachine 之上的异步框架，并且支持瘦服务器：

机架中间件支持+彩虹！和瘦网络服务器

Answer 7

如果你可以帮助的话，你可能不应该再使用 EM，它似乎不再被维护 - 如果你遇到错误 - 你就得靠自己了。

上面的大多数答案在 JRuby 中不起作用，因为 https://github.com/eventmachine /eventmachine/issues/479 - 即 EM::Synchrony 使用的模式

Thread.new{ EM.run }

以及在互联网上找到的各种答案（例如 EventMachine 和 Ruby 线程 - 这里到底发生了什么？）在 JRuby eventmachine 实现下被破坏了（纤程是 jruby 中的线程，目前没有关于何时改变的路线图）。

JRuby 消息传递选项将

1. 与 TorqueBox（与 HornetQ 捆绑在一起）一起部署，http://torquebox.org/news/2011/08/15/websockets-stomp-and-torquebox/,令人印象深刻且富有进取心，但并不真正优雅，除非您有 Java 背景
2. 较新版本的 Faye 应该可以与 JRuby 配合使用，Faye in jruby on Rails
3. 注意未来，请关注赛璐珞社区，一些有趣的分布式解决方案来自那里https://github.com/celluloid/reel/wiki/WebSockets, https://github.com/celluloid/dcell
4. ？

Answer 8

我有同样的问题并找到了解决方案。首先，将代码放入 lib 目录（例如 /lib/listener/init.rb）并创建一个运行 EM 的类方法，例如 Listener。运行。

#!/usr/bin/env ruby

require File.expand_path('../../config/environment', File.dirname(__FILE__))

class Listener
  def self.run
  # your code here
  # you can access your models too
  end
end

之后我使用了 dante gem。创建 /init/listener 文件。代码可能是这样的：

#!/usr/bin/env ruby

require File.expand_path('../../lib/listener/init.rb', __FILE__)

log_file = File.expand_path('../../log/listener.stdout.log', __FILE__)
pid_file = File.expand_path('../../tmp/listener.pid', __FILE__)

listener = Dante::Runner.new('listener')

if ARGV[0] === 'start'
  listener.execute(daemonize: true,
                   pid_path: pid_file,
                   log_path: log_file) { Listener.run }
elsif ARGV[0] === 'restart'
  listener.execute(daemonize: true,
                   restart: true,
                   pid_path: pid_file,
                   log_path: log_file) { Listener.run }
elsif ARGV[0] === 'stop'
  listener.execute(kill: true, pid_path: pid_file)
end

现在您可以运行这样的代码： ./bin/listener start, ./bin/listener restart, ./bin /listener stop

您可以使用 god 来监控监听器的运行情况。但请确保您使用相同的 pid 文件 (/tmp/listener.pid)。