0

我真的很喜欢 EventEmitter 范例,我想用它在网络上的两个程序之间进行通信。

我想出了自己的SockEmitter,但我想知道:我是不是“做错了(tm)”?是否有一些软件包已经可以做到这一点?是否有不同的范式更适合通过网络进行通信?

这是我所拥有的:

var JsonSocket = require('json-socket')

// An event emitter that uses a JsonSocket.
// emit passes things over the wire, and data received
// over the wire calls the listeners.
//
// As a result, se.on('foo', console.log); se.emit('foo', 5)
// won't do what you might normally expect from an emitter.

function SockEmitter(socket) {
  this._listeners = {}
  this.sock = new JsonSocket(socket)
  this.sock.on('message', this._message.bind(this))
}

SockEmitter.prototype = {
  on: function (type, handler) {
    if (!this._listeners[type]) {
      this._listeners[type] = [];
    }
    this._listeners[type].push(handler)
  },
  off: function (type, handler) {
    if (!this._listeners[type]) {
      return false
    }
    var idx = this._listeners[type].indexOf(handler)
    if (idx === -1) return false
    this._listeners[type].splice(idx, 1)
  },
  emit: function (type) {
    var args = [].slice.call(arguments, 1)
    this.sock.sendMessage({type: type, args: args})
  },
  _message: function (message) {
    if (!message || !message.type || !Array.isArray(message.args)) {
      return console.error('Invalid message received: %s', message)
    }
    if (!this._listeners[message.type]) return
    this._listeners[message.type].forEach(function (handler) {
      handler.apply(null, message.args)
    })
  }
}
4

2 回答 2

3

Socket.io 经常为这样的事情而出现。它以事件的方式提供 2 路通信。然而,人们经常查看Server Sent Events,这是一个 W3C 标准,用于使用标准 http 消息的单向事件(而不是UPGRADE像 socket.io 这样的自定义协议)。

使用SSE,您可能会看到许多专注于服务器到浏览器通信的文章,但规范定义了一个简单的基于 http 的消息结构,可以用于任何您想要的(例如:服务器到服务器)。

我一直在使用它并取得了巨大的成功。我可以构建事件服务器到服务器的东西,然后也可以轻松地与浏览器连接,这真是太棒了。正如预期的那样,IE 还没有加入,但大多数浏览器都加入了。

有许多SSE npm 模块。我已经eventsource-node成功地用于“聆听”端。当我开始使用SSE时,没有用于发送事件的模块——只有用于监听的模块;所以我写了我自己的。不过这没什么大不了的——该协议非常简单,只需要大约 100 行代码。我确信其中一个已发布的模块会很好用。

于 2013-08-03T18:36:07.087 回答
1

如果始终知道对等方的 IP 地址,则使用 json-socket 的解决方案将起作用 - 典型的客户端/服务器模型,其中许多 TCP 客户端连接到单个 TCP 服务器。如果您需要向所有其他客户端发送事件,那么您将需要在服务器上实现一种类似于聊天的应用程序,服务器将从客户端接收到的消息转发给其余客户端。然后,正如 shennan 提到的,使用 socket.io 可能是您的解决方案。如果您需要直接的 N 对 N 或对等连接,维护对等地址(可能会随着时间的推移而改变)将是一场噩梦。

另一种解决方案是使用 Redis 发布/订阅功能。(这是数据中心集群通信的流行解决方案之一。有一个名为“devents”的好工具。https: //npmjs.org/package/devents

于 2013-08-03T05:41:16.580 回答