将 websockets 与标准 http.Server 集成

Question

我有一个简单的网络服务器喜欢

var http = require('http'),
    url = require('url');
var server = http.createServer(function (req, res) {
  var uri = url.parse(req.url).pathname;
  if (uri == '/') {
    res.writeHead(200, {'Content-Type': 'text/plain'});
    res.end('Hello World\n');
    return;
  }

  res.writeHead(404, {'Content-Type': 'text/plain'});
  res.end('File not found');
});
server.listen(0, '127.0.0.1');

我现在想将单个路径（例如，

/ws

）连接到 Websocket，但保持服务器的其余部分不变。

但是，ws似乎要求我设置一个专用服务器（包含所需的一切，例如 SSL 终止、安全配置和端口分配）。

如何仅终止 Websocket 实现的路径

/ws

？

Answer 1

我建议使用 websocket 包，它是一个

Websocket 客户端和服务器库实现 RFC 6455 中指定的 WebSocket 协议。

这就是我想要的，所以这就是我使用它的原因。使用起来非常轻松，而且我实际上正在使用纯 javascript websockets 从 html 客户端对 Node.js 进行 wss 和 ws 连接。

git 项目处于活动状态，当我发布问题时，我会在同一天得到回复。上面链接中的示例显示了它是多么简单：

var WebSocketServer = require('websocket').server;
var http = require('http');

var server = http.createServer(function(request, response) {
    console.log((new Date()) + ' Received request for ' + request.url);
    response.writeHead(404);
    response.end();
});
server.listen(8080, function() {
    console.log((new Date()) + ' Server is listening on port 8080');
});

wsServer = new WebSocketServer({
    httpServer: server,
    autoAcceptConnections: false
});

function originIsAllowed(origin) {
  // put logic here to detect whether the specified origin is allowed.
  return true;
}

wsServer.on('request', function(request) {
    if (!originIsAllowed(request.origin)) {
      // Make sure we only accept requests from an allowed origin
      request.reject();
      console.log((new Date()) + ' Connection from origin ' + request.origin + ' rejected.');
      return;
    }

    var connection = request.accept('echo-protocol', request.origin);
    console.log((new Date()) + ' Connection accepted.');
    connection.on('message', function(message) {
        if (message.type === 'utf8') {
            console.log('Received Message: ' + message.utf8Data);
            connection.sendUTF(message.utf8Data);
        }
        else if (message.type === 'binary') {
            console.log('Received Binary Message of ' + message.binaryData.length + ' bytes');
            connection.sendBytes(message.binaryData);
        }
    });
    connection.on('close', function(reasonCode, description) {
        console.log((new Date()) + ' Peer ' + connection.remoteAddress + ' disconnected.');
    });
});

但是，我应该注意，子协议并不明显，因为没有示例。不过，该项目的 git 网站上有一些问题可以引导您走向正确的方向。

Answer 2

您可以将 socket.io 添加到与您的应用程序相同的端口上。如果您想要 /ws 路径，请使用：

var io = require('socket.io').listen(httpServer, { resource: '/ws/socket.io' });

或者让

/ws

指向

/ws/socket.io

Answer 3

找到这种在 http 协议之上创建服务器的方法很有趣，但是嘿，迟到总比不到好