跨服获取玩家rpc信息错误返回
parent
b3df483ef8
commit
845d32326c
|
@ -967,6 +967,11 @@ public class PlayerLogic {
|
||||||
}
|
}
|
||||||
public CrossArenaManager getCrossArenaManagerData(CSPlayer csPlayer){
|
public CrossArenaManager getCrossArenaManagerData(CSPlayer csPlayer){
|
||||||
String rpcString = RedisUtil.getInstence().getObject(RedisKey.LOGIC_SERVER_INFO, String.valueOf(csPlayer.getServerId()), String.class, -1);
|
String rpcString = RedisUtil.getInstence().getObject(RedisKey.LOGIC_SERVER_INFO, String.valueOf(csPlayer.getServerId()), String.class, -1);
|
||||||
|
String[] split = rpcString.split(":");
|
||||||
|
if (split.length < 4){
|
||||||
|
LOGGER.error("获取玩家rpc地址,长度错误,rpc:{},玩家id:{},服务器id:{}",rpcString,csPlayer.getUserId(),csPlayer.getServerId());
|
||||||
|
return null;
|
||||||
|
}
|
||||||
String ip = rpcString.split(":")[0];
|
String ip = rpcString.split(":")[0];
|
||||||
String port = rpcString.split(":")[3];
|
String port = rpcString.split(":")[3];
|
||||||
//rpc 数据调用
|
//rpc 数据调用
|
||||||
|
@ -983,7 +988,7 @@ public class PlayerLogic {
|
||||||
rPCClient = ClientAdapterPo.getClientAdapterPo(sb.toString());
|
rPCClient = ClientAdapterPo.getClientAdapterPo(sb.toString());
|
||||||
crossArenaManager = rPCClient.getClient().getHeroManagerInfo(uid);
|
crossArenaManager = rPCClient.getClient().getHeroManagerInfo(uid);
|
||||||
}catch (Exception e) {
|
}catch (Exception e) {
|
||||||
LOGGER.info("callback=>", e);
|
LOGGER.error("callback=>", e);
|
||||||
} finally {
|
} finally {
|
||||||
if(rPCClient != null){
|
if(rPCClient != null){
|
||||||
rPCClient.returnObject(sb.toString());
|
rPCClient.returnObject(sb.toString());
|
||||||
|
|
Loading…
Reference in New Issue