Springboot中使用Redis实现分布式锁的示例代码

<dependencies>
    <!-- Spring Data Redis -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-redis</artifactId>
    </dependency>
    <!-- Redisson客户端 -->
    <dependency>
        <groupId>org.redisson</groupId>
        <artifactId>redisson-spring-boot-starter</artifactId>
        <version>3.16.1</version> <!-- 请根据最新版本调整 -->
    </dependency>
</dependencies>

spring:
  redis:
    host: 127.0.0.1
    port: 6379
    password: your-password
    database: 0
  redisson:
    # 单节点配置
    single-server-config:
      address: redis://127.0.0.1:6379
      password: your-password
      # 其他配置项...

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class DistributedLockService {

    @Autowired
    private RedissonClient redissonClient;

    public void doSomethingInCriticalSection() {
        String lockKey = "myLock";
        RLock lock = redissonClient.getLock(lockKey);

        try {
            // 尝试获取锁，最大等待时间10秒，上锁后自动过期时间为5秒
            boolean isLocked = lock.tryLock(10, 5, TimeUnit.SECONDS);
            if (isLocked) {
                // 执行业务逻辑
                System.out.println("执行受保护的代码块...");
            } else {
                System.out.println("获取锁失败，无法执行受保护的代码块");
            }
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException("线程中断异常", e);
        } finally {
            // 释放锁
            if (lock.isHeldByCurrentThread()) {
                lock.unlock();
            }
        }
    }
}