监听来自Rails的Juggernaut事件

Question

我正在使用Juggernaut，Redis，SQLite和Rails3.1构建一个简单的实时聊天

当另一个用户断开连接(例如，他关闭了窗口)时，我想向每个用户写入一条新消息，这是为了侦听Juggernaut的客户端断开连接事件。

Juggernaut docs说我可以在服务器端做到这一点(Ruby)

Juggernaut.subscribe do |event, data|
  # Use event/data
end

问题是我不知道我应该把这段代码放在我的Rails应用程序中的什么地方(控制器，模型，观察者？)。我尝试将其放入模型中，但是服务器不会响应任何将该代码块放入模型中的请求。

我认为我应该从服务器端监听该事件，因为如果用户因为关闭窗口而断开连接，那么我就没有针对该用户的“客户端”。

也许我错过了一些关于Juggernaut是如何工作的东西。任何帮助都将不胜感激。

Answer 1

好了，最后我回答我自己：

我发现的问题是，当运行的进程调用Juggernaut.subscribe时，它会冻结，直到触发Juggernaut事件。因此，您不能从服务器进程调用Juggernaut，您需要一个新进程来运行该代码。

我的代码现在看起来像这样: Model：

class MyModel < ActiveRecord::Base

  class << self
    def subscribe
      Juggernaut.subscribe do |event, data|
        case event
          when :subscribe
            # do something
          when :unsubscribe
            # do something else
        end
      end
    end
  end

end

然后我有一个ruby脚本myapp/scripts/juggernaut_listener：

#!/usr/bin/env ruby
require File.expand_path('../../config/environment',  __FILE__)

puts "Starting juggernaut listener"
MyModel.subscribe

因此，在启动服务器之后，我需要像这样启动Juggernaut监听器：

./script/participations_listener

(请注意，您应该为脚本指定+x )。

希望对某些人有帮助！