修改redis锁

back_recharge
duhui 2023-04-06 14:14:57 +08:00
parent e5753431c4
commit eaeb457065
1 changed files with 5 additions and 4 deletions

View File

@ -774,7 +774,7 @@ public class ArenaLogic {
if (crossGroup == -1) {
return;
}
String lockKey = "WORLD_ARENA_SEND_REWARD_RANK:" + crossGroup;
String lockKey = "WORLD_ARENA_SEND_REWARD_LOCK:" + crossGroup;
boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_MINUTE * 5);
if (!lock) {
LOGGER.error("罗浮争锋,发奖退出,未获取到锁:{}",lockKey);
@ -902,14 +902,15 @@ public class ArenaLogic {
return;
}
//分布式锁,保证一个组只有一个服进行初始化
boolean lock = RedisUtil.getInstence().lock("WORLD_ARENA_INIT_RANK:" + crossGroup, TimeUtils.ONE_MINUTE * 5);
String lockKey = "WORLD_ARENA_INIT_LOCK:" + crossGroup;
boolean lock = RedisUtil.getInstence().lock(lockKey, TimeUtils.ONE_MINUTE * 5);
if (!lock) {
LOGGER.error("罗浮争锋,初始化排行榜退出,未获取到锁");
return;
}
LOGGER.info("罗浮争锋,初始化排行榜开始...");
RedisUtil.getInstence().expire2("WORLD_ARENA_INIT_RANK:" + crossGroup, TimeUtils.ONE_MINUTE * 5);
RedisUtil.getInstence().expire2(lockKey, TimeUtils.ONE_MINUTE * 5);
LOGGER.info("罗浮争锋,初始化排行榜开始...");
String key1 = RedisUtil.getInstence().getKey(RedisKey.CROSS_ARENA_ROBOT_INFO, String.valueOf(crossGroup));
String key2 = RedisUtil.getInstence().getKey(RedisKey.CROSS_SERVICE_ARENA, String.valueOf(crossGroup));
RedisUtil.getInstence().del(key1, key2);