日志保存修改

core/logs/internal/savedb/saveDb.go

@@ -22,7 +22,7 @@ func (s *DbLogs) SaveLogTask() {
 		s.Cache = make([]map[string]interface{}, 0)
 		go func() {
 			log.Println("timer..save..visit..log", len(tmp))
-			db.MgoLog.SaveBulk("jy_logs", tmp...)
+			db.MgoLog.SaveBulk("jy_gateway_logs", tmp...)
 		}()
 	}
 
@@ -33,7 +33,7 @@ func (s *DbLogs) SaveLogTask() {
 func (s *DbLogs) AddLogToTask(data map[string]interface{}) {
 	s.lock.Lock()
 	s.Cache = append(s.Cache, data)
-	if len(s.Cache) >= 500 {
+	if len(s.Cache) >= 5 {
 		tmp := s.Cache
 		s.Cache = make([]map[string]interface{}, 0)
 		go func() {

main.go

@@ -12,9 +12,9 @@ import (
 
 func init() {
 	g.Cfg().GetAdapter().(*gcfg.AdapterFile).SetFileName("./etc/config.yaml") //设置配置文件
+	db.InitDatabases()                                                        // 初始化数据库
 	logs.InitLogs()                                                           // 初始化日志组件
 	rpc.InitBaseServerRpc()                                                   // 初始化rpc服务连接
-	db.InitDatabases()                                                        // 初始化数据库
 	middleware.InitFilterPolyManager()                                        // 初始化
 }