【发布时间】:2018-11-09 11:30:56
【问题描述】:
我之前在两个 node.js 服务器之间进行过语音聊天(请参阅:tvoip),效果很好,但现在我想在 node.js 服务器和浏览器之间进行。这是怎么做到的?
从 node.js 到 node.js,我只是通过 TCP 连接使用原始 PCM 流。
对于浏览器来说,这可能不会那么容易,对吧?我的意思是浏览器并没有真正提供 TCP API。它确实提供了 WebSocket API,但它是否处理流?我是否必须将流转换为什么格式以及如何转换?我应该使用什么协议?是否有任何有用的库来实现这一点? socket.io-stream 是发送这类流的可行库吗?
据我了解,音频流在浏览器上采用 PCM 格式。所以它应该与我在 Node.js 中获得的流兼容。这个假设正确吗?
我已经设法将浏览器麦克风输入通过管道传输到浏览器扬声器输出,如下所示:
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8"/>
</head>
<body>
<!-- alternative method that also works
<audio></audio>
<script>
navigator.mediaDevices.getUserMedia({ audio: true }).then(function(stream) {
const audio = document.querySelector('audio')
audio.srcObject = stream
audio.onloadedmetadata = function(e) {
audio.play()
}
}).catch(console.error)
</script>
-->
<script>
navigator.mediaDevices.getUserMedia({audio: true}).then(stream => {
const aCtx = new AudioContext()
const analyser = aCtx.createAnalyser()
const microphone = aCtx.createMediaStreamSource(stream)
microphone.connect(analyser)
analyser.connect(aCtx.destination)
}).catch(err => {
console.error("Error getting audio stream from getUserMedia")
})
</script>
</body>
</html>
如您所见,我找到了两个解决方案。我将尝试将节点浏览器语音聊天基于第二个。
对于 Node.js,我想出了这段代码,将 node.js 麦克风输入通过管道传输到 node.js 扬声器输出:
const mic = require('mic')
const Speaker = require('speaker')
const micInstance = mic({ // arecord -D hw:0,0 -f S16_LE -r 44100 -c 2
device: 'hw:2,0', // -D hw:0,0
encoding: 'signed-integer', // -f S
bitwidth: '16', // 16
endian: 'little', // _LE
rate: '44100', // -r 44100
channels: '1', // -c 2
debug: true
})
const micInputStream = micInstance.getAudioStream()
const speakerInstance = new Speaker({ // | aplay -D plughw:CARD=0,DEV=0
channels: 1,
bitDepth: 16,
sampleRate: 44100,
signed: true,
device: 'plughw:2,0' //'plughw:NVidia,7'
})
speakerInstance.on('open', ()=>{
console.log("Speaker received stuff")
})
// Pipe the readable microphone stream to the writable speaker stream:
micInputStream.pipe(speakerInstance)
micInputStream.on('data', data => {
//console.log("Recieved Input Stream: " + data.length)
})
micInputStream.on('error', err => {
cosole.log("Error in Input Stream: " + err)
})
micInstance.start()
console.log('Started')
如果您不熟悉 Linux 下的 ALSA,为麦克风和扬声器找到合适的 device 可能会有点棘手。 It is explained here 如果您不确定。我不确定它在带有 SoX 的 Windows 和 Mac OS 上如何工作。
然后我想出了一个小型测试应用程序,使用 socket.io-stream(一个允许通过套接字发送流的 socket.io 库)连接这两个想法。很明显,这就是我被困的地方。
基本上,我在 node.js 端试试这个:
const mic = require('mic')
const Speaker = require('speaker')
const SocketIO = require('socket.io')
const ss = require('socket.io-stream')
...
io.on('connection', socket => {
let micInstance = mic(micConfig)
let micInputStream = micInstance.getAudioStream()
let speakerInstance = new Speaker(speakerConfig)
...
ss(socket).on('client-connect', (stream, data) => { // stream: duplex stream
stream.pipe(speakerInstance) //speakerInstance: writable stream
micInputStream.pipe(stream) //micInputStream: readable stream
micInstance.start()
})
})
这在浏览器端:
const socket = io()
navigator.mediaDevices.getUserMedia({audio:true}).then(clientMicStream => { // Get microphone input
// Create a duplex stream using the socket.io-stream library's ss.createStream() method and emit it it to the server
const stream = ss.createStream() //stream: duplex stream
ss(socket).emit('client-connect', stream)
// Send microphone input to the server by piping it into the stream
clientMicStream.pipe(stream) //clientMicStream: readable stream
// Play audio received from the server through the stream
const aCtx = new AudioContext()
const analyser = aCtx.createAnalyser()
const microphone = aCtx.createMediaStreamSource(stream)
microphone.connect(analyser)
analyser.connect(aCtx.destination)
}).catch(e => {
console.error('Error capturing audio.')
alert('Error capturing audio.')
})
完整的代码可以查看:https://github.com/T-vK/node-browser-audio-stream-test
(README.md 包含有关如何设置它的说明,如果您想对其进行测试。)相关代码在server.js(setupStream() 函数包含有趣的代码。)和client.html。
如您所见,我正在尝试通过连接发送双工流,并将麦克风输入通过管道传输到双工流中,并将双工流通过管道传输到每一端的扬声器(就像我在 tvoip 中所做的那样)。但是,它在 atm 中不起作用。
编辑:
我不确定我是否正确,但我从getUserMedia() 获得的“流”是MediaStream,并且该媒体流可以包含MediaStreamTracks(音频、视频或两者)。我是我的情况,它显然只是一首曲目(音频)。但是MediaStreamTrack 似乎不是stream,因为我从Node.js 知道它,这意味着它不能只是通过管道传输。所以也许它必须被转换成一个。我发现了一个名为microphone-stream 的有趣库,它声称能够做到这一点。但它似乎不能作为一个简单的浏览器库使用。似乎需要用 browserify 包装你的整个项目。这似乎非常矫枉过正。我想保持简单。
【问题讨论】:
标签: javascript node.js audio browser voip