铁路上的Redis酒吧/酒吧

Question

跟随Redis酒吧/酒吧

这很好用，我可以使用

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

使用redis cli

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

当我在另一个类（listener类）中将订户块添加到该通道时，问题就开始了，如下所示

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

在<代码>redis-cli中

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

问题是，当我将subscriber listener类添加到同一个rails应用程序时。。。它停止工作，因为OtherClass侦听redis服务器并停止执行任何其他代码。。。它只是坐在那里听着。

那么，有没有办法在同一个rails应用程序上使用redis制作消息总线呢。。。因此，事件是从某些类或服务对象发布的，并且有特定通道的侦听器在后台接收事件时进行操作。

我知道我可能会使用sidekiq或任何其他背景工作者来做这项工作。。。但过了一段时间，背景工作人员变得杂乱无章，无法维护。

Answer 1

Redis#subscribe的实现是一个循环，它将控制当前线程以监听事件。这意味着，当按照您所示的方式将订阅放到Rails类的上下文中时，启动过程将停止。

您可以尝试将调用包装到线程中，但这种方法实际上会在每次将此类加载到新进程（如rails控制台或多个unicorns）时创建一个新订阅。此外，您还必须小心共享状态和其他线程问题。这可能不是你想要的。

您最好启动一个不同的进程，加载rails环境并订阅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