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 做到这一点。

我假设您需要让 fake_manager 监听由 manager_emulator 触发的事件。

如果您使用 websocket 网络应用程序框架，这将非常容易。例如，在 Plezi web-app framework 你可以这样写：

# 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:password@my.host: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

祝你好运！

P.S.

如果你打算继续使用EM，你可以考虑使用Redis在两个端口之间推送和订阅事件。

Answer 2

我已经通过 em-websocket gem 找到了方法！您只需要在 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

em-websocket send() 通过 2 个服务器从一个客户端发送到另一个客户端

em-websocket send() send from one client to another through 2 servers

ruby

ruby-on-rails

websocket

em-websocket