From 8fdaf91d34e760c4ccec87ae53ea6e76d162455a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=98=94=E5=BF=B5?= <12574910+72wo@users.noreply.github.com> Date: Wed, 4 Mar 2026 23:40:18 +0800 Subject: [PATCH] =?UTF-8?q?```=20fix(rpc):=20=E4=BF=AE=E5=A4=8DRedis?= =?UTF-8?q?=E8=AE=A2=E9=98=85=E4=B8=BB=E9=A2=98=E5=90=8D=E7=A7=B0=E9=94=99?= =?UTF-8?q?=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 修复了战斗系统中Redis订阅主题名称的拼写错误, 将"sun:sendpack"修正为"sun:sendpack:"以确保 消息订阅功能正常工作。 ``` --- common/rpc/func.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/common/rpc/func.go b/common/rpc/func.go index 636b24d14..d9a3011b8 100644 --- a/common/rpc/func.go +++ b/common/rpc/func.go @@ -192,8 +192,8 @@ func ListenFight(ctx g.Ctx) { // cool.Logger.Info(ctx, "成功订阅 Redis 主题", "topic", subscribeTopic) //房主服务器拉取之后,所有操作通过redie转发到房主服务器去执行,非房主方只进行收包操作 - conn.Do(ctx, "subscribe", "sun:start:"+gconv.String(cool.Config.ServerInfo.Port)) //发起战斗 ,由房主服务器主动拉取战斗实现 - conn.Do(ctx, "subscribe", "sun:sendpack"+gconv.String(cool.Config.ServerInfo.Port)) //接受战斗的信息,直接接受包转发就行 + conn.Do(ctx, "subscribe", "sun:start:"+gconv.String(cool.Config.ServerInfo.Port)) //发起战斗 ,由房主服务器主动拉取战斗实现 + conn.Do(ctx, "subscribe", "sun:sendpack:"+gconv.String(cool.Config.ServerInfo.Port)) //接受战斗的信息,直接接受包转发就行 // 4. 循环接收消息 connError := false for !connError {