WebSocket协议的Node.js实现:WebSocket-Node

jopen 8年前

WebSocket-Node 是对 WebSocket 协议实现的 Node.js 扩展(Draft -08 through the final RFC 6455)。

  • Licensed under the Apache License, Version 2.0
  • Protocol version "8" and "13" (Draft-08 through the final RFC) framing and handshake
  • Can handle/aggregate received fragmented messages
  • Can fragment outgoing messages
  • Router to mount multiple applications to various path and protocol combinations
  • TLS supported for outbound connections via WebSocketClient
  • TLS supported for server connections (use https.createServer instead of http.createServer)
    • Thanks to pors for confirming this!
  • Cookie setting and parsing
  • Tunable settings
    • Max Receivable Frame Size
    • Max Aggregate ReceivedMessage Size
    • Whether to fragment outgoing messages
    • Fragmentation chunk size for outgoing messages
    • Whether to automatically send ping frames for the purposes of keepalive
    • Keep-alive ping interval
    • Whether or not to automatically assemble received fragments (allows application to handle individual fragments directly)
    • How long to wait after sending a close frame for acknowledgment before closing the socket.

浏览器支持情况:

  • Firefox 7-9 (Old) (Protocol Version 8)
  • Firefox 10+ (Protocol Version 13)
  • Chrome 14,15 (Old) (Protocol Version 8)
  • Chrome 16+ (Protocol Version 13)
  • Internet Explorer 10 (Preview) (Protocol Version 13)
  • Safari 6 (Protocol Version 13)

服务器端示例代码:

#!/usr/bin/env node  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,      // You should not use autoAcceptConnections for production      // applications, as it defeats all standard cross-origin protection      // facilities built into the protocol and the browser.  You should      // *always* verify the connection's origin and decide whether or not      // to accept it.      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.');      });  });

项目主页:http://www.open-open.com/lib/view/home/1385041974906