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;  
  
    // 假設(shè)的鎖過期時(shí)間  
    private static final long LOCK_EXPIRATION_TIME = 10L; // 10秒  
  
    // 嘗試獲取鎖  
    private boolean tryLock(String key) {  
        ValueOperations<String, String> opsForValue = redisTemplate.opsForValue();  
        // 嘗試設(shè)置鎖，如果鍵不存在則設(shè)置成功，并設(shè)置過期時(shí)間  
        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();  
  
        // 嘗試獲取鎖  ，獲取鎖成功才會(huì)繼續(xù)執(zhí)行下面業(yè)務(wù)上的校驗(yàn)
        if (tryLock(nameAgeLockKey)) {  
            try {  
                // 在這里執(zhí)行數(shù)據(jù)庫檢查（是否已存在同name和age）  
                
                // 如果不存在，則執(zhí)行插入操作  
  
                // 假設(shè)檢查通過，執(zhí)行插入操作（這里省略了具體的數(shù)據(jù)庫操作）  
                System.out.println("User added successfully");  
  
            } finally {  
                // 釋放鎖  
                releaseLock(nameAgeLockKey);  
            }  
        } else {  
            // 未能獲取鎖，可能是其他進(jìn)程正在處理相同的組合  
            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;  
  
    // 假設(shè)的鎖過期時(shí)間  
    private static final long LOCK_EXPIRATION_TIME = 10L; // 10秒  
  
    // 嘗試獲取鎖  
    private boolean tryLock(String key) {  
        ValueOperations<String, String> opsForValue = redisTemplate.opsForValue();  
        // 嘗試設(shè)置鎖，如果鍵不存在則設(shè)置成功，并設(shè)置過期時(shí)間  
        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();  
  
        // 嘗試獲取兩個(gè)鎖  
        if (tryLock(nameAgeLockKey) && tryLock(ageSexLockKey)) {  
            try {  
                // 在這里執(zhí)行數(shù)據(jù)庫檢查（是否已存在同name和age或同age和sex的User）  
                // 如果不存在，則執(zhí)行插入操作  
  
                // 假設(shè)檢查通過，執(zhí)行插入操作（這里省略了具體的數(shù)據(jù)庫操作）  
                System.out.println("User added successfully");  
  
            } finally {  
                // 釋放鎖  釋放兩次
                releaseLock(nameAgeLockKey);  
                releaseLock(ageSexLockKey);  
            }  
        } else {  
            // 未能獲取鎖，可能是其他進(jìn)程正在處理相同的組合  
            System.out.println("Failed to acquire lock(s), user addition may be in progress");  
        }  
    }  
  
    // ... 其他代碼 ...  
}