tcp_server.js 566 B

1234567891011121314151617181920212223
  1. var net = require('net'),
  2. websocket = require('..'),
  3. deflate = require('permessage-deflate');
  4. var server = net.createServer(function(connection) {
  5. var driver = websocket.server();
  6. driver.addExtension(deflate);
  7. driver.on('connect', function() {
  8. if (websocket.isWebSocket(driver)) driver.start();
  9. });
  10. driver.on('close', function() { connection.end() });
  11. connection.on('error', function() {});
  12. connection.pipe(driver.io);
  13. driver.io.pipe(connection);
  14. driver.messages.pipe(driver.messages);
  15. });
  16. server.listen(process.argv[2]);