Golang动态配置与ConfigMap热更新实践

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
            }
            if event.Op&fsnotify.Write == fsnotify.Write {
                log.Println("配置文件已更新:", event.Name)
                reloadConfig(event.Name) // 重新加载配置
            }
        case err, ok := <-watcher.Errors:
            if !ok {
                return
            }
            log.Println("监听错误:", err)
        }
    }
}()

// 添加监听路径
err = watcher.Add("/etc/config/app.conf")
if err != nil {
    log.Fatal(err)
}
<-done

var (
    config  AppConfig
    configMu sync.RWMutex
)

func reloadConfig(path string) {
    data, err := os.ReadFile(path)
    if err != nil {
        log.Println("读取配置失败:", err)
        return
    }

    var newConfig AppConfig
    if err := yaml.Unmarshal(data, &newConfig); err != nil {
        log.Println("解析配置失败:", err)
        return
    }

    configMu.Lock()
    config = new7Config
    configMu.Unlock()
    log.Println("配置已更新")
}

viper.SetConfigFile("/etc/config/app.conf")
viper.WatchConfig()
viper.OnConfigChange(func(in fsnotify.Event) {
    log.Println("配置变更:", in.Name)
    // 触发业务层更新逻辑
    onConfigReloaded()
})