em-websocket send() отправляет от одного клиента другому через 2 сервера

Question

У меня есть два клиента websocket, и я хочу обмениваться информацией между ними.

Допустим, у меня есть два экземпляра серверов сокетов, и первый - это получение приватной информации, ее фильтрация и отправка второму.

require 'em-websocket'

EM.run do
  EM::WebSocket.run(host: '0.0.0.0', port: 19108) do |manager_emulator|
    # retrieve information. After that I need to send it to another port (9108)
  end

  EM::WebSocket.run(host: '0.0.0.0', port: 9108) do |fake_manager|
    # I need to send filtered information here
  end
end

Я пытался что-то сделать, но я получил обычный мрачный код и не знаю, как реализовать эту функцию.

Answer 1

Я нашел способ, как сделать это через em-websocket драгоценный камень! Вам нужно просто определить переменные вне блока eventmachine. Что-то вроде того

require 'em-websocket'

message_sender = nil

EM.run do
  # message sender
  EM::WebSocket.run(host: '0.0.0.0', port: 19108) do |ws|
    ws.onopen { message_sender = ws }
    ws.onclose { message_sender = nil }
  end

  # message receiver
  EM::WebSocket.run(host: '0.0.0.0', port: 9108) do |ws|
    ws.onmessage { |msg| message_sender.send(msg) if message_sender }
  end
end

Answer 2

Я не уверен, как бы вы сделали это с помощью EM.

Я предполагаю, что вам понадобится, чтобы fake_manager прослушивал событие, запускаемое manager_emulator.

Было бы очень легко, если бы вы использовали фреймворк websocket для веб-приложений. Например, в среде веб-приложений Plezi вы можете написать что-то вроде этого:

# try the example from your terminal.
# use http://www.websocket.org/echo.html in two different browsers to observe:
#
# Window 1: http://localhost:3000/manager
# Window 2: http://localhost:3000/fake

require 'plezi'

class Manager_Controller
    def on_message data
        FakeManager_Controller.broadcast :_send, "Hi, fake! Please do something with: #{data}\r\n- from Manager."
        true
    end
    def _send message
        response << message
    end
end
class FakeManager_Controller
    def on_message data
        Manager_Controller.broadcast :_send, "Hi, manager! This is yours: #{data}\r\n- from Fake."
        true
    end
    def _send message
        response << message
    end
end
class HomeController
    def index
        "use http://www.websocket.org/echo.html in two different browsers to observe this demo in action:\r\n" +
        "Window 1: http://localhost:3000/manager\r\nWindow 2: http://localhost:3000/fake\r\n"
    end
end

# # optional Redis URL: automatic broadcasting across processes or machines:
# ENV['PL_REDIS_URL'] = "redis://username:[e-mail]:6379"

# starts listening with default settings, on port 3000
listen

# Setup routes:
# They are automatically converted to the RESTful route: '/path/(:id)'
route '/manager', Manager_Controller
route '/fake', FakeManager_Controller
route '/', HomeController

# exit terminal to start server
exit

Удачи!

PS

Если вы собираетесь придерживаться EM, вы можете рассмотреть возможность использования Redis для отправки и подписки на события между двумя портами.