redis 缓存服务器地址

back_recharge
zhangshanxue 2019-09-17 14:58:30 +08:00
parent 4ef73f2406
commit 6b96021e08
3 changed files with 16 additions and 7 deletions

View File

@ -173,7 +173,7 @@ public class GameApplication {
public static void register(ConfigurableApplicationContext configurableApplicationContext){
CoreSettings coreSettings = configurableApplicationContext.getBean(CoreSettings.class);
String ip = coreSettings.getIp();
int port = coreSettings.getPort();
int port = coreSettings.getGmport();
String rpcUrl = ip + ":" + port;
RedisUtil.getInstence().set(RedisKey.LOGIC_SERVER_INFO+RedisKey.Delimiter_colon+GameApplication.serverId,gson.toJson(rpcUrl));
}

View File

@ -12,6 +12,7 @@ public class CoreSettings {
private String ip;
private int port;
private int gmport;
private int area;
private int id;
private int weight;
@ -55,4 +56,12 @@ public class CoreSettings {
public void setPort(int port) {
this.port = port;
}
public int getGmport() {
return gmport;
}
public void setGmport(int gmport) {
this.gmport = gmport;
}
}

View File

@ -44,7 +44,7 @@ public class ExchangeCdkHandler extends BaseHandler<PlayerInfoProto.ExchangeCdkR
User user = UserManager.getUser(session.getUid());
Map<Integer, SCdkInfo> sCdkInfosCacheMap = CoreLogic.getInstance().getsCdkInfosCacheMap();
if (cdk.length() != 18 || sCdkInfosCacheMap == null || sCdkInfosCacheMap.isEmpty()) {
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "cdk.wrong");
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "兑换码无效");
return;
}
boolean distributedLock = RedisUtil.getInstence().tryGetDistributedLock(RedisKey.CDKEY,cdk , Integer.toString(uid),500);
@ -58,33 +58,33 @@ public class ExchangeCdkHandler extends BaseHandler<PlayerInfoProto.ExchangeCdkR
try {
cdkInfo = MongoUtil.getCoreMongoTemplate().findById(cdk, CdkInfo.class);
if (cdkInfo == null) {
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "cdk.wrong");
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "兑换码无效");
return;
}
goodsId = cdkInfo.getGoodsId();
//礼包信息
SCdkInfo scdkInfo = sCdkInfosCacheMap.get(goodsId);
if (scdkInfo == null) {
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "cdk.wrong");
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "兑换码无效");
return;
}
//pid
if(user.getPlayerInfoManager().getPid()!=scdkInfo.getPid())
{
MessageUtil.sendErrorResponse(session,0, MessageTypeProto.MessageType.EXCHANGE_CDK_REQUEST_VALUE,"cdk wrong");
MessageUtil.sendErrorResponse(session,0, MessageTypeProto.MessageType.EXCHANGE_CDK_REQUEST_VALUE,"兑换码无效");
return;
}
int usetype = scdkInfo.getUsetype();
if (usetype == 0) {//只能兑换一次
if (cdkInfo.getStatus() == 1) {
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "cdk.used");
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "兑换码已使用");
return;
}
} else {
boolean exists = MongoUtil.getCoreMongoTemplate().exists(new BasicQuery(new BasicDBObject("uid", uid).append("cdk_num", cdk)), CdkUseInfo.class);
if(exists){
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "cdk.role used");
MessageUtil.sendErrorResponse(session, 0, MessageTypeProto.MessageType.EXCHANGE_CDK_RESPONSE_VALUE, "该角色已兑换");
return;
}
}