通过内核fanotify监听文件事件实现配置文件热更新

packagemainimport (
"encoding/json""fmt""io/ioutil""log""time""github.com/fsnotify/fsnotify")
//全局自定义拦截varintercept []Intercept//文件时间varftint64varfilenamestring="intercept.json"typeInterceptstruct {
Urlstring`json:"url"`Methodstring`json:"method"`RespHeadermap[string]string`json:"resp_header"`RespBodyinterface{}       `json:"resp_body"`RespCodeint`json:"resp_code"`}
//读取自定义响应文件funcRead_resp() {
intercept_data, err :=ioutil.ReadFile(filename)
iferr!=nil {
log.Fatalln(err)
    }
err=json.Unmarshal(intercept_data, &intercept)
iferr!=nil {
log.Fatalln(err)
    }
}
funclisten(w*fsnotify.Watcher) {
err :=w.Add(filename)
iferr!=nil {
log.Fatal(err)
    }
}
funcmain() {
//初始读取Read_resp()
watcher, err :=fsnotify.NewWatcher()
iferr!=nil {
log.Fatal(err)
    }
deferwatcher.Close()
listen(watcher)
gofunc() {
for {
select {
caseevent, ok :=<-watcher.Events:
if!ok {
return                }
log.Println("event:", event)
ifevent.Op&fsnotify.Write==fsnotify.Write {
log.Println("modified file:", event.Name)
Read_resp()
                }
ifevent.Op&fsnotify.Rename==fsnotify.Rename {
listen(watcher)
Read_resp()
                }
caseerr, ok :=<-watcher.Errors:
if!ok {
return                }
log.Println("error:", err)
            }
        }
    }()
//循环打印for {
time.Sleep(1*time.Second)
iflen(intercept) >0 {
fmt.Println(intercept[0].RespBody)
        }
    }
}