ruby-on-rails – 在Middleware中运行的线程正在使用旧版本的父

它适用于Thin,但不适用于Unicorn和Puma.

还有一个回应消息实现,它响应客户端的消息.它在每个服务器上都能正常工作,因此websockets实现没有问题.

Redis设置也是正确的(它捕获所有消息,并执行订阅块内的代码).

它现在如何工作：

在服务器启动时,初始化一个空的@clients数组.然后启动新的Thread,它正在侦听Redis,它旨在从@clients数组向相应的用户发送该消息.

在页面加载时,会创建新的websocket连接,它存储在@clients数组中.

如果我们从浏览器收到消息,我们会将其发送回与同一用户连接的所有客户端(该部分在Thin和Puma上都正常工作).

如果我们收到Redis的消息,我们也会查找存储在@clients数组中的所有用户连接.
这是奇怪的事情发生的地方：

>如果使用Thin运行,它会在@clients数组中找到连接并将消息发送给它们.
>如果使用Puma / Unicorn运行,@ clients数组总是为空,即使我们按该顺序尝试它(没有页面重新加载或任何东西)：

>从浏览器发送消息 – > @ clients.length为1,传递消息
>通过Redis发送消息 – > @ clients.length为0,消息丢失
>从浏览器发送消息 – > @ clients.length仍为1,传递消息

有人可以澄清一下我错过了什么吗？

Puma服务器的相关配置：

workers 1
threads_count = 1
threads threads_count,threads_count

相关中间件代码：

require 'faye/websocket'

class NotificationsBackend

  def initialize(app)
    @app     = app
    @clients = []
    Thread.new do
      redis_sub = Redis.new
      redis_sub.subscribe(CHANNEL) do |on|
        on.message do |channel,msg|
          # logging @clients.length from here will always return 0
          # [..] retrieve user
          send_message(user.id,{ message: "ECHO: #{event.data}"} )
        end
      end
    end
  end

  def call(env)
    if Faye::WebSocket.websocket?(env)
      ws = Faye::WebSocket.new(env,nil,{ping: KEEPALIVE_TIME })
      ws.on :open do |event|
        # [..] retrieve current user
        if user
          # add ws connection to @clients array
        else
          # close ws
        end
      end

      ws.on :message do |event|
        # [..] retrieve current user
        Redis.current.publish({user_id: user.id,{ message: "ECHO: #{event.data}"}} )
      end

      ws.rack_response
    else
      @app.call(env)
    end
  end
  def send_message user_id,message
    # logging @clients.length here will always return correct result
    # cs = all connections which belong to that client
    cs.each { |c| c.send(message.to_json) }
  end
end