From 7121448d7c5ff9453a883ed524897ccde09e75f2 Mon Sep 17 00:00:00 2001 From: duhui Date: Tue, 16 May 2023 17:45:47 +0800 Subject: [PATCH 1/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=951?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ljsd/jieling/db/mongo/AreaManager.java | 19 ++++++++++++++----- .../jieling/handler/GetPlayerInfoHandler.java | 4 ++++ .../jieling/logic/dao/cross/CSPlayer.java | 2 +- 3 files changed, 19 insertions(+), 6 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java index 24b88351e..f4a0693b6 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java @@ -416,7 +416,10 @@ public class AreaManager { } public int getServerIdByUid(int uid, int defaultServerId) { -// Integer serverIdByUid = RedisUtil.getInstence().getMapEntry(RedisKey.CUser_ServerId_Key,"",Integer.toString(uid),Integer.class); + if (defaultServerId == GameApplication.serverId){ + return defaultServerId; + } + if (serverIds.contains(uid)) { return uid; } @@ -424,11 +427,17 @@ public class AreaManager { if (serverIdByUid != null) { return serverIdByUid; } + int serverIdFromMongo = CoreLogic.getInstance().findServerIdFromMongo(uid); - if (serverIdFromMongo > 0) { - String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; - RedisUtil.getInstence().setObject(key, Integer.toString(serverIdFromMongo), GlobalsDef.REDIS_OVER_TIME_DAY * 10); - } +// if (serverIdFromMongo > 0) { +// String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; +// RedisUtil.getInstence().setObject(key, Integer.toString(serverIdFromMongo), GlobalsDef.REDIS_OVER_TIME_DAY * 10); +// } return serverIdFromMongo; } + + public void putCUserServer(int uid, int serverId){ + String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; + RedisUtil.getInstence().setObject(key, serverId, GlobalsDef.REDIS_OVER_TIME_DAY * 10); + } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java index 596483885..49b9ee525 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java @@ -4,6 +4,7 @@ import com.alibaba.fastjson.JSON; import com.ljsd.GameApplication; import com.ljsd.jieling.config.clazzStaticCfg.HeroStaticConfig; import com.ljsd.jieling.core.GlobalsDef; +import com.ljsd.jieling.db.mongo.AreaManager; import com.ljsd.jieling.db.mongo.LjsdMongoTemplate; import com.ljsd.jieling.db.mongo.MongoUtil; import com.ljsd.jieling.db.mongo.gmActivity.ARBActivity; @@ -83,6 +84,9 @@ public class GetPlayerInfoHandler extends BaseHandler{ int token = netData.getToken(); int msgId = netData.getMsgId(); int msgIndex = netData.getIndex(); + + AreaManager.getInstance().putCUserServer(userId, GameApplication.serverId); + PlayerInfoProto.GetPlayerInfoRequest getPlayerInfoRequest = PlayerInfoProto.GetPlayerInfoRequest.parseFrom(netData.parseClientProtoNetData()); LOGGER.info("processMessage->uid={},token={},msgId={},msgIndex={},messageNum={},messageStr={}", userId, token,msgId,msgIndex,getPlayerInfoRequest.getNum(),getPlayerInfoRequest.getStr()); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/cross/CSPlayer.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/cross/CSPlayer.java index 824fdd825..defd47ee3 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/cross/CSPlayer.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/dao/cross/CSPlayer.java @@ -182,7 +182,7 @@ public class CSPlayer { } public int getServerId() { - return AreaManager.getInstance().getServerIdByUid(userId, GameApplication.serverId); + return AreaManager.getInstance().getServerIdByUid(userId, 0); } public void setServerId(int serverId) { From e105b589193a7acc42267c0326f537a98c5671e5 Mon Sep 17 00:00:00 2001 From: duhui Date: Wed, 17 May 2023 11:04:48 +0800 Subject: [PATCH 2/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=952?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ljsd/jieling/db/mongo/AreaManager.java | 22 +++++++++---------- .../jieling/handler/GetPlayerInfoHandler.java | 2 +- 2 files changed, 12 insertions(+), 12 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java index f4a0693b6..5c80ab647 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java @@ -416,9 +416,9 @@ public class AreaManager { } public int getServerIdByUid(int uid, int defaultServerId) { - if (defaultServerId == GameApplication.serverId){ - return defaultServerId; - } +// if (defaultServerId == GameApplication.serverId){ +// return defaultServerId; +// } if (serverIds.contains(uid)) { return uid; @@ -429,15 +429,15 @@ public class AreaManager { } int serverIdFromMongo = CoreLogic.getInstance().findServerIdFromMongo(uid); -// if (serverIdFromMongo > 0) { -// String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; -// RedisUtil.getInstence().setObject(key, Integer.toString(serverIdFromMongo), GlobalsDef.REDIS_OVER_TIME_DAY * 10); -// } + if (serverIdFromMongo > 0) { + String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; + RedisUtil.getInstence().setObject(key, Integer.toString(serverIdFromMongo), GlobalsDef.REDIS_OVER_TIME_DAY * 10); + } return serverIdFromMongo; } - public void putCUserServer(int uid, int serverId){ - String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; - RedisUtil.getInstence().setObject(key, serverId, GlobalsDef.REDIS_OVER_TIME_DAY * 10); - } +// public void putCUserServer(int uid, int serverId){ +// String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; +// RedisUtil.getInstence().setObject(key, serverId, GlobalsDef.REDIS_OVER_TIME_DAY * 10); +// } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java index 49b9ee525..87c46d4ca 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java @@ -85,7 +85,7 @@ public class GetPlayerInfoHandler extends BaseHandler{ int msgId = netData.getMsgId(); int msgIndex = netData.getIndex(); - AreaManager.getInstance().putCUserServer(userId, GameApplication.serverId); +// AreaManager.getInstance().putCUserServer(userId, GameApplication.serverId); PlayerInfoProto.GetPlayerInfoRequest getPlayerInfoRequest = PlayerInfoProto.GetPlayerInfoRequest.parseFrom(netData.parseClientProtoNetData()); LOGGER.info("processMessage->uid={},token={},msgId={},msgIndex={},messageNum={},messageStr={}", From 0e1e5d22c2e7e095dca3ae42382f5b0e007424ba Mon Sep 17 00:00:00 2001 From: duhui Date: Wed, 17 May 2023 11:08:40 +0800 Subject: [PATCH 3/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=952?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/ljsd/jieling/logic/player/PlayerLogic.java | 11 +++++++++++ 1 file changed, 11 insertions(+) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java index b143de3bf..f9b381829 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java @@ -1777,6 +1777,17 @@ public class PlayerLogic { if (rpcString == null) { return null; } + // 合服 + String localRpc = RedisUtil.getInstence().getObject(RedisKey.LOGIC_SERVER_INFO, String.valueOf(GameApplication.serverId), String.class, -1); + if (localRpc != null && localRpc.equals(rpcString)) { + try { + return UserManager.getUser(uid, true); + } catch (Exception e) { + LOGGER.info("getUserByRpc Exception uid={} e={}", uid, e); + return null; + } + } + String[] split = rpcString.split(":"); if (split.length < 4) { LOGGER.error("获取玩家rpc地址,长度错误,rpc:{},玩家id:{},服务器id:{}", rpcString, uid, serverId); From e8c17d38ddbc2f0d18afb46485838b0bd5561243 Mon Sep 17 00:00:00 2001 From: duhui Date: Wed, 17 May 2023 16:21:23 +0800 Subject: [PATCH 4/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=952?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/ljsd/jieling/db/redis/RedisUtil.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java index cedf29a6e..c05d218cb 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java @@ -1587,11 +1587,9 @@ public class RedisUtil { return type + RedisKey.Delimiter_colon + key; } - if (!RedisKey.newAreaCacChe.contains(type) && !RedisKey.rankCacChe.contains(type) && key.length() == 8) { - Integer serverId = RedisUtil.getInstence().getObject(RedisKey.CUser_ServerId_Key, key, Integer.class, GlobalsDef.REDIS_OVER_TIME_DAY * 10); - if (serverId != null){ - return serverId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; - } + Integer serverId = RedisUtil.getInstence().getObject(RedisKey.CUser_ServerId_Key, key, Integer.class, GlobalsDef.REDIS_OVER_TIME_DAY * 10); + if (serverId != null){ + return serverId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; } return AreaManager.areaId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; From 0166becd7755c89cb7db1f99f9a2230e7d5fcf87 Mon Sep 17 00:00:00 2001 From: duhui Date: Thu, 18 May 2023 13:24:15 +0800 Subject: [PATCH 5/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=953?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/ljsd/jieling/core/CoreLogic.java | 19 +++++-- .../ljsd/jieling/db/mongo/AreaManager.java | 27 +++++----- .../ljsd/jieling/db/mongo/core/CHefuInfo.java | 50 +++++++++++++++++++ .../com/ljsd/jieling/db/redis/RedisUtil.java | 8 +-- .../jieling/handler/GetPlayerInfoHandler.java | 4 +- .../jieling/logic/player/PlayerLogic.java | 11 +--- 6 files changed, 84 insertions(+), 35 deletions(-) create mode 100644 serverlogic/src/main/java/com/ljsd/jieling/db/mongo/core/CHefuInfo.java diff --git a/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java index 6318bc53a..9a4a165e2 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java @@ -1,6 +1,8 @@ package com.ljsd.jieling.core; +import com.ljsd.GameApplication; import com.ljsd.jieling.db.mongo.MongoUtil; +import com.ljsd.jieling.db.mongo.core.CHefuInfo; import com.ljsd.jieling.db.mongo.core.ServerAreaInfoManager; import com.ljsd.jieling.logic.dao.SCdkInfo; import com.ljsd.jieling.logic.dao.root.UserInfo; @@ -30,13 +32,22 @@ public class CoreLogic { public final static CoreLogic instance = new CoreLogic(); } - - - public ServerAreaInfoManager findServerArenaInfoManager() throws Exception{ - MongoTemplate coreMongoTemplate =MongoUtil.getCoreMongoTemplate(); + public ServerAreaInfoManager findServerArenaInfoManager() throws Exception{ + MongoTemplate coreMongoTemplate = MongoUtil.getCoreMongoTemplate(); return coreMongoTemplate.findById(1,ServerAreaInfoManager.class); } + public CHefuInfo findHefuInfo() { + MongoTemplate coreMongoTemplate = MongoUtil.getCoreMongoTemplate(); + Query query = new Query(Criteria.where("serverId").is(GameApplication.serverId)); + return coreMongoTemplate.findOne(query, CHefuInfo.class); + } + + public boolean isHefu(int serverId) { + CHefuInfo hefuInfo = findHefuInfo(); + return hefuInfo.getSlaveServerIds().contains(serverId); + } + public int findServerIdFromMongo(int uid) { MongoTemplate coreMongoTemplate = MongoUtil.getCoreMongoTemplate(); Query query = new Query(Criteria.where("_id").is(uid)); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java index 5c80ab647..0193d8789 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/AreaManager.java @@ -416,28 +416,25 @@ public class AreaManager { } public int getServerIdByUid(int uid, int defaultServerId) { -// if (defaultServerId == GameApplication.serverId){ -// return defaultServerId; -// } - - if (serverIds.contains(uid)) { - return uid; + if (defaultServerId == GameApplication.serverId){ + return defaultServerId; } + Integer serverIdByUid = RedisUtil.getInstence().getObject(RedisKey.CUser_ServerId_Key, Integer.toString(uid), Integer.class, GlobalsDef.REDIS_OVER_TIME_DAY * 10); - if (serverIdByUid != null) { + if (serverIdByUid != null && !CoreLogic.getInstance().isHefu(serverIdByUid)) { return serverIdByUid; } int serverIdFromMongo = CoreLogic.getInstance().findServerIdFromMongo(uid); - if (serverIdFromMongo > 0) { - String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; - RedisUtil.getInstence().setObject(key, Integer.toString(serverIdFromMongo), GlobalsDef.REDIS_OVER_TIME_DAY * 10); + if (serverIdFromMongo != 0 && !CoreLogic.getInstance().isHefu(serverIdFromMongo)){ + return serverIdFromMongo; } - return serverIdFromMongo; + + return GameApplication.serverId; } -// public void putCUserServer(int uid, int serverId){ -// String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; -// RedisUtil.getInstence().setObject(key, serverId, GlobalsDef.REDIS_OVER_TIME_DAY * 10); -// } + public void putCUserServer(int uid, int serverId){ + String key = RedisKey.CUser_ServerId_Key + RedisKey.Delimiter_colon + uid; + RedisUtil.getInstence().setObject(key, serverId, GlobalsDef.REDIS_OVER_TIME_DAY * 10); + } } diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/core/CHefuInfo.java b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/core/CHefuInfo.java new file mode 100644 index 000000000..f530e2603 --- /dev/null +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/mongo/core/CHefuInfo.java @@ -0,0 +1,50 @@ +package com.ljsd.jieling.db.mongo.core; + +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.mapping.Document; +import org.springframework.data.mongodb.core.mapping.Field; + +import java.util.List; + +/** + * @Author hj + * @Date 2023/5/17 17:22:10 + * @Description: + * @Version 1.0 + */ +@Document(collection = "c_hefu_info") +public class CHefuInfo { + + @Id + private int id; + + @Field(value = "masterServerId") + private int masterServerId; + + @Field(value = "slaveServerIds") + private List slaveServerIds; + + public int getMasterServerId() { + return masterServerId; + } + + public void setMasterServerId(int masterServerId) { + this.masterServerId = masterServerId; + } + + public int getId() { + return id; + } + + public void setId(int id) { + this.id = id; + } + + public List getSlaveServerIds() { + return slaveServerIds; + } + + public void setSlaveServerIds(List slaveServerIds) { + this.slaveServerIds = slaveServerIds; + } +} diff --git a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java index c05d218cb..aa3ded669 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/db/redis/RedisUtil.java @@ -1587,9 +1587,11 @@ public class RedisUtil { return type + RedisKey.Delimiter_colon + key; } - Integer serverId = RedisUtil.getInstence().getObject(RedisKey.CUser_ServerId_Key, key, Integer.class, GlobalsDef.REDIS_OVER_TIME_DAY * 10); - if (serverId != null){ - return serverId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; + if (!RedisKey.newAreaCacChe.contains(type) && !RedisKey.rankCacChe.contains(type) && key.length() == 8) { + Integer serverId = RedisUtil.getInstence().getObject(RedisKey.CUser_ServerId_Key, key, Integer.class, GlobalsDef.REDIS_OVER_TIME_DAY * 10); + if (serverId != null) { + return serverId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; + } } return AreaManager.areaId + RedisKey.Delimiter_colon + type + RedisKey.Delimiter_colon + key; diff --git a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java index 87c46d4ca..04e3d60ca 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/handler/GetPlayerInfoHandler.java @@ -84,9 +84,7 @@ public class GetPlayerInfoHandler extends BaseHandler{ int token = netData.getToken(); int msgId = netData.getMsgId(); int msgIndex = netData.getIndex(); - -// AreaManager.getInstance().putCUserServer(userId, GameApplication.serverId); - + AreaManager.getInstance().putCUserServer(userId,GameApplication.serverId); PlayerInfoProto.GetPlayerInfoRequest getPlayerInfoRequest = PlayerInfoProto.GetPlayerInfoRequest.parseFrom(netData.parseClientProtoNetData()); LOGGER.info("processMessage->uid={},token={},msgId={},msgIndex={},messageNum={},messageStr={}", userId, token,msgId,msgIndex,getPlayerInfoRequest.getNum(),getPlayerInfoRequest.getStr()); diff --git a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java index f9b381829..ce09ec8e4 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/logic/player/PlayerLogic.java @@ -4,6 +4,7 @@ import com.google.gson.Gson; import com.ljsd.GameApplication; import com.ljsd.jieling.config.clazzStaticCfg.CommonStaticConfig; import com.ljsd.jieling.config.clazzStaticCfg.TaskStaticConfig; +import com.ljsd.jieling.core.CoreLogic; import com.ljsd.jieling.core.GlobalsDef; import com.ljsd.jieling.core.VipPrivilegeType; import com.ljsd.jieling.dataReport.reportBeans_37.ChatContentType; @@ -1777,16 +1778,6 @@ public class PlayerLogic { if (rpcString == null) { return null; } - // 合服 - String localRpc = RedisUtil.getInstence().getObject(RedisKey.LOGIC_SERVER_INFO, String.valueOf(GameApplication.serverId), String.class, -1); - if (localRpc != null && localRpc.equals(rpcString)) { - try { - return UserManager.getUser(uid, true); - } catch (Exception e) { - LOGGER.info("getUserByRpc Exception uid={} e={}", uid, e); - return null; - } - } String[] split = rpcString.split(":"); if (split.length < 4) { From 29a6e674ace482675b3c14cc9364787f976a54d9 Mon Sep 17 00:00:00 2001 From: duhui Date: Thu, 18 May 2023 16:15:15 +0800 Subject: [PATCH 6/6] =?UTF-8?q?=E5=90=88=E6=9C=8D=E6=B5=8B=E8=AF=953?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java b/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java index 9a4a165e2..4306652b9 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/core/CoreLogic.java @@ -45,6 +45,9 @@ public class CoreLogic { public boolean isHefu(int serverId) { CHefuInfo hefuInfo = findHefuInfo(); + if (hefuInfo == null){ + return false; + } return hefuInfo.getSlaveServerIds().contains(serverId); }