JAVA实现redis分布式双重加锁的示例代码

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.data.redis.core.RedisTemplate;  
import org.springframework.data.redis.core.ValueOperations;  
import org.springframework.stereotype.Service;  
  
import java.util.concurrent.TimeUnit;  
  
@Service  
public class UserService {  
  
    @Autowired  
    private RedisTemplate<String, String> redisTemplate;  
  
    // 假设的锁过期时间  
    private static final long LOCK_EXPIRATION_TIME = 10L; // 10秒  
  
    // 尝试获取锁  
    private boolean tryLock(String key) {  
        ValueOperations<String, String> opsForValue = redisTemplate.opsForValue();  
        // 尝试设置锁，如果键不存在则设置成功，并设置过期时间  
        return opsForValue.setIfAbsent(key, "locked", LOCK_EXPIRATION_TIME, TimeUnit.SECONDS);  
    }  
  
    // 释放锁  
    private void releaseLock(String key) {  
        redisTemplate.delete(key);  
    }  
  
    // 新增User的逻辑  
    public void addUserIfNotExists(User user) {  
        String nameAgeLockKey = "user:lock:name:" + user.getName() + ":age:" + user.getAge();  
  
        // 尝试获取锁  ，获取锁成功才会继续执行下面业务上的校验
        if (tryLock(nameAgeLockKey)) {  
            try {  
                // 在这里执行数据库检查（是否已存在同name和age）  
                
                // 如果不存在，则执行插入操作  
  
                // 假设检查通过，执行插入操作（这里省略了具体的数据库操作）  
                System.out.println("User added successfully");  
  
            } finally {  
                // 释放锁  
                releaseLock(nameAgeLockKey);  
            }  
        } else {  
            // 未能获取锁，可能是其他进程正在处理相同的组合  
            System.out.println("Failed to acquire lock(s), user addition may be in progress");  
        }  
    }  
  
    // ... 其他代码 ...  
}

import org.springframework.beans.factory.annotation.Autowired;  
import org.springframework.data.redis.core.RedisTemplate;  
import org.springframework.data.redis.core.ValueOperations;  
import org.springframework.stereotype.Service;  
  
import java.util.concurrent.TimeUnit;  
  
@Service  
public class UserService {  
  
    @Autowired  
    private RedisTemplate<String, String> redisTemplate;  
  
    // 假设的锁过期时间  
    private static final long LOCK_EXPIRATION_TIME = 10L; // 10秒  
  
    // 尝试获取锁  
    private boolean tryLock(String key) {  
        ValueOperations<String, String> opsForValue = redisTemplate.opsForValue();  
        // 尝试设置锁，如果键不存在则设置成功，并设置过期时间  
        return opsForValue.setIfAbsent(key, "locked", LOCK_EXPIRATION_TIME, TimeUnit.SECONDS);  
    }  
  
    // 释放锁  
    private void releaseLock(String key) {  
        redisTemplate.delete(key);  
    }  
  
    // 新增User的逻辑  
    public void addUserIfNotExists(User user) {  
    	//加两次锁
        String nameAgeLockKey = "user:lock:name:" + user.getName() + ":age:" + user.getAge();  
        String ageSexLockKey = "user:lock:age:" + user.getAge() + ":sex:" + user.getSex();  
  
        // 尝试获取两个锁  
        if (tryLock(nameAgeLockKey) && tryLock(ageSexLockKey)) {  
            try {  
                // 在这里执行数据库检查（是否已存在同name和age或同age和sex的User）  
                // 如果不存在，则执行插入操作  
  
                // 假设检查通过，执行插入操作（这里省略了具体的数据库操作）  
                System.out.println("User added successfully");  
  
            } finally {  
                // 释放锁  释放两次
                releaseLock(nameAgeLockKey);  
                releaseLock(ageSexLockKey);  
            }  
        } else {  
            // 未能获取锁，可能是其他进程正在处理相同的组合  
            System.out.println("Failed to acquire lock(s), user addition may be in progress");  
        }  
    }  
  
    // ... 其他代码 ...  
}