从套接字连接收集的二进制数据生成视频文件

generate video file from binary data collected from socket connection

我已经创建了一个套接字连接并使用该连接将二进制流数据发送到服务器,在服务器端我正在使用该数据获取二进制数据我想创建一个视频文件并将其保存在服务器上。我成功地获得了二进制数据,现在没有任何方法可以将其转换为视频文件。请帮助实现。

在服务器端 m 使用 node.js 创建套接字服务器,在客户端 javascript

服务器端代码:

var server = http.createServer(function(request, response) {
    //Creating websocket server
});
server.listen(1337, function() { }); // listen to 1337 port

// create the server
wsServer = new WebSocketServer({
    httpServer: server
});

// WebSocket server
wsServer.on('request', function(request) {
    var connection = request.accept(null, request.origin);

    // all messages from client will receive here.
    connection.on('message', function(message) {
      if (message.type === 'utf8') {

      }else if (message.type === 'binary') {
           //here i will get the binary data not want to create the video file using this
      }
    });

    connection.on('close', function(connection) {


    });

})

客户端:

window.WebSocket = window.WebSocket || window.MozWebSocket;
    var connection = new WebSocket('ws://localhost:1337');
    connection.binaryType = 'arraybuffer';
    var options = {
      mimeType: 'video/webm;codecs=vp9'
    };

    mediaRecorder = new MediaRecorder(MediaStream, options);
    mediaRecorder.ondataavailable = function(event) {
      if (event.data.size > 0) {
        recordedChunks.push(event.data);
         connection.onopen = function () {
            var byteArray = new Uint8Array(event.data);
            connection.send(byteArray.buffer);
         };
      }
    };

我已经成功地在服务器上创建了视频文件我使用了 recordRTC api 将视频流转换为 dataurl 并使用 socket.io 发送到服务器并在服务器上将 dataurl 转换为 base64 和将其写入文件。

这是我的客户端代码。

socketio = io("ws://192.168.0.42:1337");
  recordVideo = RecordRTC(MediaStream, {type: 'video'});
  recordVideo.startRecording();
  onStopRecording();
  function onStopRecording(){
      recordVideo.stopRecording(function() {
        recordVideo.getDataURL(function(videoDataURL) {
                  var d = new Date();
                   var files = {
                       video: {
                           type: recordVideo.getBlob().type || 'video/webm',
                           dataURL: videoDataURL,
                           time : d.getTime()
                       }
                   };
                   socketio.emit('message', files);
         })
      });
  }

从服务器端:

var server = http.createServer(function(request, response) {
    //Creating websocket server
});
server.listen(1337, function() { }); // listen to 1337 port


var wIoSocket = io.listen(server);
wIoSocket.sockets.on('connection', function (socket) {
    socket.on('message', function (data) {
        if (data.video) {
            writeToDisk(data.video.dataURL, data.video.time+'.webm');
        }
    });
});


function writeToDisk(dataURL, fileName) {
    var dataURL = dataURL.split(',').pop();
    var fileBuffer = new Buffer(dataURL, 'base64');
    fs.writeFileSync(fileName, fileBuffer);
}