最小热重载#

监听配置文件变化，在回调中读取新值并重新解码结构体。

本系列使用 Viper v1.21.0。每章都是独立实验，示例命令在项目目录中执行；开始新一章时，使用该章的完整程序和配置，不累积上一章的临时修改。

尚未准备练习项目时，先完成第 1 章的项目准备。

初始示例#

初始配置 config/config.yaml：

1
app:
2
  name: viper-demo
3
  port: 8080

初始完整 main.go：

1
package main
2

3
import (
4
  "fmt"
5
  "github.com/fsnotify/fsnotify"
6
  "github.com/spf13/viper"
7
  "log"
8
  "os"
9
  "os/signal"
10
)
11

12
func main() {
13
  v := viper.New()
14
  v.SetConfigFile("config/config.yaml")
15
  if err := v.ReadInConfig(); err != nil {
16
    log.Fatal(err)
17
  }
18
  fmt.Println("启动端口:", v.GetInt("app.port"))
19

20
  v.OnConfigChange(func(event fsnotify.Event) {
21
    fmt.Println("配置文件发生变化:", event.Name)
22
    fmt.Println("更新后的端口:", v.GetInt("app.port"))
23
  })
24
  v.WatchConfig()
25

26
  stop := make(chan os.Signal, 1)
27
  signal.Notify(stop, os.Interrupt)
28
  defer signal.Stop(stop)
29
  fmt.Println("正在监听，按 Ctrl+C 退出")
30
  <-stop
31
}

执行 go run main.go，等待“正在监听”。OnConfigChange 注册回调，WatchConfig 启动监听，等待信号让程序持续运行。

第一次修改#

程序运行期间，将 YAML 中的端口改为：

1
  port: 9090

保存后应看到新端口，无需重启。一次保存可能触发多个回调。

第二次修改#

停止程序，在 main 外增加：

1
type Config struct {
2
    App struct {
3
        Name string `mapstructure:"name"`
4
        Port int    `mapstructure:"port"`
5
    } `mapstructure:"app"`
6
}

将完整的 OnConfigChange 回调块替换为：

1
v.OnConfigChange(func(event fsnotify.Event) {
2
    fmt.Println("配置文件发生变化:", event.Name)
3
    var next Config
4
    if err := v.UnmarshalExact(&next); err != nil {
5
        log.Println("解码失败:", err)
6
        return
7
    }
8
    fmt.Println("更新后的应用名称:", next.App.Name)
9
    fmt.Println("更新后的端口:", next.App.Port)
10
})

重新启动，再修改并保存端口，观察重新解码得到的值。结构体不会自动跟随 Viper 变化，需要主动再次解码。

本节只演示合法保存。Viper 会尝试重新读取后调用回调，但收到回调不代表读取一定成功；打印新结构体也不等于已替换业务正在使用的配置。下一章单独解决这些问题。

监听会修改 Viper 内部数据，它不保证并发读写安全。本章开始监听后只在回调中读取 v，不要同时增加其他 goroutine 读取这个实例的循环。

HikariTish

最小热重载#

初始示例#

第一次修改#

第二次修改#

参考资料#

Viper 学习记录

继续阅读

换条路线

HikariTish

最小热重载#

初始示例#

第一次修改#

第二次修改#

参考资料#

分享文章

沿着主题读

换条路线