From b4e1129c56089804d3484092bacbcb2820ef6fc8 Mon Sep 17 00:00:00 2001 From: 1 <1@72wo.cn> Date: Thu, 6 Nov 2025 18:24:51 +0000 Subject: [PATCH] =?UTF-8?q?refactor(fight):=20=E4=BC=98=E5=8C=96=E6=88=98?= =?UTF-8?q?=E6=96=97=E9=80=BB=E8=BE=91=E4=BB=A3=E7=A0=81=E7=BB=93=E6=9E=84?= =?UTF-8?q?=EF=BC=8C=E6=B8=85=E7=90=86=E5=86=97=E4=BD=99=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- logic/controller/getserver.go | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/logic/controller/getserver.go b/logic/controller/getserver.go index 1ceb195b..d9be0b07 100644 --- a/logic/controller/getserver.go +++ b/logic/controller/getserver.go @@ -3,12 +3,22 @@ package controller import ( "blazing/common/rpc" "blazing/common/socket/errorcode" - "blazing/logic/service/user" + "golang.org/x/sync/singleflight" + "github.com/panjf2000/gnet/v2" ) +var sg singleflight.Group + +var ServerList []rpc.ServerInfo + +func fetchData() (any, error) { + ServerList = rpc.GetServerInfoList() //todo 待修改增加缓存 + return ServerList, nil +} + // 处理命令: 105 func (h *Controller) COMMEND_ONLINE(data *user.SidInfo, c gnet.Conn) (result *rpc.CommendSvrInfo, err errorcode.ErrorCode) { //这个时候player应该是空的 result = rpc.NewInInfo() @@ -16,8 +26,9 @@ func (h *Controller) COMMEND_ONLINE(data *user.SidInfo, c gnet.Conn) (result *rp if data.Head.UserID < 100000 { result.IsVip = 1 } + v, _, _ := sg.Do("GetServerInfoList", fetchData) - result.ServerList = rpc.GetServerInfoList() //todo 待修改增加缓存 + result.ServerList = v.([]rpc.ServerInfo) //todo 待修改增加缓存 return