会话

main.go

@@ -26,7 +26,7 @@ func main() {
 	web.Router("/", &controllers.BaseCommonController{})
 	go services.Task()
 
-	go services.StartSessionManager()
+
 	// 异常处理
 	web.ErrorController(&controllers.ErrorController{})
 

routers/commentsRouter.go

@@ -13119,5 +13119,4 @@ func init() {
             MethodParams: param.Make(),
             Filters: nil,
             Params: nil})
-
-}
+}

services/task.go

@@ -60,7 +60,7 @@ func Task() {
 		// 监听数据源binlog写入es
 		go binlog.HandleDataSourceChange2Es()
 	}
-
+	go StartSessionManager()
 	// TODO:数据修复
 	//FixNewEs()
 	fmt.Println("task end")

utils/ws/limiter.go

@@ -22,7 +22,7 @@ const (
 	LIMITER_KEY         = "llm_chat_key_user_%d"
 	CONNECT_LIMITER_KEY = "llm_chat_connect_key_user_%d"
 
-	RATE_LIMTER_TIME	=60*time.Second
+	RATE_LIMTER_TIME	=30*time.Second
 )
 
 type RateLimiter struct {