Go 语言中达成优雅的停止程序
发布时间：2021-11-21 17:43:52 所属栏目：教程 来源：互联网
导读：过早的部署这种行为非常粗略，尤其是在部署还要中断用户请求的情况下更是如此，因此，我们在Betable构建的Go服务要在不中断任何用户请求的情况下优雅的中止服务。其基本思想就是停止侦听（llistening），假定会有一个新的进程来接管这些侦听，让所有已经建立
|
过早的部署这种行为非常粗略，尤其是在部署还要中断用户请求的情况下更是如此，因此，我们在Betable构建的Go服务要在不中断任何用户请求的情况下优雅的中止服务。其基本思想就是停止侦听（llistening），假定会有一个新的进程来接管这些侦听，让所有已经建立起来的连接在最终停止服务前继续处理进行中的请求。顺便说一句，我们采用了goagain，从而可以甚至在不停止侦听的情况下重启服务，但这个话题超出了本文的讨论范围。 main.main做了四件事情：侦听、生成一个Service并将其发送到后台（background）执行、阻塞直到收到相应的信号（signal）、 然后优雅的停止服务。侦听以及信号处理完全出自于标准库的一般打法，只有一点令我十分恼火，就是，不仅需要使用anet.Listener或者net.Connto调用SetDeadline，竟然还需要*net.TCPListener或者*net.TCPConnand。 service.Serve(listener)用来接受连接请求并在它自己的goroutine之内处理它所接受的每个连接请求。由于它设置了一个截至时间，所以listener.AcceptTCP()不会永久性地处于阻塞状态，而且它还会在下一轮循环时检查它是否应该停止侦听。 service.serve(conn)进行读写操作，而且同样的，它也具有一个截至时间。由于它设置了截至时间，所以conn.Read(buf)不会永久性地处于阻塞状态，而且在写入响应数据和读取下一个请求之间或者超过了conn.Read(buf)截至时间后，检查它是否应该关闭该连接。 因为不会有别的东西发送到service的channel中，只有在service.Stop()关闭该channel后才会向该channel中发送一个值，所以，只要从service的channel中接收到一个值，各个goroutine就会决定关闭相关的连接和侦听器（listener）。 难题的最后一个部分是通过调用标准库sync.WaitGroup实现等待所有的goroutine结束执行。  （编辑：开发网_开封站长网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
浙公网安备 33038102330459号