1 2 3 4 | [root@symfred1 ~]# telnet localhost 28777 Trying 127.0.0.1... Connected to localhost. Escape character is '^]'. |
1 | +node|test1 |
1 | +node|test2|s1,s2 |
1 | +stream|s3|test2 |
1 | -stream|s3|test2 |
1 | +log|s2|test2|info|this is a message |
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 |