节点(套接字)直播音频流/广播

Question

拜托,有没有简单的方法来通过的Node.js和可能SOCKET.IO从服务器流式传输(广播)的媒体文件(OGG,MP3,SPX ..)客户端(浏览器)？

我必须在服务器端录制音频输入,然后才能为许多客户端实时播放.我一直在搞乱binary.js或socket.io流,但是无法正确使用它.

我试图用speex,vorbis或lame对音频输入进行编码,然后通过FS将其加载到客户端,但我还没有成功.或者我必须捕获PCM然后在浏览器中解码它？

对此有任何建议,我发现没有任何帮助过我.

非常感谢任何提示,链接和想法.

Answer 1

您将需要查找适用于Streams的软件包,并从那里开始根据需要将流输出到输出.使用Express或仅使用内置HTTP,您可以非常轻松地完成此任务.这是一个围绕osx-audio构建的示例,它提供了一个PCM流,lame可以将流编码为mp3,而Express:

var Webcast = function(options) {

  var lame = require('lame');
  var audio = require('osx-audio');
  var fs = require('fs');

  // create the Encoder instance
  var encoder = new lame.Encoder({
    // input
    channels: 2,        // 2 channels (left and right)
    bitDepth: 16,       // 16-bit samples
    sampleRate: 44100,  // 44,100 Hz sample rate

    // output
    bitRate: options.bitrate,
    outSampleRate: options.samplerate,
    mode: (options.mono ? lame.MONO : lame.STEREO) // STEREO (default), JOINTSTEREO, DUALCHANNEL or MONO
  });

  var input = new audio.Input();
  input.pipe(encoder);

  // set up an express app
  var express = require('express')
  var app = express()

  app.get('/stream.mp3', function (req, res) {
    res.set({
      'Content-Type': 'audio/mpeg3',
      'Transfer-Encoding': 'chunked'
    });
    encoder.pipe(res);
  });

  var server = app.listen(options.port);
}

module.exports = Webcast;

如何获得输入流可能是最有趣的部分,但这取决于您的实现.流行的request软件包也是围绕Streams构建的,所以它可能只是一个HTTP请求!

Answer 2

在Web浏览器上，您具有HTML5视频元素和音频元素。他们两个都有来源。每个Web浏览器本身都支持不同的编解码器。因此，如果您要流式传输mp3，则需要注意这一点。

您不需要socket.io，只需要HTTP。您的应用正在读取文件，music.ogg并且对于每个读取的块，它将通过http服务器发送该文件。这将是一个一直保持打开状态的HTTP请求，直到文件传输完毕。

这是您的html外观：

<audio src="http://example.com/music.ogg"></audio>

您的nodejs代码将是这样的（尚未测试）：

var http = require('http');
var fs = require('fs');

http.on('request', function(request, response) {
    var inputStream = fs.open('/path/to/music_file.ogg');
    inputStream.pipe(response);
})

我仅在上述代码的http和fs模块上使用ReadableStream.pipe方法inputStream。如果要对音频文件进行转码（例如，从mp3转换为ogg），则需要找到一个可以执行此操作的模块，然后将文件中的数据传输到转码器中，然后输入response：

// using some magical transcoder
inputStream.pipe(transcoder).pipe(response);

该方法将end在完成写入后立即调用流，以便在读取（和转码）文件后立即完成HTTP请求。

Answer 3

您可以使用节点和 RTC 来完成此操作。有一些工具可供使用，例如SimpleWebRTC或EasyRTC。对于我已经测试过的视频来说仍然是一个麻烦，但音频效果很好。