cluster dir watcher

master.js

var cluster = require('cluster');

function watchdir(dir) {
  var watcher = childprocess.fork('watcher.js', [dir]);
  watcher.on('exit', function () {
    // logger exit message
    watcher = null;
    // refork again
    setTimeout(watchdir.bind(null, dir), 1000);
  }).on('message', function (info) {
    if (info.isFile) {
      sendClusterMessage({action: 'watch-file', info: info}); 
    }
  }); 
}

watchdir(cmspath);

watcher.js

var wt = require('wt');
var dir = process.argv[2];

wt.watch(dir).on('file', function (info) {
  process.send(info);
});

worker.js

// cluster mode
process.on('message', function (msg) {
  if (msg && msg.action === 'watch-file') {
    reloadFile(msg.info.path);
  }
});

@dead-horse 大概这个思路