ruby-on-rails - ruby 和 Redis : set a timeout for subscribtions

Question

我想在 Redis channel 中等待消息最多 2 秒，然后我希望订阅过期/超时并停止阻止我的代码。

redis = Redis.new

redis.subscribe(channel) do |on|
  on.message do |channel, message|
    # ...
  end
end

# This line is never reached if no message is sent to channel :(

我正在使用 https://github.com/redis/redis-rb .我在源代码中搜索但没有找到订阅超时选项。

Answer 1

您现在可以 subscribe with a timeout一步到位:

redis.subscribe_with_timeout(5, channel) do |on|
  on.message do |channel, message|
    # ...
  end
end