diff --git a/common/rpc/func.go b/common/rpc/func.go index d9a3011b8..f608a45f2 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(100000*cool.Config.ServerInfo.OnlineID+cool.Config.ServerInfo.Port)) //发起战斗 ,由房主服务器主动拉取战斗实现 + conn.Do(ctx, "subscribe", "sun:sendpack:"+gconv.String(100000*cool.Config.ServerInfo.OnlineID+cool.Config.ServerInfo.Port)) //接受战斗的信息,直接接受包转发就行 // 4. 循环接收消息 connError := false for !connError {