node.js - 使用 ws 和 websocket-stream 在 node.js 中流式传输数据

Question

我正在尝试使用 websocket 将数据从服务器流式传输到客户端 - 特别是 ws 和 websocket 流。但是，流似乎关闭得太早了，我只收到了两 block 数据。这是一个简单的例子。

我有一个服务器:

var WebSocketServer = require('ws').Server;
var websocketStream = require('websocket-stream');

var wss = new WebSocketServer({port: 8098});
var fs = require('fs');
var util = require('util');

wss.on('connection', function connect(ws) {
  var stream = websocketStream(ws);
  var rs = fs.createReadStream('foo.big');
  rs.pipe(stream);
});

和一个使用 pipe() 连接和流式传输 foo.big 到本地文件的客户端:

var fs = require('fs');
var util = require('util');
var websocket = require('websocket-stream');

var rs = fs.createWriteStream('big.out');

rs.on('open', function () {
  var ws = websocket('http://localhost:8098');

  ws.on('open', function () {
    ws.pipe(rs);
  }).on('error', function (err) {
    console.log(err);
  }).on('close', function (err) {
    console.log("Closing");
  });
});

任何想法为什么我只会得到几个数据包？如果我删除客户端中对管道的调用，并且只接收 block 中的数据，它似乎接收到所有数据。

Answer 1

上述有几处问题(截至 2017 年)。

1. 您宁愿监听 fs.readStream() close 事件
2. 你不应该监听 websocket-stream open 事件，因为你可以假设它是打开的

另外，性能:ws 可能不适合服务器到服务器的通信。考虑替代方案，如 net，如 here ，或其他低于 ws 级别的方式。

查找完整示例 here on my GH .

const fs = require('fs')
const websocket = require('websocket-stream')

const writeStream = fs.createWriteStream('big.out')

writeStream.on('open', () => {
  let ws = websocket('http://localhost:8098')

  ws.pipe(writeStream)

  ws.on('error', (err) => {
    if (err) throw err
  }).on('close', (err) => {
    if (err) throw err
    console.log(`Closing ws with: ${fs.statSync('big.out').size} bytes`)
  })

  writeStream.on('close', () => {
    console.log(`Closing file stream with: ${fs.statSync('big.out').size} bytes`)
  })
})