ネットソケットを使用したNodeJS、OpenCVおよびストリーミングイメージ

Question

私の最終目標は、ラップトップからサーバーにビデオをストリームすることです。私はノートパソコンのNodeJsを使ってこれを達成しようとしています&サーバ。 OpenCVライブラリを使ってノートパソコンのビデオをキャプチャし、jpgファイルに保存します。次に、ファイルを読み込んでbase64に変換して、ノードのNet.socketモジュールを使用してファイルを転送できるようにします。これは連続的なプロセスです。キャプチャ、エンコード、および送信です。 FINは、サーバから受信されるまで、クライアントのIループで

var cv = require('opencv'); 
var fs = require('fs'); 
var net = require('net'); 
var camera = new cv.VideoCapture(0); 
var server = net.createServer(); 
server.listen('50007', '127.0.0.1'); 

server.on('connection', function(socket){ 
    camera.read(function(image){ 
     image.save('original.jpg'); 

     fs.readFile('original.jpg', 'base64', function(err, image){ 
      socket.write(image, 'base64', function(){ 
       socket.end(); 
      }); 
     }); 
    }); 
}); 

：ここ

はただ一つのjpgファイルを送信するためのサーバーコードです。ここでは、クライアントコードは次のとおりです。

var net = require('net'); 
var fs = require('fs'); 
var client = new net.Socket(); 
var buffer =''; 
client.setEncoding('base64'); 

client.connect('50007', '127.0.0.1', function(){ 
    console.log('Connecting to server...'); 
}); 

client.on('data', function(data){ 
    buffer += data; 
}); 

client.on('end', function(){ 
    var dataBuffer = new Buffer(buffer, 'base64'); 
    fs.writeFile('copy.jpg', dataBuffer, function(err){ 
     if(err){ 
      console.log(err); 
     } 
    }); 
}); 

問題は、画像全体が実際に送信されないということです。私が受け取ったファイル、copy.jpgを開いたとき、常に下部に欠けているチャンクがあります。

最後のバージョンでは、1つのjpgを別のものに送り、 'EndOfFile'などのキーワードを使用して各 'jpg'の終わりを区切ります。私は送信する前にbase64でエンコードされたイメージにキーワード 'EndOfFile'を追加することでこれをやろうとしましたが、受信側では本当に台無しになってしまいました。

サンプルのAdvanced Server：

fs.readFile('original.jpg', 'base64', function(err, image){ 
    image += 'EndOfFile'; 
    socket.write(image, 'base64'); 
}); 

一つのクライアント側は、ループは、キーワードのデータの各チャンクを調べるでしょうし、それが見つかった場合には、バッファにあるものは何でもファイルに書き込まれ、バッファがリセットされます、次のファイルの準備が整いました。私はPythonで動作するようにこれを得ている

client.on('data', function(data){ 
    if(data.indexOf('EndOfFile') > 0){ 
     buffer += data.substr(0, data.indexOf('EndOfLine')); 
     var dataBuffer = new Buffer(buffer, 'base64'); 

     fs.writeFile('copy.jpg', dataBuffer, function(err){ 
      if(err){ 
       console.log(err); 
      } 
     }); 

     buffer = ''; 
    } else { 
     buffer += data; 
    } 
}); 

サンプルアドバンストクライアントはので、私は私のロジックが正しいことだと思うが、私はNodeJSのように快適ではありませんよ。

これが本物の方法であるのか、どこで間違っているのか誰かが私に教えてもらえますか。

ありがとうございます！

Answer 1

データの最後のビットがまだバッファされている間にendイベントが発生していると思われます。

endイベントではなく、closeイベントを待ってください。私はソケットについてはわかりませんが、spawnのような他のNode APIでは、関連するストリームがフラッシュされる前に、endイベントが早く起動されるため、待機中のバッファされたデータが残っている可能性があります。

配管でこれを自分で管理することは避けることができます。ファイルへのソケットストリームはfs.createWriteStream()と.pipe()です。