Spring Boot 中整合 Redisson 实现分布式锁

1. 添加 Redisson 依赖：在 pom.xml 文件中添加 Redisson 的依赖。

2. 配置 Redis 连接信息：在 application.properties 或 application.yml 文件中配置 Redis 的连接信息。

3. 使用 Redisson 实现分布式锁：在预减库存的地方使用 Redisson 提供的分布式锁功能，确保在并发情况下只有一个线程能够成功减库存。

下面是一个简单的示例：

首先，添加 Redisson 依赖到 pom.xml 文件中：

<dependency>
    <groupId>org.redisson</groupId>
    <artifactId>redisson-spring-boot-starter</artifactId>
    <version>{version}</version>
</dependency>

接下来，配置 Redis 连接信息。在 application.properties 文件中添加以下配置：

# Redisson 配置
spring.redis.host=your_redis_host
spring.redis.port=your_redis_port

然后，在预减库存的地方注入 org.redisson.api.RedissonClient 并使用它来创建分布式锁。例如：

java
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
@Component
public class StockService {
 
    @Autowired
    private RedissonClient redissonClient;
 
    public boolean reduceStock(String productId) {
        // 获取分布式锁
        RLock lock = redissonClient.getLock("stock_lock_" + productId);
 
        try {
            // 尝试加锁，最多等待10秒，锁定时间30秒
            boolean isLocked = lock.tryLock(10, 30, TimeUnit.SECONDS);
            
            if (isLocked) {
                // 成功获取到锁
                // 执行减库存操作
                // 注意要在执行减库存操作之前再次检查库存是否充足，避免因为网络延迟等原因导致的超卖问题
                int currentStock = getCurrentStock(productId);
                if (currentStock > 0) {
                    updateStock(productId, currentStock - 1);
                    return true; // 减库存成功
                } else {
                    return false; // 库存不足，无法减库存
                }
            } else {
                // 未能获取到锁
                return false; // 减库存失败
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            return false; // 减库存失败
        } finally {
            // 释放锁
            lock.unlock();
        }
    }
 
    // 模拟获取当前库存
    private int getCurrentStock(String productId) {
        // 实际情况中应该从数据库或缓存中获取库存信息
        // 这里简单地返回一个固定的库存量
        return 100;
    }
 
    // 模拟更新库存
    private void updateStock(String productId, int newStock) {
        // 实际情况中应该更新数据库或缓存中的库存信息
        // 这里只是简单地打印日志
        System.out.println("更新库存，产品ID：" + productId + "，新库存：" + newStock);
    }
}

在这个示例中，我们使用 Redisson 创建了一个名为 "stock_lock_" + productId 的分布式锁来保护减库存操作。在减库存的过程中，我们首先获取分布式锁，然后再次检查当前库存是否充足，避免因为网络延迟等原因导致的超卖问题。如果库存充足，则执行减库存操作，并释放锁。如果未能获取到锁，则说明有其他线程正在执行减库存操作，此时返回减库存失败。

这样就实现了在 Spring Boot 中使用 Redisson 实现分布式锁进行预减库存的功能。确保在项目中正确配置 Redisson 和 Redis 连接信息，并在关键代码块中使用分布式锁来保护共享资源。