feat(common/rpc): 修改Redis订阅主题的生成规则 将Redis订阅主题的生成方式从仅使用端口号改为使用OnlineID和端口号的组合, 通过公式10000*OnlineID+Port来生成唯一的订阅主题,以支持多服务器环境下的 战斗功能区分。 ```
This commit is contained in:
@@ -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 {
|
||||
|
||||
Reference in New Issue
Block a user