Juggernaut 2 的服务器端计时器

Question

我正在使用 Juggernaut 2 编写一个用于实时推送通知的 Rails 应用程序，但不知道如何解决这个问题。我的聊天室中有许多用户，我想运行一个计时器，以便每 30 秒向聊天室中的每个浏览器推送一次。 Juggernaut 2 是基于 node.js 构建的，因此我假设我需要在那里编写此代码。我只是不知道从哪里开始将其与 Juggernaut 2 集成。

Answer 1

我只是简单浏览了一下 Juggernaut，所以请对我的回答持保留态度......

1. 您可能对 Channel 对象感兴趣（https://github.com/maccman/juggernaut/blob/master/lib/juggernaut/channel.js ）您会注意到 Channel.channel 是所有存在的通道的对象（想想 ruby​​ 的哈希）。您可以设置 30 秒的循环计时器 (setInterval - http://nodejs. org/docs/v0.4.2/api/timers.html#setInterval) 对所有通道执行某些操作。

2. 每次循环迭代要做什么？嗯，前面提到的频道代码的链接有一个发布方法：

   发布：函数（消息）{
   var 频道 = message.getChannels();
   删除消息.channels；
   
   for(var i=0, len =channels.length; i < len; i++) {
     消息.channel = 通道[i];
     var client = this.find(channels[i]).clients;
   
     for(var x=0, len2 = client.length; x < len2; x++) {
       客户端[x].write(消息);
       }
     }  
   

   }

所以你基本上必须创建一个 Message 对象，并将 message.channels 设置为 Channel.channels，如果你将该消息传递给发布方法，它将发送给所有你的客户。

至于您的消息内容，我不知道您正在使用什么客户端（socket.io？某人已经为您在 Juggernaut 和 socket.io 上构建的聊天客户端？），所以这取决于您。

至于在哪里放置创建间隔并触发回调以将消息发布到所有通道的代码，您可能需要在此处检查创建在给定端口上侦听的实际服务器的代码： com/maccman/juggernaut/blob/master/lib/juggernaut/server.js) 如果您在 init() 中附加间隔，那么一旦您启动服务器，它将每 30 秒检查一次，以将给定的消息发布到每个渠道

Answer 2

下面是一个示例客户端，它在 Ruby 中每 30 秒推送一次。

使用 Redis 和 Node 安装 Juggernaut：安装 ruby​​ 和 ruby​​gems，然后运行 ​​gem install juggernaut 并

#!/usr/bin/env ruby
require "rubygems"
require "juggernaut"
while 1==1
 Juggernaut.publish("channel1","some Message")
 sleep 30
end

Answer 3

我们实施了一个测验系统，以可变的时间间隔推出问题。我们的做法如下：

def start_quiz
  Rails.logger.info("*** Quiz starting at #{Time.now}")
  $redis.flushall  # Clear all scores from database

  quiz = Quiz.find(params[:quizz] || 1 )
  @quiz_master = quiz.user  
  quiz_questions = quiz.quiz_questions.order("question_no ASC")

  spawn_block do 
    quiz_questions.each { |q|
      Rails.logger.info("*** Publishing question #{q.question_no}.")
      time_alloc = q.question_time
      Juggernaut.publish( select_channel("/quiz_stream"), {:q_num => q.num, :q_txt => q.text :time=> time_alloc} ) 
      sleep(time_alloc)             
      scoreboard = publish_scoreboard
      Juggernaut.publish( select_channel("/scoreboard"), {:scoreboard => scoreboard} ) 
    }
  end

  respond_to do |format|
    format.all { render :nothing => true, :status => 200 }
  end
end

在我们的案例中，关键是使用“spawn”来运行测验计时的后台进程，以便我们仍然可以处理传入的分数。

我不知道这有多大的可扩展性。