在Spring Boot中使用Redis实现分布式锁通常涉及到RedisTemplate或StringRedisTemplate。以下是一个简单的示例，展示了在Spring Boot应用中如何在事务提交后释放Redis分布式锁：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class DistributedLockController {
@Autowired
private StringRedisTemplate redisTemplate;
private static final String LOCK_KEY = "distributed_lock";
@GetMapping("/acquireLock")
public String acquireLock() {
boolean locked = tryLock(LOCK_KEY);
if (locked) {
// 模拟业务逻辑处理
doBusinessLogic();
// 释放锁
unlock(LOCK_KEY);
return "Lock released";
} else {
return "Failed to acquire lock";
}
}
private boolean tryLock(String key) {
// 尝试获取锁，使用 SET key value NX PX milliseconds 命令
Boolean locked = redisTemplate.opsForValue().setIfAbsent(key, "lock_value", 10, TimeUnit.SECONDS);
return Boolean.TRUE.equals(locked);
}
private void unlock(String key) {
// 释放锁，删除键
redisTemplate.delete(key);
}
@Transactional
private void doBusinessLogic() {
// 事务性业务逻辑
}
}在这个例子中，tryLock 方法使用了 StringRedisTemplate 的 opsForValue().setIfAbsent() 方法尝试获取锁，该方法在Redis中对应的是 SET key value NX PX milliseconds 命令，其中 NX 表示只在键不存在时设置值，PX 表示设置键的过期时间。
unlock 方法简单地使用了 StringRedisTemplate 的 delete() 方法释放锁，即删除键。
在 acquireLock 方法中，我们首先尝试获取锁，如果成功，则执行业务逻辑，在业务逻辑执行完毕后，无论成功还是回滚，都会释放锁。这里假设了业务逻辑在一个独立的方法 doBusinessLogic() 中，并用 @Transactional 注解标记，以确保业务逻辑在事务的上下文中执行。
请注意，这个例子中锁的过期时间设置为10秒，实际使用时应该根据业务场景适当调整锁的超时时间。同时，在高并发情况下，可能需要使用更复杂的算法来确保锁的安全性和效率。