用过Go语言的HTTP包的同学应该知道，要进行监听客户端请求的话必须调用其 ListenAndServe() 函数，所以我们要定义这个函数：
func ListenAndServe(addr string, handler http.Handler) error {
server := NewServer(addr, handler)
return server.ListenAndServe()
}
函数的实现很简单，就是先调用 NewServer() 函数创建一个 endlessServer 结构，然后调用其 ListenAndServe() 方法。所以我们要为 endlessServer 结构定义一个 ListenAndServe() 方法：
func (srv *endlessServer) ListenAndServe() (err error) {
addr := srv.Addr
if addr == "" {
addr = ":http"
}
go srv.handleSignals()
l, err := srv.getListener(addr)
if err != nil {
log.Println(err)
return
}
srv.EndlessListener = newEndlessListener(l, srv)
if srv.isChild {
syscall.Kill(syscall.Getppid(), syscall.SIGTERM)
}
return srv.Serve()
}
ListenAndServe() 方法首先会创建一个协程处理 handleSignals() 方法，这个方法主要是处理信号，下面会介绍。然后调用 getListener() 方法获取一个类型为 net.Listener 的对象，然后调用 newEndlessListener() 函数创建一个类型为 endlessListener 的对象。再通过判断当前进程是否为新的处理进程，如果是就调用 syscall.Kill() 方法发送一个 SIGTERM信号 给父进程（旧的服务处理进程），最后调用 Serve() 方法开始处理客户端连接。
我们先来看看处理信号的 handleSignal() 方法：
func (srv *endlessServer) handleSignals() {
var sig os.Signal
signal.Notify(
srv.sigChan,
syscall.SIGHUP,
syscall.SIGINT,
syscall.SIGTERM,
)
pid := syscall.Getpid()
for {
sig = <-srv.sigChan
srv.signalHooks(PRE_SIGNAL, sig)
switch sig {
case syscall.SIGHUP:
err := srv.fork()
if err != nil {
log.Println("Fork err:", err)
}
case syscall.SIGINT:
srv.shutdown()
case syscall.SIGTERM:
srv.shutdown()
default:
log.Printf("Received %v: nothing i care about...n", sig)
}
}
}
handleSignal() 方法主要监听3种信号， syscall.SIGHUP 、 syscall.SIGINT 和 syscall.SIGTERM 。 syscall.SIGHUP 信号为重启信号，而 syscall.SIGINT 信号为关闭服务信号，而 syscall.SIGTERM 信号主要是新的服务进程发送给旧的服务进程，告诉其关闭监听处理客户端的socket。当收到 syscall.SIGHUP 信号时，需要调用 fork() 方法来创建一个新的服务进程，而收到 syscall.SIGINT 和 syscall.SIGTERM 信号主要调用 shutdown() 方法来关闭当前进程。
再来看看创建新服务进程的 fork() 方法：
func (srv *endlessServer) fork() (err error) {
files := []*os.File{
srv.EndlessListener.(*endlessListener).File(),
}
env := append(
os.Environ(),
"ENDLESS_CONTINUE=1",
)
path := os.Args[0]
var args []string
if len(os.Args) > 1 {
args = os.Args[1:]
}
cmd := exec.Command(path, args...)
cmd.Stdout = os.Stdout
cmd.Stderr = os.Stderr
cmd.ExtraFiles = files
cmd.Env = env
err = cmd.Start()
if err != nil {
log.Fatalf("Restart: Failed to launch, error: %v", err)
}
return
}
