
viper无法动态修改计时器的困惑
在使用viper进行动态配置管理时,你遇到了这样的问题:虽然配置文件可以实时动态更新,但程序中的定时器却无法响应配置变更。
这个问题源于time.newticker函数的行为。newticker在创建时设定了指定的间隔时间,并且会一直按照该间隔执行。对于你的情况,这意味着当文件变更时,viper.getduration("kafka.timeexec")的值可能会改变,但创建的ticker仍然保持原来的间隔。
解决方案:重置计时器的间隔
要解决这个问题,最简单的方案是当文件变更时,重置ticker的间隔时间。这可以通过ticker.reset方法实现。在onconfigchange回调中调用reset方法可以确保ticker的间隔始终保持与配置文件中的最新配置一致。
修改后的代码如下:
func main() {
viper.SetConfigName("app")
viper.SetConfigType("ini")
viper.AddConfigPath(".")
err := viper.ReadInConfig()
if err != nil {
log.Fatal("read config failed: %v", err)
}
viper.WatchConfig()
// 执行定时任务
ticker := time.NewTicker(viper.GetDuration("kafka.TimeExec") * time.Second)
defer ticker.Stop()
viper.OnConfigChange(func(e fsnotify.Event) {
fmt.Println("Config file changed:", e.Name)
ticker.Reset(viper.GetDuration("kafka.TimeExec") * time.Second)
})
for {
select {
case <-ticker.C:
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
fmt.Println("间隔:", viper.GetDuration("kafka.TimeExec")*time.Second)
}
}
}










