1. 文件监控

    官网地址:

    fsnotify利用golang.org/x/sys而不是syscall从标准库。通过运行以下命令确保已安装最新版本:

    1.1.2. 常问问题

    当文件移到另一个目录时,仍在监视它吗?

    不(不应该这样,除非您正在观看它的移动位置)。

    不,您必须为要观看的任何目录添加监视(路线图#18上有一个递归监视程序)。

    我是否必须在单独的goroutine中观看错误和事件通道?

    截至目前,是的。正在考虑使此单线程友好(请参阅howeyc#7)

    为什么我在OS X上收到同一文件的多个事件?

    一次可以查看多少个文件?

    对于可创建的手表数量,存在特定于操作系统的限制:

    • Linux:/ proc / sys / fs / inotify / max_user_watches包含该限制,达到此限制将导致“设备上没有剩余空间”错误。
    • BSD / OSX:sysctl变量“ kern.maxfiles”和“ kern.maxfilesperproc”达到这些限制会导致“打开的文件太多”错误。

    为什么通知不能与NFS文件系统或用户空间(FUSE)中的文件系统一起使用?

    fsnotify需要底层操作系统的支持才能正常工作。当前的NFS协议不为文件通知提供网络级别的支持。

    1. import (
    2. "fmt"
    3. "log"
    4. "os"
    5. "path/filepath"
    6. "github.com/fsnotify/fsnotify"
    7. )
    8. func main() {
    9. watch, _ := fsnotify.NewWatcher()
    10. w := Watch{
    11. watch: watch,
    12. }
    13. w.watchDir("./web")
    14. select {}
    15. }
    16. type Watch struct {
    17. watch *fsnotify.Watcher
    18. func (w *Watch) watchDir(dir string) {
    19. if info.IsDir() {
    20. path, err := filepath.Abs(path)
    21. if err != nil {
    22. return err
    23. }
    24. err = w.watch.Add(path)
    25. if err != nil {
    26. return err
    27. }
    28. }
    29. return nil
    30. })
    31. log.Println("监控服务已经启动")
    32. go func() {
    33. for {
    34. select {
    35. case ev := <-w.watch.Events:
    36. {
    37. if ev.Op&fsnotify.Create == fsnotify.Create {
    38. fmt.Println("创建文件 : ", ev.Name)
    39. fi, err := os.Stat(ev.Name)
    40. if err == nil && fi.IsDir() {
    41. w.watch.Add(ev.Name)
    42. }
    43. if ev.Op&fsnotify.Write == fsnotify.Write {
    44. fmt.Println("写入文件 : ", ev.Name)
    45. }
    46. if ev.Op&fsnotify.Remove == fsnotify.Remove {
    47. fmt.Println("删除文件 : ", ev.Name)
    48. fi, err := os.Stat(ev.Name)
    49. if err == nil && fi.IsDir() {
    50. w.watch.Remove(ev.Name)
    51. fmt.Println("删除监控 : ", ev.Name)
    52. }
    53. }
    54. if ev.Op&fsnotify.Rename == fsnotify.Rename {
    55. fmt.Println("重命名文件 : ", ev.Name)
    56. w.watch.Remove(ev.Name)
    57. }
    58. }
    59. case err := <-w.watch.Errors:
    60. {
    61. fmt.Println("error : ", err)
    62. return
    63. }
    64. }
    65. }