redis分布式锁修改
parent
bf1194f37e
commit
facba9b042
|
|
@ -75,7 +75,7 @@ public class CarDelayFunction implements FunctionManager {
|
||||||
boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_SECOND * 60);
|
boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_SECOND * 60);
|
||||||
if (!lock) {
|
if (!lock) {
|
||||||
//没有拿到锁直接返回
|
//没有拿到锁直接返回
|
||||||
LOGGER.error("跨服车迟斗法,发奖, key:{} 跨服分组 ={},未获取到锁",lockKey, crossGroup);
|
LOGGER.error("跨服车迟斗法,发奖, key:{} 跨服分组 ={},锁状态:{},未获取到锁",lockKey, crossGroup, lock);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
personRangeWithScores = RedisUtil.getInstence().getZsetreverseRangeWithScores(personRank.getCrossRedisKey(), "", 0, -1, false);
|
personRangeWithScores = RedisUtil.getInstence().getZsetreverseRangeWithScores(personRank.getCrossRedisKey(), "", 0, -1, false);
|
||||||
|
|
@ -117,6 +117,6 @@ public class CarDelayFunction implements FunctionManager {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
MongoUtil.getLjsdMongoTemplate().lastUpdate();
|
MongoUtil.getLjsdMongoTemplate().lastUpdate();
|
||||||
RedisUtil.getInstence().del(lockKey);
|
// RedisUtil.getInstence().del(lockKey);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -175,9 +175,6 @@ public class CrossLingmaiLogic {
|
||||||
redisUtil.del(key2);
|
redisUtil.del(key2);
|
||||||
LOGGER.info("灵脉初始化,key:{}, 长度:{}",key2,mapValue2.size());
|
LOGGER.info("灵脉初始化,key:{}, 长度:{}",key2,mapValue2.size());
|
||||||
mapValue2.clear();
|
mapValue2.clear();
|
||||||
|
|
||||||
//释放分布式锁
|
|
||||||
redisUtil.del(lockKey);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// public static LingMaiSecretArea getLingaMaiData(int id, int uid,int crossGroup,int group) {
|
// public static LingMaiSecretArea getLingaMaiData(int id, int uid,int crossGroup,int group) {
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue