Redis常见坑及解决方案

2023-10-11 09:37:36 浏览数 (2)

非原子操作(setNx expire)

代码语言:javascript复制
//加锁
if(jedis.setnx(lock_key,lock_value) == 1){ 
  //设置过期时间
    jedis.expire(lock_key,timeout);
  //业务逻辑处理
    doBusiness 
}

以上使用Redis的setNx()命令和expire命令实现了加锁,但是本方案是分成了两步完成的加锁操作,并不是原子操作,可能会出现未给该key设置过期时间的问题,因此该问题的解决方案推荐使用Redisson的分布式锁。

解决方案-Redission
  • Redisson 提供的分布式锁功能是原子操作的。Redisson 内部使用了 Redis 的 Lua 脚本来执行获取锁和释放锁的操作,确保这些操作的原子性。
  • 自动续期:Redisson 实现了分布式锁的自动续期功能。在获取锁时,Redisson 会设置一个过期时间,并周期性地对锁进行续期。这样可以确保在锁的持有者在任务执行期间出现阻塞或延迟时,锁不会过期而被其他进程获取,从而保证任务的完整性和准确性。
  • 可重入性支持:Redisson 支持分布式锁的可重入性。即同一个线程可以多次获取同一个锁,而不会产生死锁。Redisson 使用锁的持有者标识和计数来判断锁的重入次数,从而确保同一个线程能够正确地释放锁。
  • 高可用支持:Redission可以与Redis的主从复制或集群模式配合使用,当主节点发生故障时,Redission可以自动切换到可用的从节点或其他节点上,确保分布式锁的可用性和稳定性。

Redisson pom坐标:

代码语言:javascript复制
<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>3.16.1</version>
</dependency>

代码实现:

代码语言:javascript复制
@Service
public class PurchaseService {
    private final RedissonClient redissonClient;

    public PurchaseService(RedissonClient redissonClient) {
        this.redissonClient = redissonClient;
    }

    private int a = 9;

    @Transactional(rollbackFor = Exception.class)
    public boolean purchase(String productId, int quantity) {
        String lockKey = "lock:"   productId;
        RLock lock = redissonClient.getLock(lockKey);
        try {
            lock.lock(); // 加锁

            // 检查库存是否充足
            int stock = getStockFromDatabase(productId);
            if (stock >= quantity) {
                // 执行下单操作
                // ...

                // 扣减库存
                decreaseStockInDatabase(productId, quantity);

                if (true){
                    throw new RuntimeException("1");
                }
                return true; // 抢购成功
            } else {
                return false; // 库存不足,抢购失败
            }

        } catch (Exception e) {
            throw new RuntimeException(e); // 抛出异常,触发事务回滚
        } finally {
            lock.unlock(); // 释放锁
            int stockFromDatabase = getStockFromDatabase("1");
            System.out.println("下单后"   stockFromDatabase);
        }
    }

    private int getStockFromDatabase(String productId) {
        // 从数据库获取库存信息
        // ...
        return a;
    }

    private void decreaseStockInDatabase(String productId, int quantity) {
        // 更新数据库中的库存信息
        // ...
        a = a - quantity;
        System.out.println("更新数据库,下单减库存后"   a);
    }

}
B的锁被A给释放了
代码语言:javascript复制
try{
  if(jedis.set(lockKey, requestId, "NX", "PX",expireTime)==1){//加锁
     doBusiness //业务逻辑处理
     return true; //加锁成功,处理完业务逻辑返回
  }
  return false; //加锁失败
} finally {
    unlock(lockKey); //释放锁
} 

业务场景:

并发情况下,A、B两个线程尝试在Redis设置key为lockKey的锁,key三秒后过期,A线程先拿到锁,若A的网络较慢或执行逻辑较为耗时,超过了三秒未执行完成,那么在Redis中,lockKey由于到达过期时间而过期,那么B此时尝试加锁,由于A过期,那么B此时刚好可以拿到锁,而后,A此时正好执行完业务逻辑去释放锁,此时B的业务逻辑还在执行,但是B加的锁被B释放了。

解决方案
代码语言:javascript复制
try{
  if(jedis.set(lockKey, requestId, "NX", "PX",expireTime)==1){//加锁
     doBusiness //业务逻辑处理
     return true; //加锁成功,处理完业务逻辑返回
  }
  return false; //加锁失败
} finally {
    if (requestId.equals(jedis.get(lockKey))) { //判断一下是不是自己的requestId
      unlock(lockKey);//释放锁
    }   
}  

在设置锁时,设置value值为当前线程客户端的唯一标识。

释放锁时,不是原子性
代码语言:javascript复制
if(requestId.equals(jedis.get(lockKey))) { //判断一下是不是自己的requestId
   unlock(lockKey);//释放锁
  }  

jedis.get(lockKey)unlock(lockKey)是两个操作,在get操作时,该锁可能被其他线程释放掉,或者是该锁被其他客户端获取到,在执行至unlock()时,释放掉其他客户端设置的锁。

解决方案

Redis Lua脚本以保证释放锁需要原子性

代码语言:javascript复制
if redis.call('get',KEYS[1]) == ARGV[1] then 
   return redis.call('del',KEYS[1]) 
else
   return 0
end;  

0 人点赞