Go語(yǔ)言fsnotify接口實(shí)現(xiàn)監(jiān)測(cè)文件修改

更新時(shí)間：2022年06月27日 14:30:06 作者：Go語(yǔ)言由淺入深

這篇文章主要為大家介紹了Go語(yǔ)言fsnotify接口實(shí)現(xiàn)監(jiān)測(cè)文件修改的示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

引言

在開發(fā)過(guò)程中，經(jīng)常需要觀察本地文件系統(tǒng)的更改。經(jīng)過(guò)谷歌了幾個(gè)小時(shí)后，到了一個(gè)簡(jiǎn)單的工具來(lái)做這件事。

該工具就是fsnotify是一個(gè)Go跨平臺(tái)文件系統(tǒng)通知工具。它提供了一個(gè)簡(jiǎn)單的接口來(lái)監(jiān)測(cè)本地文件系統(tǒng)中的更改。

本文我們就來(lái)看看如何使用這個(gè)工具。

安裝工具

$ go get github.com/fsnotify/fsnotify

關(guān)鍵類型

我們先來(lái)了解下fsnotify工具的所有類型。

Event結(jié)構(gòu)體

Event結(jié)構(gòu)體表示單個(gè)文件系統(tǒng)通知。

函數(shù)String()返回一個(gè)“file: REMOVE|WRITE|…”格式字符串表示事件的字符串。

type Event struct {
    Name string    //文件或目錄的相對(duì)路徑
    Op      Op       //文件更改事件
}
func (e Event) String() string

Op類型

該工具描述了一組文件操作。它們是可以觸發(fā)通知的通用文件操作。

type Op uint32
const (
    Create Op = 1 &lt;&lt; iota
    Write
    Remove
    Rename
    Chmod
)

Watcher結(jié)構(gòu)體

Watcher結(jié)構(gòu)體是該工具的核心。包含兩個(gè)channel和三個(gè)函數(shù)。

type Watcher struct {
    Events chan Event
    Errors chan error
    ...
}
func (w *Watcher) Add(name string) error
func (w *Watcher) Remove(name string) error 
func NewWatcher() (*Watcher, error)

Channel

Events 通道
Errors 通道

函數(shù)

Add：非遞歸監(jiān)測(cè)文件或目錄的變化。
Remove：停止監(jiān)測(cè)文件或目錄。
Close：關(guān)閉所有文件或目錄的監(jiān)測(cè)以及關(guān)閉Events通道。

Watcher工廠函數(shù)

函數(shù)NewWatcher通過(guò)底層操作系統(tǒng)調(diào)用創(chuàng)建watcher對(duì)象，并等待事件通知。

func NewWatcher() (*Watcher, error)

完整例子

import (
    "log"
    "github.com/fsnotify/fsnotify"
)
func main() {
    watcher, err := fsnotify.NewWatcher()
    if err != nil {
        log.Fatal("new watcher failed: ", err)
    }
    defer watcher.Close()
    done := make(chan bool)
    go func() {
        defer close(done)
        for {
            select {
            case event, ok := <-watcher.Events:
                if !ok {
                    return
                }
                log.Printf("%s %s\n", event.Name, event.Op)
            case err, ok := <-watcher.Errors:
                if !ok {
                    return
                }
                log.Println("error: ", err)
            }
        }
    }()
    err = watcher.Add("./")
    if err != nil {
        log.Fatal("add failed:", err)
    }
    <-done
}

上面的代碼通過(guò)啟動(dòng)一個(gè)goroutine在后臺(tái)監(jiān)測(cè)目錄或文件的變化，調(diào)用函數(shù)watcher.Add("./")添加監(jiān)測(cè)的目錄是當(dāng)前目錄，也就是main.go文件所在目錄。
運(yùn)行程序后，如果你修改下當(dāng)前main.go文件會(huì)產(chǎn)生如下結(jié)果：

Output

2022/06/09 07:01:15 main.go~ CREATE
2022/06/09 07:01:15 main.go WRITE|CHMOD
2022/06/09 07:01:15 main.go~ CREATE
2022/06/09 07:01:15 main.go CHMOD
2022/06/09 07:01:15 main.go WRITE
2022/06/09 07:01:15 main.go~ REMOVE
2022/06/09 07:01:16 main.go CHMOD

上面的輸出過(guò)程可以發(fā)現(xiàn)，修改文件并保存會(huì)觸發(fā)以下動(dòng)作：