php小编百草在这里与大家分享一种有效的方法,即如何从fsnotify过滤重复的系统消息。在日常的开发工作中,我们经常会遇到需要实时监控文件系统变化的场景,而fsnotify正是一个强大的工具。然而,当系统频繁变动时,可能会导致大量的重复消息出现,给我们的工作带来困扰。因此,本文将教您一种简单而实用的过滤重复系统消息的方法,帮助您提高工作效率。
我使用“github.com/fsnotify/fsnotify”来监听文件更改,但是我应该如何多次过滤某些消息?
func listener() { watcher, err := fsnotify.newwatcher() if err != nil { log.fatal(err) } defer watcher.close() done := make(chan bool) go func() { for { select { case event, ok := <-watcher.events: if !ok { return } log.println("event:", event.name, event.op) // writing in this way reduces some messages: if event.op&fsnotify.rename == fsnotify.rename { // do ... } else if event.op&fsnotify.create == fsnotify.create { // do ... } else if event.op&fsnotify.write == fsnotify.write { // do ... } else if event.op&fsnotify.remove == fsnotify.remove { // do ... } case _, ok := <-watcher.errors: if !ok { return } } } }() err = watcher.add("e:/.../demo") if err != nil { log.fatal(err) } <-done }
比如write、create事件发生了好几次,我发现官方已经修复了bug,但是好像没有完全解决
2022/12/12 21:00:55 event: e:\...\demo\a.bbb create 2022/12/12 21:00:55 event: e:\...\demo\a.bbb create 2022/12/12 21:00:55 event: e:\...\demo\a.bbb create 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write 2022/12/12 21:01:57 event: e:\...\demo\2.md write
我应该如何过滤消息?
##############################
var syncMap sync.Map go func() { for { select { case event, ok := <-watcher.Events: if !ok { return } fPath := strings.ReplaceAll(event.Name, "\\", "/") pathKey, _ := syncMap.Load(fPath) if pathKey != 1 { // ... syncMap.Store(fPath, 1) go func() { time.Sleep(time.Second * 2) syncMap.Delete(fPath) }() } case _, ok := <-watcher.Errors: if !ok { return } } } }()
如果发出事件的库不在您的控制之下,您只能更改处理重复项的方式。 您可以使用 map[string]bool 来跟踪您已经看到/处理的事件,因此修改您的代码可以执行以下操作:
seenMap := make(map[string]bool) go func() { for { select { case event, ok := <-watcher.Events: if !ok { return } log.Println("event:", event.Name, event.Op) _, seen := seenMap[event.Name] if !seen { // Writing in this way reduces some messages: if event.Op&fsnotify.Rename == fsnotify.Rename { // do ... } else if event.Op&fsnotify.Create == fsnotify.Create { // do ... } else if event.Op&fsnotify.Write == fsnotify.Write { // do ... } else if event.Op&fsnotify.Remove == fsnotify.Remove { // do ... } seenMap[event.Name] = true } case _, ok := <-watcher.Errors: if !ok { return } } } }()
위 내용은 fsnotify에서 중복 시스템 메시지를 필터링하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!