0

我有两个 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

我试图做一些事情，但我得到了通常的暗代码，我不知道如何实现这个功能。

4

2 回答 2

0

我不确定你会如何使用 EM 来做到这一点。

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

如果您使用 websocket web-app 框架，那将非常容易。例如，在Plezi web-app 框架上，您可以编写如下内容：

# 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

祝你好运！

附言

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

于 2015-05-29T04:01:16.743 回答
0

我找到了一种方法来通过em-websocketgem 做到这一点！您只需要在 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
于 2015-05-30T07:31:53.340 回答