Streaming Binary con Node.js e WebSockets

Question

Ho cercato su Google questo e guardandomi attorno a StackOverflow per un po 'ma non ho trovato una soluzione - da qui il post.

Sto giocando con Node.js e WebSockets per curiosità. Sto cercando di trasmettere alcuni dati binari (un mp3) al client. Il mio codice finora è sotto ma ovviamente non funziona come previsto.

Sospetto che il mio problema è che in realtà non sto inviando dati binari dal server e vorrei qualche chiarimento/aiuto.

Heres mio server ...

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}); 
    }); 
}); 

e il mio cliente ...

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"); 
     }); 
}; 

La chiamata di decodificare sempre finiscono nella richiamata errore. Presumo questo perché riceve dati errati.

Quindi la mia domanda è come eseguire correttamente il flusso del file come file binario?

Grazie

Answer 1

Problema risolto.

Ho risolto questo problema con una combinazione di rimuovere il " 'encoding': 'binario'" parametro dei opzioni passate a "createReadStream()" e la soluzione a ...

decodeAudioData returning a null error

Come alcuni dei miei commenti, quando ho aggiornato le opzioni createReadStream, il primo blocco era in riproduzione, ma tutti gli altri blocchi eseguivano il callback onError da decodeAudioData(). La soluzione nel link sopra ha risolto questo problema per me. Sembra che decodeAudioData() sia un po 'schizzinoso su come i blocchi che riceve dovrebbero essere formattati. Essi dovrebbero essere validi pezzi apparentemente ...

Define 'valid mp3 chunk' for decodeAudioData (WebAudio API)

Answer 2

Che il server sta facendo è che è l'invio di dati costituite da dati audio binari in 64 KB pezzi al vostro cliente. Il client dovrebbe ricostruire il file audio prima di chiamare decodeAudioData.

Stai chiamando decodeAudioData ogni volta che il tuo cliente riceve un messaggio su websocket. Devi creare un buffer separato per aggiungere tutti i pezzi ad esso. Quindi, al completamento del trasferimento, il buffer deve essere immesso in decodeAudioData.

Sono disponibili due opzioni: ora

1. si carica tutto il file (fs.read) senza l'utilizzo di eventi di flusso e inviare l'intero file con ws.send (facile da fare)
2. Si utilizza eventi streaming , modifica il tuo client per accettare blocchi di dati e assemblarli prima di chiamare decodeAudioData