windows 文件watch nodejs

Posted 2020-08-05 点滴人生 legu2009

本篇博客，主要是记录下最近一直纠结的gulp.watch方法，在工作中我们肯定都遇到过，新添加的文件没办法自动触发watch,下面我们就来看有什么办法处理

1.首先我们肯定是先百度一下

   百度推荐的是gulp-watch插件，这个插件其实是基于上片博客的提到的node模块chokidar。可以监控文件的增删改查，重命名的会发送一个添加和一个删除

   但是用这个模块，在关闭控制台的时候，会有一段时间的无响应时间，感觉重视怪怪的

2.本人平时在windows下面，还会熟悉写arrdio的脚本语言，这个语言对文件的监控，也有相关的模块，其实相对使用的是Kernel32.dll里面的Windows api

    ReadDirectoryChangesW  MSDN直通车 

    但是arrdio exe程序怎么和nodejs程序通信的，以前也有相关的尝试，

    a.通过进程的输入，输出设备相关，打印信息。后台发现该方案只能是子进程返回给主进程信息就放弃了。

    b.基于http,主要感觉要占用端口，而且http也是响应式的，相关的交互也有点麻烦

    c.基于TCP,tcp属于长连接，server和client 可以相互通信，这又是好一顿折腾（TCP服务是node还是arrdio创建，后来是考虑arrdio创建，主要是想在mynote项目里面，也借助tcp服务，进行让node在Windows使用sqlite数据库【主要是网上没有找到相关windows下编译好的sqlite模块，自己又没有相关的环境和知识】）

总结下相关的对比

	gulp.watch	chokidar	aau.watch
初始化		ready事件之前会有文件的add事件
文件添加	无反应	add	添加文件
删除文件	运行前存在的 deleted 运行后添加的 无反应	unlink	移除文件
重命名文件	运行前存在的 deleted 运行后添加的 无反应	被重名文件  unlink 重命名后文件 add	被重命名文件  重命名：原文件 重命名后文件  重命名:新文件名 重命名后文件  文件被修改
修改文件	运行前存在的 changed 运行后添加的 无反应	change	文件被修改

 

 

 

 

 

 

 

 

 

 

aau.watch采用的是TCP消息通信，但是由于文件重命名，消息比较频繁，短时间内3条信息传递，导致node的tcp客户端，存在调包，或者少响应data时间的现象。

相关的我也写了arrdio的tcp客户端的响应处理，只是获取的消息会一次性获取，没有掉包的情况。

不知道其中是什么原因导致的。

下面贴下相关的代码

node watch.js代码

var net = require(‘net‘);
var gulp = require(‘gulp‘);
var chokidar = require(‘chokidar‘);

var HOST = ‘127.0.0.1‘;
var PORT = 7070;

var actionTab = ["", "添加文件", "移除文件", "文件被修改", "重命名:原文件名", "重命名:新文件名"];
var client = new net.Socket();
client.connect(PORT, HOST, function() {
    client.write(‘{action: "dirWatch", url:"D:/snailshop/wgu/"}‘);
});
client.on(‘data‘, function(data) {
    var tab = data.toString().split(‘,‘);
    console.log(‘[aau.watch]‘, tab[1], actionTab[tab[0]], +new Date)
});
client.on(‘close‘, function() {
    console.log(‘Connection closed‘);
});
/*
net.createServer(function(sock) {
    console.log(‘CONNECTED: ‘ + sock.remoteAddress + ‘:‘ + sock.remotePort);
    sock.on(‘data‘, function(data) {
        console.log(‘DATA ‘ + sock.remoteAddress + ‘: ‘ + data);
        sock.write(‘You said "‘ + data + ‘"‘);
    });
    sock.on(‘close‘, function(data) {
        console.log(‘CLOSED: ‘ + sock.remoteAddress + ‘ ‘ + sock.remotePort);
    });
}).listen(PORT, HOST);*/
gulp.watch([‘./wgu/**/*‘], event => {
    console.log(‘[gulp.watch]‘, event.path, event.type, +new Date)
});
var watcher = chokidar.watch([‘./wgu/**/*‘], {
    ignored: /[\/\\]\./,
    persistent: true
});
‘add,change,unlink,addDir,unlinkDir,ready‘.split(‘,‘).forEach(item => {
    watcher.on(item, path => {
        console.log(‘[chokidar]‘, path, item, +new Date)
    })
})

arrdio tcp server,相关的都有封装，只需要写比较少的代码，唯一可惜的是官网的文档比较少，需要花一定的时间自己了解怎么写法

import console;
import wsock.tcp.server;
import wsock.tcp.client;
import thread.command;

var tcpTab = {};
var listener = ..thread.command();//线程命令，对线程抛出的消息进行处理
listener.onFileChange = function (msg) {
    for (i = 1; #tcpTab; 1) {
        tcpTab[i].write(msg)
    }
};
var tcpServer, errMsg = wsock.tcp.server("127.0.0.1", 7070);
if(!tcpServer) {
    console.log( errMsg )
    console.pause();
} else {
    tcpServer.forever(function(acceptSocket){
        table.push(tcpTab, wsock.tcp.client(, acceptSocket)) //保存客户端socket
        ..thread.invoke(function(acceptSocket, hwndListener){ //启动单独线程，响应每一个客户端的请求
            import wsock.tcp.client;
            import web.json;
            import fsys.dirWatcher;
            import console;    
            import thread.command; 
            
            var tcpClient = wsock.tcp.client(, acceptSocket);
            do{
                var cstr = tcpClient.recv();
                if (cstr) {
                    var obj = web.json.parse(cstr);
                    console.dump(obj)
                    if (obj && type(obj) == ‘table‘ && obj.action == ‘dirWatch‘) {
                        var watcher = fsys.dirWatcher(obj.url);
                        for( filename,action,actionText,item in watcher.eachChanges(flags,subTree) ){
                            //console.log(1, string.join({action;filename;}, ","))
                            //tcpClient.write(string.join({action;filename;}, ","))
                            thread.command.post(hwndListener, "onFileChange", string.join({action;filename;}, ","));  //线程命令处理
                        } 
                    }
                }
            } while(1)
        }, acceptSocket, listener.hwnd);
    })
}
      

arrdio的tcp客户端（用于测试重命名消息的处理能力）

import console;
import wsock.tcp.client;
import fsys.dirWatcher;

var tcpc = wsock.tcp.client();
tcpc.connect("127.0.0.1", 7070);
tcpc.write(‘{action: "dirWatch", url:"D:/snailshop/wgu/"}‘);
do{
    var cstr = tcpc.recv();
    console.log(cstr);
    
} while(1)

本来还想arrdio的文件监控，使用的是window api，相对的响应效果更好，但是在和nodejs信息传递方面还是存在很大的难度，不是我这个前端知识面能解决的问题。只能放弃了。

chokidar 即 gulp-watch监控文件的方面也不错，性能上面有些消耗，但是用起来应该不受太大影响