springboot整合redis分布式锁

在Spring Boot中，可以通过使用Redis实现分布式锁。以下是一种可能的实现方式：

1. 首先，在项目的`pom.xml`文件中添加对spring-boot-starter-data-redis的依赖。

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

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

spring.redis.host=127.0.0.1
spring.redis.port=6379

3. 创建一个`RedisLock`类，用于获取和释放分布式锁。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

import java.util.concurrent.TimeUnit;

@Component
public class RedisLock {
    
    @Autowired
    private RedisTemplate<String, String> redisTemplate;
    
    public boolean acquireLock(String key, String value, long timeout) {
        return redisTemplate.opsForValue().setIfAbsent(key, value, timeout, TimeUnit.MILLISECONDS);
    }
    
    public void releaseLock(String key, String value) {
        String currentValue = redisTemplate.opsForValue().get(key);
        if (currentValue != null && currentValue.equals(value)) {
            redisTemplate.delete(key);
        }
    }
}

4. 在需要使用分布式锁的地方，注入`RedisLock`并使用它进行加锁和解锁操作。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class YourService {
    
    @Autowired
    private RedisLock redisLock;
    
    public void doSomething() {
        String lockKey = "your-lock-key";
        String requestId = UUID.randomUUID().toString();
        try {
            boolean locked = redisLock.acquireLock(lockKey, requestId, 5000);
            if (locked) {
                // 获取到锁，执行业务逻辑
                // ...
            } else {
                // 未获取到锁，处理失败逻辑
                // ...
            }
        } finally {
            redisLock.releaseLock(lockKey, requestId);
        }
    }
}

上述代码中，`acquireLock`方法用于尝试获取分布式锁，它使用Redis的`setIfAbsent`方法来设置一个键值对，如果键不存在则设置成功，返回`true`表示获取到了锁。`releaseLock`方法用于释放锁，它首先比较当前锁的值是否与传入的值相等，如果相等则删除该键。