nodejs实现tail -f功能

‘use strict’;const fs = require(‘fs’);/** * tailf * * @param {String} filename 文件名 * @param {Number} delay 读取不到内容时等待的时间，ms * @param {Function} onError 操作出错时的回调函数，onError(err) * @param {Function} onData 读取到文件内容时的回调函数，onData(data) */function tailf(filename, delay, onError, onData) { // 每次读取文件块大小，16K const CHUNK_SIZE = 16 * 1024; // 打开文件，获取文件句柄 fs.open(filename, ‘r’, (err, fd) => { if (err) return onError(err); // 文件开始位置 fs.fstat(fd, (err, stats) => { if (err) return onError(err); // 文件开始位置 let position = stats.size; // 循环读取 const loop = () => { const buf = Buffer.alloc(CHUNK_SIZE); fs.read(fd, buf, 0, CHUNK_SIZE, position, (err, bytesRead, buf) => { if (err) return onError(err); // 实际读取的内容长度以 bytesRead 为准 // 并且更新 position 位置 position += bytesRead; onData(buf.slice(0, bytesRead)); if (bytesRead < CHUNK_SIZE) { // 如果当前已到达文件末尾，则先等待一段时间再继续 // setTimeout(loop, delay); } else { loop(); } }); }; loop(); // 监听文件变化，如果收到 change 事件则尝试读取文件内容 fs.watch(filename, (event, filename) => { if (event === ‘change’) { loop(); } }); }); });}const filename = process.argv[2];if (filename) { tailf(filename, 100, err => { if (err) console.error(err); }, data => { process.stdout.write(data); });} else { console.log(‘使用方法： node tailf <文件名>’);}