概述
我的项目启动必定少不了配置文件，个别咱们会放在独自的目录，例如config中，有yaml、ini、json等等格局，个别用开源的读取相应问的文件映射到构造体中。
然而当一个我的项目秒杀频繁管制库存和限流策略等、或者其余须要频繁的变更配置文件的时候，就须要频繁的更改代码，打包，上线。工夫老本高，实效性也低。所以个别都做配置热更新。
做配置热更新的有很多consul、Firestore、etcd、也有redis等等KV存储，明天咱们要讲的是viper和etcd的热更新操作
筹备工作
我用的是mac m1
装置etcd
生产环境必定就是集群，测试咱们间接单机模式了
brew install etcd启动
etcd测试
$ etcdctl versionetcdctl version: 3.5.5API version: 3.5或者docker，k8s装置测试环境
viper
go get github.com/spf13/viper应用配置文件
func configByFile(vp *viper.Viper){ var err error //设置配置文件的名字 vp.SetConfigName("config") // name of config file (without extension) //设置配置文件后缀 vp.SetConfigType("json") // REQUIRED if the config file does not have the extension in the name //设置配置文件的门路 vp.AddConfigPath("/Users/xxxx/Desktop/test/testCode/") // path to look for the config file in vp.Set("verbose", true) // 设置默认参数 //读取文件 if err = vp.ReadInConfig(); err != nil { if _, ok := err.(viper.ConfigFileNotFoundError); ok { // Config file not found; ignore error if desired log.Fatal("not found") } else { // Config file was found but another error was produced } } if err = vp.Unmarshal(&conf);nil != err{ log.Fatal("Unmarshal ",err) } fmt.Println(conf) //watch go func() { vp.OnConfigChange(func(e fsnotify.Event) { fmt.Println("Config file changed:", e.Name) fmt.Println(e.String()) fmt.Println(e.Op.String()) }) vp.WatchConfig() }() }配置文件产生批改等行为时候回接管到调用回调函数，做相应的解决
etcd做配置
func configByEtcd(vp *viper.Viper){ var err error if err = vp.AddRemoteProvider("etcd3", "http://127.0.0.1:2379", "/config/viper-test/config");err != nil { log.Fatal(err) } vp.SetConfigType("json") if err = vp.ReadRemoteConfig();err != nil { log.Fatal(err) } if err = vp.Unmarshal(conf);err != nil { log.Fatal(err) } fmt.Println("获取的配置信息 ",conf) //fmt.Println(vp.Get("addr")) //fmt.Println(vp.Get("port")) go watchRemoteConfig(vp) select {}}func watchRemoteConfig(vp *viper.Viper) { for { time.Sleep(time.Second * 5) // delay after each request // currently, only tested with etcd support err := vp.WatchRemoteConfig() if err != nil { log.Printf("unable to read remote config: %v", err) continue } // unmarshal new config into our runtime config struct. you can also use channel // to implement a signal to notify the system of the changes if err = vp.Unmarshal(&conf); nil != err{ log.Printf("unable to read remote config: %v", err) continue } fmt.Println("获取的配置信息 ",conf) }}批改 ercdkeeper内容
查看后果
获取的配置信息 &{127.0.0.1 3307}获取的配置信息 &{127.0.0.1 3307}获取的配置信息 &{127.0.0.1 3307}获取的配置信息 &{127.0.0.1 3306}获取的配置信息 &{127.0.0.1 3306}^Csignal: interrupt能够看到扭转了 就收到了
上边只是一个简略的应用，更具体的利用能够本人封装下 ，还是很实用的
本文由mdnice多平台公布