Redis pub/sub on rails

关注Redis Pub/Sub

这工作正常,我可以使用任何类发布消息

$redis.publish 'channel', { object: @object.id }

使用redis-cli > MONITOR,我可以验证此请求是否已正确发布

[0 127.0.0.1:64192] "publish" "channel" "{:object=>\"5331d541f4eec77185000003\" }"

当我在其他类(监听器类)中向该通道添加订户块时,问题就开始了,如下所示

class OtherClass
  $redis.subscribe('channel') do |payload|
    p payload
  end
end

in redis-cli > MONITOR,还表明侦听器已正确订阅

[0 127.0.0.1:52930] "subscribe" "channel"

问题是,当我将订阅者监听器类添加到相同的rails应用程序时...它停止工作导致OtherClass侦听redis服务器并停止执行任何其他代码...它只是坐在那里听.

那么有没有办法在相同的rails应用程序上使用redis创建消息传递总线...以便从某些类或服务对象发布事件,并且有特定通道的侦听器在后台接收事件时采取行动.

我知道我可能会使用sidekiq或任何其他背景工作者来完成这项工作......但过了一段时间后,后台工作人员变得混乱且无法维护.

实现Redis#subscribe是一个循环,它将控制当前线程以便监听事件.这意味着在以您显示的方式将订阅放入Rails类的上下文时,将停止引导过程.

您可以尝试在一个线程中包装调用,但是每次在新进程中加载​​此类时,这种方法都会创建一个新的订阅,例如rails控制台或多个独角兽.另外,您必须小心共享状态和其他线程问题.这可能不是你想要的.

您最好启动一个加载rails环境的不同进程,并与提供Web请求的进程分开订阅redis.它可能是一个像下面这样的rake任务:

namespace :subscribe do
  task :redis => :environment do
    $redis.subscribe("bravo") do |on|
      on.message do |channel, message|
        Rails.logger.info("Broadcast on channel #{channel}: #{message}")
        OtherClass.some_method # yada yada
      end
    end
  end
end