使用 Node.js 和 WebSocket 传输二进制文件

我已经在谷歌上搜索这个并在 stackoverflow 上搜索了一段时间，但还没有找到解决方案 - 因此发表了这篇文章。

出于好奇，我正在尝试使用 Node.js 和 WebSockets。我正在尝试将一些二进制数据（mp3）传输到客户端。到目前为止，我的代码如下，但显然没有按预期工作。

我怀疑我的问题是我实际上并没有从服务器发送二进制数据，并且需要一些澄清/帮助。

这是我的服务器...

var fs = require('fs');
var WebSocketServer = require('ws').Server;

var wss = new WebSocketServer({port: 8080,host:"127.0.0.1"});
wss.on('connection', function(ws) {    
    var readStream = 
    fs.createReadStream("test.mp3", 
     {'flags': 'r',
      'encoding': 'binary', 
      'mode': 0666, 
      'bufferSize': 64 * 1024});

    readStream.on('data', function(data) {
        ws.send(data, {binary: true, mask: false});
    });
});

还有我的客户...

context = new webkitAudioContext();
var ws = new WebSocket("ws://localhost:8080");
ws.binaryType = 'arraybuffer';

ws.onmessage = function (evt) {
    context.decodeAudioData(
    evt.data,
        function(buffer) {
            console.log("Success");
        }, 
        function(error) {
            console.log("Error");
        });
};

对解码的调用始终以错误回调结束。我假设这是因为它收到了错误的数据。

所以我的问题是如何正确地将文件传输为二进制文件？

Thanks

您的服务器所做的是将包含 64 KB 块的二进制音频数据的消息发送到您的客户端。您的客户应该在调用之前重建音频文件decodeAudioData.

你正在呼唤decodeAudioData每次你的客户端在 websocket 上收到消息时。您必须创建一个单独的缓冲区来将所有块添加到其中。然后在传输完成后，应向缓冲区提供输入decodeAudioData.

您现在有两个选择：

1. 您可以在不使用流事件的情况下加载整个文件（fs.read）并使用 ws.send 发送整个文件（很容易做到）
2. 您使用流事件，修改客户端以接受数据块并在调用之前组装它们decodeAudioData