diff --git a/pkg/common/db/model.go b/pkg/common/db/model.go index b586bab2f..bf2058e51 100644 --- a/pkg/common/db/model.go +++ b/pkg/common/db/model.go @@ -49,7 +49,7 @@ func init() { var mongoClient *mongo.Client var err1 error fmt.Println("init mysql redis mongo ") - defer fmt.Println("init mysql redis mongo ok ") + initMysqlDB() // mongo init // "mongodb://sysop:moon@localhost/records" @@ -148,6 +148,8 @@ func init() { // 弱一致性缓存,当一个key被标记删除,其他请求线程直接返回该key的value,适合高频并且生成很缓存很慢的情况 如大群发消息缓存的缓存 DB.WeakRc = rockscache.NewClient(DB.RDB, rockscache.NewDefaultOptions()) DB.WeakRc.Options.StrongConsistency = false + + fmt.Println("init mysql redis mongo ok ") } func createMongoIndex(client *mongo.Client, collection string, isUnique bool, keys ...string) error {