From 928d78d41bcd22a64bd9a649c6fc2666e1bdf7c7 Mon Sep 17 00:00:00 2001
From: luorijun <luorijun@outlook.com>
Date: Sat, 24 May 2025 12:35:43 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4=E4=B8=8D=E5=BF=85=E8=A6=81?=
 =?UTF-8?q?=E7=9A=84=20Asynq=20=E5=AE=A2=E6=88=B7=E7=AB=AF=E5=85=B3?=
 =?UTF-8?q?=E9=97=AD=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 README.md            |  2 ++
 web/globals/asynq.go | 10 ----------
 web/web.go           |  2 --
 3 files changed, 2 insertions(+), 12 deletions(-)

diff --git a/README.md b/README.md
index 3d567a3..7e59b10 100644
--- a/README.md
+++ b/README.md
@@ -1,5 +1,7 @@
 ## TODO
 
+修改边缘节点上线分配策略，已分配的边缘节点优先使用旧的配置，新的边缘节点使用负载均衡算法分配新的网关
+
 ## 枚举字典
 
 ### 产品
diff --git a/web/globals/asynq.go b/web/globals/asynq.go
index 19fe59c..b494482 100644
--- a/web/globals/asynq.go
+++ b/web/globals/asynq.go
@@ -2,7 +2,6 @@ package globals
 
 import (
 	"github.com/hibiken/asynq"
-	"log/slog"
 )
 
 var Asynq *asynq.Client
@@ -11,12 +10,3 @@ func InitAsynq() {
 	var client = asynq.NewClientFromRedisClient(Redis)
 	Asynq = client
 }
-
-func CloseAsynq() {
-	if Asynq != nil {
-		err := Asynq.Close()
-		if err != nil {
-			slog.Error("关闭 Asynq 客户端失败", "error", err)
-		}
-	}
-}
diff --git a/web/web.go b/web/web.go
index 7db773b..2b3016f 100644
--- a/web/web.go
+++ b/web/web.go
@@ -94,8 +94,6 @@ func (s *Server) Stop() {
 		slog.Error("Failed to close database connection", slog.Any("err", err))
 	}
 
-	g.CloseAsynq()
-
 	err = s.fiber.Shutdown()
 	if err != nil {
 		slog.Error("Failed to shutdown server", slog.Any("err", err))