本篇文章为大家展示了使用golang怎么对文件的变化进行监听，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。
计算
安全
数据库
网络和加速
企业服务
package main
import (
"log"
"github.com/fsnotify/fsnotify"
)
func main() {
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)
if event.Op&fsnotify.Write == fsnotify.Write {
log.Println("modified file:", event.Name)
}
case err, ok := <-watcher.Errors:
if !ok {
return
}
log.Println("error:", err)
}
}
}()
err = watcher.Add("/tmp/foo")
if err != nil {
log.Fatal(err)
}
<-done
}补充：golang监控文件变化，git自动提交代码
如果文件有变动，且10分钟内，没有再次变动，则提交代码
package main
import (
"fmt"
_ "fmt"
"github.com/fsnotify/fsnotify"
"log"
"os"
"os/exec"
"path/filepath"
"time"
)
//if the conditions are met, execute the shell script
func execCmd() {
cmd := exec.Command("/root/nfs_bak_pro/nfs.git.sh")
err := cmd.Run()
if err != nil {
fmt.Println("Execute Command failed:" + err.Error())
return
}
fmt.Println("Execute Command finished.")
}
//handle folder files changed event
func watchFiles(watcher *fsnotify.Watcher, ch chan int64) {
for {
select {
case ev := <-watcher.Events: {
isNotify := false
if ev.Op & fsnotify.Create == fsnotify.Create {
log.Println("create : ", ev.Name)
isNotify = true
file, err := os.Stat(ev.Name)
if err == nil && file.IsDir() {
watcher.Add(ev.Name)
fmt.Println("add watch : ", ev.Name)
}
}
if ev.Op & fsnotify.Remove == fsnotify.Remove {
log.Println("delete : ", ev.Name)
isNotify = true
err := watcher.Remove(ev.Name)
fmt.Printf("remove watch: %s, err: %v\n", ev.Name, err)
}
if ev.Op & fsnotify.Rename == fsnotify.Rename {
log.Println("rename : ", ev.Name)
if "" != ev.Name {
isNotify = true
err := watcher.Remove(ev.Name)
fmt.Printf("remove watch: %s, err: %v\n", ev.Name, err)
}
}
if isNotify {
ch <- time.Now().Unix()
}
}
case err := <-watcher.Errors: {
log.Println("watcher error : ", err)
return
}
}
}
}
//if folder event met, execute the shell script after 10minutes
func watchTime(ch chan int64) {
var timer *time.Timer
for {
select {
case <- ch:{
if nil != timer {
log.Printf("reset timer")
timer.Stop()
}
timer = time.NewTimer(10 * 60 * time.Second)
go func() {
<-timer.C
execCmd()
}()
}
}
}
}
//watch the folder and sub folders
func WatchDir(watcher *fsnotify.Watcher, dir string) {
filepath.Walk(dir, func(path string, info os.FileInfo, err error) error {
if info.IsDir() {
path, err := filepath.Abs(path)
if err != nil {
return err
}
err = watcher.Add(path)
if err != nil {
return err
}
}
return nil
})
}
func main() {
notifyCh := make(chan int64)
watcher, err := fsnotify.NewWatcher()
if err != nil {
log.Fatal(err)
}
defer watcher.Close()
WatchDir(watcher, "/data/nfs")
go watchFiles(watcher, notifyCh)
go watchTime(notifyCh)
select {}
}#!/bin/bash
cd /root/nfs_bak_pro/nfs.git
log_file=/root/nfs_bak_pro/nfs_git_`date +"%Y%m%d"`.log
git add --all . >> $log_file
git commit -a -m "`date +"%Y-%m-%d %H:%M:%S"`" >> $log_file
git push origin master >> $log_file上述内容就是使用golang怎么对文件的变化进行监听，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注亿速云行业资讯频道。
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
