如何在node.js中搜索流中的字符串

Question

如何在流中搜索字符串并打印它？我指的是使用CCD_ 1。我已经了解了如何使用indexOf在readFile中查找字符串，但我了解到使用流更有效。

更具体地说，我一直在尝试在流中找到一个字符串，然后打印出包含该字符串的整行。然而，以下不断给我错误

fs.createReadStream(process.argv[2], function (err, data) {
      data.indexOf ...

目前，我的程序打印出整个流，而不仅仅是包含字符串的行。

var http = require('http'); 
var fs = require('fs');
var server = http.createServer( function(req, res) {
console.log("Request received.");
res.writeHead(200, {"Content-Type": "text/plain"});
res.write("Hello Worldnnn");
var s = fs.createReadStream(process.argv[2]).pipe(res); 
s.on('end', function(){ res.end() }) 

});
server.listen(8000);

Answer 1

流是缓冲的，因此传递给data事件（您通常会侦听）的缓冲区不会以任何方式拆分为单独的行或在单独的行上定界。

您可以使用readline模块执行逐行搜索：

var fs        = require('fs');
var readline  = require('readline');
var server = http.createServer( function(req, res) {
  console.log("Request received.");
  res.writeHead(200, {"Content-Type": "text/plain"});
  res.write("Hello Worldnnn");
  readline.createInterface({
    input     : fs.createReadStream(process.argv[2]),
    terminal  : false
  }).on('line', function(line) {
    var idx = line.indexOf(THE_SUBSTRING);
    if (idx !== -1) {
      res.write(line + 'n');
    }
  }).on('close', function() {
    res.end();
  });
});

（EDIT:readline去掉换行符，所以res.write加了一个换行符）

Answer 2

您可以使用此模块在流中搜索字符串，而无需缓冲