使用socket.io在页面上输出实时日志

const exec = require('child_process').exec;
//存储所有stream的集合
const streams = {};

/**
 * 用tail -f读文件
 * @param file
 * @return id
 */
function watchFile(file) {
  return watchProcess(`tail -f ${file}`);
}

/**
 * 自定义的命令行，比如pm2 logs 0
 * @param cmd
 * @return id
 */
function watchProcess(cmd) {
  return watchStream(exec(cmd).stdout);
}

/**
 * 对流做一些额外处理
 * @param stream
 * @return id
 */
function watchStream(stream) {
  const id     = Date.now();
  streams[id]  = stream;
  stream._buff = '';

  //处理流的data事件，使其按行(\n结尾)来触发自定义的line事件
  stream.on('data', data => {
    stream._buff += data;
    let lines    = stream._buff.split('\n');
    stream._buff = lines.pop();
    lines.forEach(line => stream.emit('line', line));
  });
}

const io = SocketIO(httpServer);

io.on('connection', function (socket) {
  socket.on('sub', function (id) {
    if (!streams[id]) return socket.emit('line', `该订阅id不存在: ${id}`);

    //管道函数，收到流的line事件则将控制台的ansi格式内容转成html格式然后触发客户端的line事件
    const pipe = line => socket.emit('line', ansiHTML(line));

    //订阅流的line事件
    streams[id].on('line', pipe);
  });
});

var socket = io.connect();
socket.on('line', function (data) {
  app.rawLines.push(data);
  if (app.rawLines.length > 2000) app.rawLines.splice(0, app.rawLines.length - 2000); //行数上限设为2000
});

socket.on('connect', function () {
  console.log('connect succeed');

  socket.emit('sub', 'time');//根据各种业务逻辑拿到一个订阅id并订阅
});