Node.js中监听process/stdout/stdin及无影响捕获输入输出至文件
嘿,我来帮你搞定这两个Node.js里的IO捕获问题,都是实际开发中可能碰到的需求,咱们一步步来:
1. 如何监听process.stdout和process.stdin
监听process.stdout
stdout本质是一个可写流(Writable Stream),要监听它的输出,咱们可以通过包装它原本的write方法来实现——既不会打断原有输出,又能捕获到内容:
// 先把原始的stdout.write存起来,别弄丢了 const originalStdoutWrite = process.stdout.write; // 重写write方法,加入咱们的监听逻辑 process.stdout.write = function(chunk, encoding, callback) { // 这里就是你捕获到的输出内容,想干嘛都行,比如打印个标记 console.log(`[捕获到stdout]: ${chunk.toString().trim()}`); // 一定要调用原始的write方法,保证内容正常输出到控制台 return originalStdoutWrite.apply(this, arguments); }; // 测试一下,你会看到控制台既有原输出,又有咱们的捕获日志 console.log("Hello, Node.js stdout!");
监听process.stdin
stdin是可读流(Readable Stream),直接监听它的data事件就能获取输入内容,记得先开启流动模式:
// 开启stdin的流动模式,不然它会等着手动读取 process.stdin.resume(); // 设置编码,避免拿到Buffer process.stdin.setEncoding('utf8'); // 监听输入数据 process.stdin.on('data', (input) => { const trimmedInput = input.trim(); console.log(`[捕获到stdin输入]: ${trimmedInput}`); // 比如输入exit就停止监听 if (trimmedInput === 'exit') { process.stdin.pause(); } }); // 监听输入结束的事件 process.stdin.on('end', () => { console.log("stdin输入流结束啦"); });
2. 不影响原有IO的前提下捕获保存到文件
这个需求的核心是让IO内容“同时走两路”:一路正常输出到控制台/被应用读取,另一路写入文件。咱们不用重定向(重定向会改变原有IO的流向),用包装方法+文件流就能实现:
const fs = require('fs'); // 创建三个文件流,分别存stdout、stderr、stdin的内容,用追加模式避免覆盖 const stdoutLog = fs.createWriteStream('./stdout.log', { flags: 'a' }); const stderrLog = fs.createWriteStream('./stderr.log', { flags: 'a' }); const stdinLog = fs.createWriteStream('./stdin.log', { flags: 'a' }); // 处理stdout:同时输出到控制台和文件 const originalStdoutWrite = process.stdout.write; process.stdout.write = function(chunk, encoding, callback) { stdoutLog.write(chunk, encoding); // 写入日志文件 return originalStdoutWrite.apply(this, arguments); // 保持原有输出 }; // 处理stderr:和stdout逻辑一样 const originalStderrWrite = process.stderr.write; process.stderr.write = function(chunk, encoding, callback) { stderrLog.write(chunk, encoding); return originalStderrWrite.apply(this, arguments); }; // 处理stdin:监听输入,同时写入文件,不影响应用原本的输入处理 process.stdin.resume(); process.stdin.setEncoding('utf8'); process.stdin.on('data', (input) => { stdinLog.write(input); // 写入输入日志 // 这里应用原本的stdin处理逻辑完全不受影响,比如下面的打印只是示例 console.log(`你刚才输入了: ${input.trim()}`); }); // 进程退出时记得关闭所有文件流,防止数据丢失 process.on('exit', () => { stdoutLog.end(); stderrLog.end(); stdinLog.end(); }); // 测试一下 console.log("这条内容会同时出现在控制台和stdout.log"); console.error("这条错误信息会同时出现在控制台和stderr.log"); // 现在你在控制台输入内容,会同时被保存到stdin.log,且正常被应用读取
小提醒
- 用
flags: 'a'是为了每次启动都追加日志,不会覆盖之前的内容;如果需要覆盖,改成'w'就行。 - 如果是高并发的大流量场景,要注意处理流的背压问题(比如监听
drain事件),不过普通场景上面的代码足够用了。
内容的提问来源于stack exchange,提问作者faressoft
相关产品推荐
相关产品推荐

