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) } }}
登录后复制
以上就是Viper动态配置下，如何让定时器响应配置变更?的详细内容，更多请关注【创想鸟】其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至253000106@qq.com举报，一经查实，本站将立刻删除。
发布者：PHP中文网，转转请注明出处：https://www.chuangxiangniao.com/p/2312712.html
