使用Redis实现分布式锁解决商品超卖问题（接上篇文章）

news2024/11/15 23:46:23

1. RedLock（红锁）简介

在这里插入图片描述

RedLock是一种用于分布式系统的锁定算法，旨在提供分布式锁的高可用性和分布式容错性。它是由Redis的创建者Salvatore Sanfilippo提出的，用于克服Redis单实例的单点故障问题。RedLock的目标是确保在多个Redis实例上获取锁时，锁定操作在大多数实例上都成功。

RedLock的基本思想是，获取分布式锁需要在多个Redis实例上获取锁，至少需要在N/2 + 1个Redis实例上成功获取锁，其中N表示Redis实例的总数。这样做是为了保证锁在大多数实例上是可用的。

RedLock的步骤如下：

获取当前时间戳。
在每个Redis实例上尝试获取锁，使用相同的锁名称、唯一标识符和超时时间。
统计成功获取锁的实例数量。
如果成功获取锁的实例数量大于等于N/2 + 1，则认为锁获取成功。
否则，在成功获取锁的实例上释放锁，确保锁不会被占用。

RedLock的优点是它提供了高可用性，即使其中一个Redis实例出现问题，其他实例仍可以提供服务。然而，需要注意的是，RedLock仍然依赖于Redis，如果所有Redis实例都无法正常工作，那么RedLock也无法正常运行。

总之，RedLock是一种用于提供分布式锁的算法，它充分考虑了高可用性和分布式容错性，适用于需要可靠锁定机制的分布式系统。

2. Redisson简介

Redisson是一个开源的Java框架，它为Redis提供了一组分布式Java对象和服务，使得在Java应用程序中使用Redis变得更加容易。Redisson的目标是简化分布式系统的开发，提供易于使用的API和丰富的功能集合，以满足不同分布式应用的需求。

Redisson提供了一些常见的分布式数据结构和服务，如分布式锁、分布式集合、分布式Map、分布式队列、分布式消息发布/订阅等，这些功能可以方便地在分布式应用中使用。Redisson还提供了一种流畅的API，使开发人员可以更容易地与Redis进行交互，同时还提供了许多性能优化和线程安全的功能。

使用Redisson，开发人员可以更容易地构建分布式系统，从而充分利用Redis的强大功能，提高应用程序的性能和可伸缩性。这个框架已经被广泛用于构建各种分布式应用，如缓存、任务队列、分布式锁和会话管理等。

3. 解决方案

3.1 版本12

使用基于红锁的Redission客户端实现分布式加锁多台Redis实例：

添加Redisson依赖：首先，确保你的项目中引入了Redisson依赖。
初始化Redisson：创建Redisson的客户端并配置多个Redis实例的信息。

Config config = new Config();
config.useClusterServers()
      .addNodeAddress("redis://server1:6379")
      .addNodeAddress("redis://server2:6379")
      .addNodeAddress("redis://server3:6379")
      .addNodeAddress("redis://server4:6379")
      .addNodeAddress("redis://server5:6379");

RedissonClient redisson = Redisson.create(config);

获取锁并执行业务逻辑：

RLock lock = redisson.getLock("order_lock");

try {
    boolean isLocked = lock.tryLock(1, 10, TimeUnit.SECONDS); // 尝试获取锁，等待1秒，锁定10秒
    if (isLocked) {
        String retMessage = "";
        try{
            // 1.查询库存
            String resultFromRedis = stringRedisTemplate.opsForValue().get(key);
            // 判断库存是否足够
            Integer num=resultFromRedis == null?0:Integer.parseInt(resultFromRedis);
            if(num-count > 0){
                stringRedisTemplate.opsForValue().set(key,String.valueOf(--num));
                retMessage = "成功卖出"+count+"件商品"+"服务端口号："+serverPort;
                System.out.println(retMessage+"当前商品剩余："+(num+1-count)+"件。");
                // 模拟长业务
                try {TimeUnit.SECONDS.sleep(200);} catch (InterruptedException e) {e.printStackTrace();}

            }else{
                retMessage="商品已售罄！非常抱歉！";
                System.err.println(retMessage);
            }
        }
    } else {
        // 获取锁失败，可以处理一些逻辑，如返回错误信息
    }
} finally {
    lock.unlock();
}