概要
基于 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 }
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 群星.2006-失而复得2辑【新艺宝】【WAV+CUE】
- 《张震岳6CD合集》1993-2000全套[WAV+CUE][3.1G]
- 周华健《粤语精选+国语精选》日本母带 [WAV+CUE][1.2G]
- 《陈楚生6CD合集》[WAV+CUE][2.2G]
- dnf经验胶囊快速获得
- dnf结婚地下城入场材料怎么获得
- dnf结婚戒指属性和婚房属性
- FlorianNoack-IWannaBeLikeYou(2024)【Hi-Res】24bit-96kHz【flac】
- 张国荣.1995-狂恋·国语经典【新艺宝】【WAV+CUE】
- 佛教音乐.2012-《藏传密咒精选集》[FLAC+CUE]
- 微软在Win11中加入内置广告:宣传XGP服务
- 《地狱之刃2》官方:游戏中美景都是取材于真实地点
- 对漫威太失望!叉骨叔确认加盟DC《和平使者》第2季
- 李克勤.1998-寻最这五年2CD【艺能动音】【WAV+CUE】
- 彭莉.1995-感谢你的爱【宝丽金】【WAV+CUE】