update

application/init_app.go

@@ -58,6 +58,7 @@ func (x *Application) Run() {
 	services := CreateServices(x.h())
 	closes := Close(services)
 	x.app = app.New(services, closes)
+	eventbus.Eb.Publish(context.TODO(), eventbus.TopicPrintSwagger)
 	x.app.Run()
 }
 

gin/xgin/xgin.go

 package xgin
 
 import (
+	"context"
 	"fmt"
 	"net/http"
 	"time"
@@ -18,6 +19,7 @@ import (
 	"gitlab.wanzhuangkj.com/tush/xpkg/gin/prof"
 	"gitlab.wanzhuangkj.com/tush/xpkg/gin/validator"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/errcode"
+	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/eventbus"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/ips"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/jwt"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/logger"
@@ -96,13 +98,13 @@ func New() *gin.Engine {
 	if config.IsNotProd() {
 		r.GET(consts.RootRoute+"/config", gin.WrapF(errcode.ShowConfig([]byte(config.Show()))))
 		r.GET(consts.RootRoute+"/swagger/*any", ginSwagger.WrapHandler(swaggerFiles.Handler))
-		defer func() {
+		eventbus.Eb.Subscribe(eventbus.TopicPrintSwagger, func(ctx context.Context) {
 			fmt.Println(text.Blue(fmt.Sprintf("swagger: http://localhost:%d"+consts.RootRoute+"/swagger/index.html", httpCfg.Port)))
 			ip := ips.GetLocalHost()
 			if ip != "" {
 				fmt.Println(text.Blue(fmt.Sprintf("swagger: https://%s:%d"+consts.RootRoute+"/swagger/index.html", ip, httpCfg.Port)))
 			}
-		}()
+		})
 	}
 
 	r.GET("/health", handlerfunc.CheckHealth)

pkg/eventbus/init.go

@@ -9,5 +9,6 @@ const (
 	TopicCacheInitFinish  string = "event:application:cache:init:finish"    // cache初始化完成
 	TopicCronInitFinish   string = "event:application:cron:init:finish"     // 定时任务初始化完成
 	TopicCoreInitFinish   string = "event:application:core:init:finish"     // 核心服务初始化完成
+	TopicPrintSwagger     string = "event:swagger:print"                    // 打印swagger doc info
 	TopicApplicationClose string = "event:application:close"                // 应用关闭
 )