golang API开发过程的中的自动重启(基于gin框架)

对于这个函数, 一般可能用的比较少, 这里稍微介绍下. 它有 3 个参数:

1. args[0]: 可执行文件的路径(相对路径, 绝对路径或者 PATH 中的路径都可以)
2. args[1]: 命令的参数
3. args[2]: 命令的执行的环境变量, os.Environ() 表示继承 caller 的环境变量

当 syscall.Exec 执行时, 在它之前的所有未执行完的程序都会被中止(包括在 go routine 中执行的程序),
然后执行 syscall.Exec 调用的命令, 该命令还保持在之前程序的 PID 下执行.

syscall.Exec 是最后一条执行的代码, 重启时在它之后可以有代码, 但是都不会被执行到, 包括 defer 中的代码.

下面是个小例子(通过这个例子可以验证上面的结论):

 1  package main
 2  
 3  import (
 4   "fmt"
 5   "log"
 6   "os"
 7   "syscall"
 8   "time"
 9  
10   "github.com/fsnotify/fsnotify"
11   "github.com/kardianos/osext"
12  )
13  
14  func syscallExec() {
15   watcher, err := setupWatcher()
16   if err != nil {
17     log.Fatal(err)
18   }
19   defer finally(watcher)
20  
21   fmt.Printf("current pid: %dn", os.Getpid())
22   var count = 0
23  
24   go func(count int) {
25     for {
26       fmt.Printf(">>> count in GO ROUTINE: %dn", count)
27       count++
28       time.Sleep(1 * time.Second)
29     }
30   }(count)
31  
32   for {
33     fmt.Printf(">>> count in MAIN: %dn", count)
34     count++
35     time.Sleep(1 * time.Second)
36   }
37  }
38  
39  func finally(watcher chan struct{}) {
40   // 重启时没有执行此函数
41   fmt.Println("exit original exec")
42   close(watcher)
43  }
44  
45  func setupWatcher() (chan struct{}, error) {
46   file, err := osext.Executable()
47   if err != nil {
48     return nil, err
49   }
50   log.Printf("watching %qn", file)
51   w, err := fsnotify.NewWatcher()
52   if err != nil {
53     return nil, err
54   }
55   done := make(chan struct{})
56   go func() {
57     select {
58     case e := <-w.Events:
59       log.Printf("watcher received: %v", e)
60       err := syscall.Exec(file, os.Args, os.Environ())
61       if err != nil {
62         log.Fatal(err)
63       }
64     case err := <-w.Errors:
65       log.Printf("watcher error: %+v", err)
66     case <-done:
67       log.Print("watcher shutting down")
68       return
69     }
70   }()
71   err = w.Add(file)
72   if err != nil {
73     return nil, err
74   }
75   return done, nil
76  }