池Websocket连接-NodeJS

Question

我希望构建一个节点应用程序，将实现以下目标：

null

chat.prototype.connect = function() {
var self = this;
  self.ws = new ws(url);
  self.ws.on('message', function(data, flags) {
    var message = JSON.parse(data);
    self.handle(message);
  });
};

Answer 1

假设您将需要连接的URL列表存储在名为urls的实例属性中。您可以这样设置连接：

chat.prototype.connect = function() {
  urls.forEach(this.connectOne.bind(this));
};

chat.prototype.connectOne = function(url) {
  var handle = this.handle.bind(this);
  var conn   = this.connections[url] = new ws(url);
  conn.on('message', function(data, flags) {
    var message = JSON.parse(data);
    handle(message);
  });
};

要实现添加新连接，请定期查询数据库，并检查每个URL是否已经存在于this.connections中；如果没有，可以使用this.connectone()添加它。您可以执行类似的操作来删除连接。