对于一个Golang开发者来说,牢固扎实的基础是十分重要的,编程网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《如何优雅地退出 go uber fx 应用程序》,主要介绍了,希望对大家的知识积累有所帮助,快点收藏起来吧,否则需要时就找不到了!
问题内容如何停止 uber fx,就像关闭整个程序一样。除了ctrl+c好像没有别的办法了
func main() {
fx.New(
fx.Invoke(register)
).Run
}
func register() {
time.Sleep(5*time.Seconds)
// shutdown somehow
}
解决方案
docs 不是特别清楚,但有一个 shutdowner
接口可供任何具有 shutdown
方法的 fx 模块使用,该方法请求正常关闭应用程序。
这是 the example package 的修改部分,它将在收到请求后简单地关闭:
func newhandler(logger *log.logger, shutdowner fx.shutdowner) (http.handler, error) {
logger.print("executing newhandler.")
return http.handlerfunc(func(http.responsewriter, *http.request) {
logger.print("got a request. requesting shutdown now that i've gotten one request.")
shutdowner.shutdown()
}), nil
}
编辑:以下是修改解决方案的方法:
func register(shutdowner fx.shutdowner) {
time.sleep(5*time.seconds)
shutdowner.shutdown()
}
您可以将其包装在 go 例程中并使用上下文优雅退出。
import (
"context"
"log"
" go.uber.org/fx"
)
func main() {
f := fx.New(fx.Invoke(register))
go func() {
f.Run()
}()
stopCh := make(chan os.Signal)
signal.Notify(stopCh, syscall.SIGINT, syscall.SIGTERM)
<-stopCh
if err := f.Stop(context.Background()); err != nil {
log.Printf("error stopping gracefully")
}
}
func register() {
time.Sleep(5*time.Seconds)
// shutdown somehow
}
今天关于《如何优雅地退出 go uber fx 应用程序》的内容就介绍到这里了,是不是学起来一目了然!想要了解更多关于的内容请关注编程网公众号!