概要
基于 golang Gin 框架开发 web 服务时, 需要时不时的 go build , 然后重启服务查看运行结果.
go build 的过程集成在编辑器中(emacs), 可以通过快捷键迅速完成, 但是每次重启服务都切换到命令行中操作.
因此, 希望能够编译通过之后自动重启服务.
这里并不是部署阶段的服务重启, 所以不用过多考虑是否正常退出其中的协程.
实现方式
在开源的 illuminant 项目中, 已经将相应的代码集成到 gin 的 debug mode 中.
代码文件: https://gitee.com/wangyubin/illuminant/blob/dev/server_cmd.go
func setupWatcher() (chan struct{}, error) { file, err := osext.Executable() if err != nil { return nil, err } log.Printf("watching %q\n", file) w, err := fsnotify.NewWatcher() if err != nil { return nil, err } done := make(chan struct{}) go func() { select { case e := <-w.Events: log.Printf("watcher received: %+v", e) err := syscall.Exec(file, os.Args, os.Environ()) if err != nil { log.Fatal(err) } case err := <-w.Errors: log.Printf("watcher error: %+v", err) case <-done: log.Print("watcher shutting down") return } }() err = w.Add(file) if err != nil { return nil, err } return done, nil }
在 gin debug mode 下, 使用此方法自动重启服务
if c.Bool("prod") { gin.SetMode(gin.ReleaseMode) // start route return routes.Routes(cnf.Server.Port) } else { gin.SetMode(gin.DebugMode) watcher, err := setupWatcher() if err != nil { // do something sensible log.Fatal(err) } defer close(watcher) return routes.Routes(cnf.Server.Port) }
补充
上面函数的核心有以下两点:
- w, err := fsnotify.NewWatcher(): 创建监控文件变化的 watcher, err = w.Add(file) 并将当前二进制文件加入到监控文件列表中
- err := syscall.Exec(file, os.Args, os.Environ()) 接受到文件变化的事件时, 重新调用一次自己, 使用上次一样的参数和环境变量
syscall.Exec
对于这个函数, 一般可能用的比较少, 这里稍微介绍下. 它有 3 个参数:
- args[0]: 可执行文件的路径(相对路径, 绝对路径或者 PATH 中的路径都可以)
- args[1]: 命令的参数
- args[2]: 命令的执行的环境变量, os.Environ() 表示继承 caller 的环境变量
当 syscall.Exec 执行时, 在它之前的所有未执行完的程序都会被中止(包括在 go routine 中执行的程序),
然后执行 syscall.Exec 调用的命令, 该命令还保持在之前程序的 PID 下执行.
syscall.Exec 是最后一条执行的代码, 重启时在它之后可以有代码, 但是都不会被执行到, 包括 defer 中的代码.
下面是个小例子(通过这个例子可以验证上面的结论):
package main import ( "fmt" "log" "os" "syscall" "time" "github.com/fsnotify/fsnotify" "github.com/kardianos/osext" ) func syscallExec() { watcher, err := setupWatcher() if err != nil { log.Fatal(err) } defer finally(watcher) fmt.Printf("current pid: %d\n", os.Getpid()) var count = 0 go func(count int) { for { fmt.Printf("> count in GO ROUTINE: %d\n", count) count++ time.Sleep(1 * time.Second) } }(count) for { fmt.Printf("> count in MAIN: %d\n", count) count++ time.Sleep(1 * time.Second) } } func finally(watcher chan struct{}) { // 重启时没有执行此函数 fmt.Println("exit original exec") close(watcher) } func setupWatcher() (chan struct{}, error) { file, err := osext.Executable() if err != nil { return nil, err } log.Printf("watching %q\n", file) w, err := fsnotify.NewWatcher() if err != nil { return nil, err } done := make(chan struct{}) go func() { select { case e := <-w.Events: log.Printf("watcher received: %v", e) err := syscall.Exec(file, os.Args, os.Environ()) if err != nil { log.Fatal(err) } case err := <-w.Errors: log.Printf("watcher error: %+v", err) case <-done: log.Print("watcher shutting down") return } }() err = w.Add(file) if err != nil { return nil, err } return done, nil }
RTX 5090要首发 性能要翻倍!三星展示GDDR7显存
三星在GTC上展示了专为下一代游戏GPU设计的GDDR7内存。
首次推出的GDDR7内存模块密度为16GB,每个模块容量为2GB。其速度预设为32 Gbps(PAM3),但也可以降至28 Gbps,以提高产量和初始阶段的整体性能和成本效益。
据三星表示,GDDR7内存的能效将提高20%,同时工作电压仅为1.1V,低于标准的1.2V。通过采用更新的封装材料和优化的电路设计,使得在高速运行时的发热量降低,GDDR7的热阻比GDDR6降低了70%。
更新动态
- 凤飞飞《我们的主题曲》飞跃制作[正版原抓WAV+CUE]
- 刘嘉亮《亮情歌2》[WAV+CUE][1G]
- 红馆40·谭咏麟《歌者恋歌浓情30年演唱会》3CD[低速原抓WAV+CUE][1.8G]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[320K/MP3][193.25MB]
- 【轻音乐】曼托凡尼乐团《精选辑》2CD.1998[FLAC+CUE整轨]
- 邝美云《心中有爱》1989年香港DMIJP版1MTO东芝首版[WAV+CUE]
- 群星《情叹-发烧女声DSD》天籁女声发烧碟[WAV+CUE]
- 刘纬武《睡眠宝宝竖琴童谣 吉卜力工作室 白噪音安抚》[FLAC/分轨][748.03MB]
- 理想混蛋《Origin Sessions》[320K/MP3][37.47MB]
- 公馆青少年《我其实一点都不酷》[320K/MP3][78.78MB]
- 群星《情叹-发烧男声DSD》最值得珍藏的完美男声[WAV+CUE]
- 群星《国韵飘香·贵妃醉酒HQCD黑胶王》2CD[WAV]
- 卫兰《DAUGHTER》【低速原抓WAV+CUE】
- 公馆青少年《我其实一点都不酷》[FLAC/分轨][398.22MB]
- ZWEI《迟暮的花 (Explicit)》[320K/MP3][57.16MB]