概要
基于 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 }
免责声明:本站文章均来自网站采集或用户投稿,网站不提供任何软件下载或自行开发的软件!
如有用户或公司发现本站内容信息存在侵权行为,请邮件告知! 858582#qq.com
暂无“golang API开发过程的中的自动重启方式(基于gin框架)”评论...
更新动态
20240517
20240517
- Taylor Swift《THE TORTURED POETS DEPARTMENT- THE ANTHOLOGY》[320K/MP3][279.09MB]
- 崔健《85回顾+梦中的倾诉》2CD [WAV+CUE][771M]
- 群星《安桥试音碟》3CD[FLAC][1.1G]
- Taylor Swift《THE TORTURED POETS DEPARTMENT- THE ANTHOLOGY》][24bit 48kH][FLAC/分轨]
- 群星1995-阿诗玛·中国歌剧金曲[中唱][WAV+CUE]
- [JVC]吴文光-中国古琴:流水[FLAC分轨]
- 刘欢.2004-经典20年珍藏锦集【新索】【WAV+CUE】
- 中唱唱片群星《好歌珍藏-游子情深》2CDWAV
- CD圣经上榜天碟1995-乌仁娜-《蒙古草原之歌》[WAV+CUE].
- 【电影原声】武满彻《旭日东升》1993[WAV+CUE整轨]
- Taylor Swift《THE TORTURED POETS DEPARTMENT》[320K/MP3][148.54MB]
- Taylor Swift《THE TORTURED POETS DEPARTMENT》[FLAC/分轨][405.72MB]
- Joyce Jonathan《法式松弛感 漫步香榭丽舍》[320K/MP3][80.8MB]
- 女神异闻录5佐仓双叶coop攻略 p5r佐仓双叶对话选项攻略
- 【民谣】张智《尼勒克小镇》[FLAC]