听Rails的Juggernaut事件

我正在使用Juggernaut,Redis,SQLite和Rails 3.1构建一个简单的实时聊天

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

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

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

问题是我不知道我应该把这个代码放在我的Rails应用程序(控制器,模型,观察者？)中.我试图将它放入模型中,但是服务器不会响应任何带有大量代码的请求进入模型.

我想我应该从服务器端收听该事件,因为如果用户因为关闭窗口而断开连接,那么我没有该用户的"客户端".

可能我错过了一些关于Juggernaut如何工作的东西.任何帮助将不胜感激.

好的,最后我回答自己:

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

我的代码现在看起来像这样:型号:

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).

希望它对某人有帮助!