ruby-on-rails - 在 Passenger fork 上重新启动 Rails Redis Cache Store 连接

Question

我想使用 redis 缓存存储(使用 redis-store gem)。

它在本地运行良好，但在 Passenger 派生多个 Rails worker 实例的生产环境中，我们收到 Redis 错误，这表明不同实例之间关于 Redis 访问的同步问题。

此类错误的示例是

 Got '7' as initial reply byte. If you're running in a multi-threaded environment, make sure you pass the :thread_safe option when initializing the connection. If you're in a forking environment, such as Unicorn, you need to connect to Redis after forking.
  redis (2.2.2) lib/redis/connection/ruby.rb:78:in `format_reply'

我读了一些书，了解到每个 Passenger worker 实例都必须创建自己的 Redis 连接。这可以使用以下代码实现

#config/initializers/redis_fork_init.rb
if defined?(PhusionPassenger)
  PhusionPassenger.on_event(:starting_worker_process) do |forked|
    if forked
      $redis = Redis.new
    end
  end
end

假设 Redis 访问是通过整个代码中的 $redis 完成的 - 这个解决方案很棒。

我的问题是 - 我如何创建一个新的 Redis 连接，当我执行 Rails.cache 操作(例如读取、写入等...)时将使用该连接？

我的 config/environments/production.rb 包括以下内容:

config.cache_store = :redis_store, { :host => 'localhost', :port => 6379, :thread_safe => true } 

使用 Rails 3.2.3、Redis 2.2.2、redis-store 1.1.1、Passenger 3.0

Answer 1

看一下redis store的reconnect方法: https://github.com/jodosha/redis-store/blob/master/redis-activesupport/lib/active_support/cache/redis_store.rb

所以基本上你的 fork block 应该是这样的:

if defined?(PhusionPassenger)
  PhusionPassenger.on_event(:starting_worker_process) do |forked|
    if forked
      Rails.cache.reconnect
    end
  end
end