update

app/cfg/init_task.go

@@ -30,6 +30,8 @@ func InitTaskCfg() {
 	IMDB = &conf.ImDB
 	Log = &conf.Log
 	RedisAddr = conf.RedisAddr
+	MQ = &conf.MQ
+	ES = &conf.ES
 }
 
 var MemCache mc.Cache

cmd/task/main.go

@@ -20,6 +20,8 @@ func init() {
 	cfg.InitLog()
 	// 初始化redis
 	cfg.InitCache()
+	cfg.InitMq() // 队列初始化
+	cfg.InitEs() //ElasticSearch初始化
 	baseDb := *cfg.DB
 	baseDb.Path = fmt.Sprintf(cfg.DB.Path, cfg.DB.Name)
 	if err := db.InitDB(&baseDb); err != nil {