Rails push EM-Socket

Question

我正在写Rails应用程序，并且我希望用户在新消息保存到数据库后能够收到通知。对于websocket，我使用em-websocket宝石。连接后，我将客户端ID和套接字实例存储在数组中。

问题：如何从控制器\模型动作（例如before_save）将数据推送到客户端？它能够使用em-websocket吗？

chat.rb

EVENTCHAT_CONFIG = YAML.load_file("#{Rails.root}/config/eventchat.yml")[Rails.env].symbolize_keys 

#escape html/xss 
include ERB::Util 

Thread.abort_on_exception = true 

Thread.new { 
    EventMachine.run { 
    @sockets = Array.new 

    EventMachine::WebSocket.start(EVENTCHAT_CONFIG) do |ws| 
     ws.onopen do 

     end 

     ws.onclose do 
     index = @sockets.index {|i| i[:socket] == ws} 
     client = @sockets.delete_at index 
     @sockets.each {|s| s[:socket].send h("#{client[:id]} has disconnected!")} 
     end 

     ws.onmessage do |msg| 
     client = JSON.parse(msg).symbolize_keys 
     case client[:action] 
     when 'connect' 
      @sockets.push({:id=>client[:id], :socket=>ws}) 
      @sockets.each {|s| s[:socket].send h("#{client[:id]} has connected!")} 
     when 'say' 
      @sockets.each {|s| s[:socket].send h("#{client[:id]} says : #{client[:data]}")} 
     end 
     end 
    end 
    } 
} 

Answer 1

当部署 - 您可能必须与具有对一些没有绑定到插座或并不是所有的用户接收的每个轨工人（一个独立的EM反应器，例如错误的问题所有消息）

与websocket reactor相关的Rails控制器只是另一种类型的客户端，最简单的方法是使用特殊的客户端ID打开连接，然后推入一些数据并关闭它。更有效的方式 - 是保持每个轨道工人

打开的连接如果基于EM-单进程的服务器使用（例如 - thin），你可以使用EM::Queue将消息传送给WebSocket的工人进程或甚至直接从控制器写入websocket