ruby on rails - Ruby websocket client para websocket-rails

ruby-on-rails ruby-on-rails-4.1

Question

Estoy desarrollando una página web de rieles que necesita utilizar la funcionalidad de websocket para comunicarse con un cliente de Ruby externo. Para hacer esto, estoy usando la gema websocket-rails en el servidor de rieles, definiendo el evento client_connected client_disconnected y una acción específica para recibir los mensajes del cliente (new_message).

Del lado del cliente, he tratado de usar diferentes gemas de rubí, como faye-websocket-ruby y websocket-client-simple, pero siempre obtengo errores cuando intento enviar un mensaje. En el servidor no puedo encontrar la manera de procesar estos mensajes. Ambas gemas tienen un método de envío que solo acepta una cadena (no se puede especificar el nombre del evento)

El código que he estado usando es el siguiente:

Lado del servidor

app / controllers / chat_controller.rb

class ChatController < WebsocketRails::BaseController
def new_message
puts '')''*40
end
def client_connected
puts ''-''*40
end
def client_disconnected
puts ''&''*40
end
end

config / events.rb

WebsocketRails::EventMap.describe do
subscribe :client_connected, :to => ChatController, :with_method => :client_connected
subscribe :message, :to => ChatController, :with_method => :new_message
subscribe :client_disconnected, :to => ChatController, :with_method => :client_disconnected
end

config / initializers / websocket_rails.rb

WebsocketRails.setup do |config|
config.log_path = "#{Rails.root}/log/websocket_rails.log"
config.log_internal_events = true
config.synchronize = false
end

Lado del cliente

websocket-client-simple

require ''rubygems''
require ''websocket-client-simple''
ws = WebSocket::Client::Simple.connect ''ws://localhost:3000/websocket''
ws.on :message do |msg|
puts msg.data
end
ws.on :new_message do
hash = { channel: ''example'' }
ws.send hash
end
ws.on :close do |e|
p e
exit 1
end
ws.on :error do |e|
p e
end
hash = { channel: ''Example'', message: ''Example'' }
ws.send ''new_message'', hash
loop do
ws.send STDIN.gets.strip
end

faye-websocket

require ''faye/websocket''
require ''eventmachine''
EM.run {
ws = Faye::WebSocket::Client.new(''ws://localhost:3000/websocket'')
ws.on :open do |event|
p [:open]
end
ws.on :message do |event|
p [:message, event.data]
end
ws.on :close do |event|
p [:close, event.code, event.reason]
ws = nil
end
ws.send( ''Example Text'' )
}

Gracias por adelantado. Saludos.

PD: Avíseme si necesita más código.

Answer 1

Finalmente, he encontrado la solución. El problema es que el mensaje debe ser construido con un cierto formato para que sea entendido por websocket-rails.

Ejemplo: ws.send (''["new_message", {"data": "Ejemplo de mensaje"}]'')

donde new_message es el evento que websocket-rails está escuchando.