1 | npm install chokidar --save |
1 2 3 4 5 6 | logStreams: { directories: [ //监测的目录 '/root/test/logs' ] }, |
1 2 | host: '0.0.0.0',//log.io 服务器地址 port: 28777//log.io 端口 |
1 2 | node myHarverster.js log.io-server |
1 2 3 4 5 6 7 8 9 | function socket_init(port, host){ var socket = new net.Socket(); socket.on('error', function(error) { return setTimeout((function() { return socket_init(); }), 2000); }); return socket.connect(port, host); } |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 | function watch(path, socket) { var currect = {}; var watcher = chokidar.watch(path, { ignored: /[\/\\]\./, persistent: true }); watcher.on('unlink', function(path){ send(socket, "-stream|" + p.basename(path) + "|" + nodeName); }); watcher.on('add', function(path){ send(socket, "+stream|" + p.basename(path) + "|" + nodeName); }); watcher.on('change', function(path, stat){ if(currect[p.basename(path)] === undefined){ currect[p.basename(path)] = 0; } read(path, stat.size, currect[p.basename(path)], socket); currect[p.basename(path)] = stat.size; }); } |
欢迎光临 电子技术论坛_中国专业的电子工程师学习交流社区-中电网技术论坛 (http://bbs.eccn.com/) | Powered by Discuz! 7.0.0 |