1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

func (a *app) signalHandler(wg *sync.WaitGroup) {

ch := make(chan os.Signal, 10)

signal.Notify(ch, syscall.SIGINT, syscall.SIGTERM, syscall.SIGUSR2)

for {

sig := <-ch

switch sig {

case syscall.SIGINT, syscall.SIGTERM:

// this ensures a subsequent INT/TERM will trigger standard go behaviour of

// terminating. 执行标准的go终止行为，程序就结束了

signal.Stop(ch)

a.term(wg)

return

case syscall.SIGUSR2: // 这里开始执行优雅重启

err := a.preStartProcess()

// 这个函数在源代码中没有具体实现功能，只是预留了一个钩子函数，用户可以注册自己的函数，可以在重启之前做些自定义的事情。一般情况下也没有什么可以做的，除非有些特殊的服务环境或是状态保存之类的，至少目前，我们的server还没有遇到

if err != nil {

a.errors <- err

}

// we only return here if there's an error, otherwise the new process

// will send us a TERM when it's ready to trigger the actual shutdown.

if _, err := a.net.StartProcess(); err != nil { // 这里开始正式所谓的优雅重启

a.errors <- err

}

}

}

}

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

40

41

42

43

44

45

46

47

func (n *Net) StartProcess() (int, error) {

listeners, err := n.activeListeners() // 获取目前在监听的端口，这块也是重点，下面重点介绍

if err != nil {

return 0, err

}

// Extract the fds from the listeners. 从监听端口中把文件描述符取出来

files := make([]*os.File, len(listeners))

for i, l := range listeners {

files[i], err = l.(filer).File()

if err != nil {

return 0, err

}

defer files[i].Close()

}

// Use the original binary location. This works with symlinks such that if

// the file it points to has been changed we will use the updated symlink.

// 获取可执行bin文件的路劲，也可以是链接路劲，会使用最新的链接路径作为启动文件路劲的

argv0, err := exec.LookPath(os.Args[0])

if err != nil {

return 0, err

}

// Pass on the environment and replace the old count key with the new one.

// 获取 LISTEN_FDS 换进变量值

var env []string

for _, v := range os.Environ() {

if !strings.HasPrefix(v, envCountKeyPrefix) {

env = append(env, v)

}

}

env = append(env, fmt.Sprintf("%s%d", envCountKeyPrefix, len(listeners)))

allFiles := append([]*os.File{os.Stdin, os.Stdout, os.Stderr}, files...)

// 这里调用一个golang底层的进程启动函数，来指定，上面获取的参数来启动进程

process, err := os.StartProcess(argv0, os.Args, &os.ProcAttr{

Dir: originalWD,

Env: env,

Files: allFiles,

})

if err != nil {

return 0, err

}

// 返回新进程id。

return process.Pid, nil

}