在fsnotify上递归重新生成文件删除/重命名（Golang）

Question

目标：

我正在尝试监视可能随时被移动或删除的文件。如果是，我想重新生成此文件，以便应用程序可以继续写入它。

尝试：

我试图通过实现两个函数monitorFile()来监听fsnotify事件，并通过一个通道将删除的文件名发送到listen()，在通过未缓冲的通道mvrm（移动或重命名）接收到文件路径字符串后，将递归地重新生成文件。

观察到的行为：

我可以echo 'foo' >> ./inlogs/test.log并看到写通知，甚至可以rm ./inlogs/test.log（或mv），并看到该文件重新生成...但只有一次。如果我第二次rm或mv文件，则不会重新生成该文件。

奇怪的是，在本地Mac OSx（系统版本：macOS 10.13.2（17C88），内核版本：Darwin 17.3.0）上不会发生意外行为，但是在具有构建的两台不同Linux机器上会发生这种情况：

Linux 3.13.0-32-generic＃57-Ubuntu SMP x86_64 x86_64 x86_64 GNU / Linux

Linux 4.9.51-10.52.amzn1.x86_64＃1 SMP x86_64 x86_64 x86_64 GNU / Linux

诊断尝试：

不同的行为让我觉得我有竞争条件。然而，go build -race没有输出。

我想知道done chan是否因为这样的竞争条件而接收？

抱歉这不是“可以游乐场”的，但任何建议或观察这可能是由于racy或buggy欢迎。

watcher.go：

package main

import (
    "os"
    "log"
    "fmt"

    "github.com/go-fsnotify/fsnotify"
)

//Globals
var mvrm chan string

func main() {
    mvrm = make(chan string)
    listen(mvrm)
    monitorFile("./inlogs/test.log", mvrm)
}

func listen(mvrm chan string) {
    go func() {
        for {
            select {
            case fileName := <-mvrm :
                fmt.Println(fileName)
                newFile, err := os.OpenFile(fileName, os.O_RDWR | os.O_CREATE | os.O_APPEND , 0666)
                if err == nil {
                    defer newFile.Close()

                    // Recursively re-spawn monitoring
                    go listen(mvrm)
                    go monitorFile(fileName, mvrm)
                } else {
                    log.Fatal("Err re-spawning file")
                }
            default:
                continue
            }
        }
    }()
}

func monitorFile(filepath string, mvrm chan string) {
    watcher, err := fsnotify.NewWatcher()
    if err != nil {
        log.Fatal(err)
    }
    defer watcher.Close()

    done := make(chan bool)
    go func() {
        for {
            select {
            case event := <-watcher.Events:
                switch event.Op {
                case fsnotify.Write :
                    log.Println("Write!")
                    continue
                case fsnotify.Chmod :
                    log.Println("Chmod!")
                    continue
                case fsnotify.Remove, fsnotify.Rename :
                    log.Println("Moved or Deleted!")
                    mvrm <- event.Name
                    continue
                default:
                    log.Printf("Unknown: %v
", event.Op)
                    continue
                }
            case err := <-watcher.Errors:
                log.Println("Error:", err)
            }
        }
    }()

    err = watcher.Add(filepath)
    if err != nil {
        log.Fatal(err)
    }
    <-done
}

编辑：

通过一些很好的反馈，我把它配对了。在Linux中，它现在按照预期重新生成文件，但在使用top进行监视后，我发现每次移动或删除文件时它都会产生一个新的PID，所以我仍然有泄漏。关于如何消除这种行为的建议欢迎。

https://play.golang.org/p/FrlkktoK2-s

Answer 1

另一答案