1. 文件监控

1.1.1. Go的文件系统通知

官网地址:https://github.com/fsnotify/fsnotify

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

  1. go get -u golang.org/x/sys/...

1.1.2. 常问问题

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

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

当我查看目录时,是否也监视所有子目录?

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

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

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

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

在OS X上对Spotlight进行索引可能会导致多个事件(请参见howeyc#62)。临时的解决方法是将您的文件夹添加到Spotlight隐私设置中,直到我们具有本机FSEvents实现(请参阅#11)。

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

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

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

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

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

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