Stream.pipe 事件“结束”仅在 Nodejs socket.io-stream 上触发一次

Question

我有一个使用 nodejs 设置的服务器和一个客户端。服务器正在使用 socket.io-stream 向客户端发送文件。传输文件后，我想开始在客户端使用它。为此，我正在听流的“结束”事件。 我的代码有效，但只有一次。在我发送的第一个文件上触发了事件，但在下一个文件上没有。在第一个文件之后，下一个文件已损坏并且为 0 字节。

server.js

 socketObj.emit('order', orderData);

 ss(socketObj).on('file', function(stream) {
            fs.createReadStream('./uploads/'+ orderData.file.name +'').pipe(stream);
 });

client.js

socket.on('order', function(data) {

    var stream = ss.createStream();

    ss(socket).emit('file', stream);

    stream.pipe(fs.createWriteStream(data.file.name));

    stream.on('end', function(){
        doSomeStuff(data); //This function is called only once
    });

});

我尝试使用'end' 和'finish' 事件，将autoClose 设置为true 和false，使用stream.close() 和stream.end()，但没有任何效果。对我来说，就像有些东西没有正确重置。

Answer 1

在你的 client.js 文件中试试这个：

socket.on('order', function(data) {

    var stream = ss.createStream();
    var writeStream = fs.createWriteStream(data.file.name);

    ss(socket).emit('file', stream);

    stream.pipe(writeStream);

    writeStream.on('close', function(){
        doSomeStuff(data);
    });

});