update

application/init_app.go

@@ -25,6 +25,7 @@ import (
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/app"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/logger"
 	_ "gitlab.wanzhuangkj.com/tush/xpkg/xcron"
+	_ "gitlab.wanzhuangkj.com/tush/xpkg/xutils/redsyncutils"
 )
 
 func init() {

xutils/redsyncutils/red_sync_utils.go

@@ -7,6 +7,8 @@ import (
 	"github.com/go-redsync/redsync/v4"
 	"github.com/go-redsync/redsync/v4/redis/goredis/v9"
 	"github.com/redis/go-redis/v9"
+	"gitlab.wanzhuangkj.com/tush/xpkg/database"
+	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/eventbus"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/logger"
 	"gitlab.wanzhuangkj.com/tush/xpkg/pkg/xerrors/xerror"
 	ctxutils "gitlab.wanzhuangkj.com/tush/xpkg/xutils/ctxutils"
@@ -16,7 +18,13 @@ var (
 	redSync *redsync.Redsync
 )
 
-func Init(redisCli *redis.Client) {
+func init() {
+	eventbus.Eb.Subscribe(eventbus.TopicCacheInitFinish, func(ctx context.Context) {
+		initialize(database.GetRedisCli())
+	})
+}
+
+func initialize(redisCli *redis.Client) {
 	pool := goredis.NewPool(redisCli)
 	redSync = redsync.New(pool)
 }