import java.util.Collections;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Component;
@Component
public class RedisDistributedLock {
@Autowired
private StringRedisTemplate stringRedisTemplate;
/**
* <p>Title lock</p>
* <p>Description </p>
* @param requestId
* @param key
* @param expiresTime 过期时间,毫秒
* @return
*/
public boolean lock(String key, String requestId, int expiresTime) {
String lockScriptStr = "if redis.call('setnx',KEYS[1],ARGV[1]) == 1 then return redis.call('pexpire',KEYS[1],ARGV[2]) else return 0 end";
DefaultRedisScript<Long> longDefaultRedisScript = new DefaultRedisScript<>(lockScriptStr, Long.class);
Long result = stringRedisTemplate.execute(longDefaultRedisScript, Collections.singletonList(key), requestId,String.valueOf(expiresTime));
return result == 1;
}
/**
* <p>Title releaseLock</p>
* <p>Description </p>
* @param key
* @param requestId
* @return
*/
public boolean unlock(String key, String requestId) {
String unLockScriptStr = "if redis.call('get',KEYS[1]) == ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end";
DefaultRedisScript<Long> longDefaultRedisScript = new DefaultRedisScript<>(unLockScriptStr, Long.class);
Long result = stringRedisTemplate.execute(longDefaultRedisScript, Collections.singletonList(key), requestId);
return result == 1;
}
}
spring boot集成redis实现分布式锁
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。
推荐阅读更多精彩内容
- 前言 目前几乎很多大型网站及应用都是分布式部署的,分布式场景中的数据一致性问题一直是一个比较重要的话题。在很多场景...
- 昔日繁华的背后, 落幕, 告别了一段属于它曾经的辉煌。 拾起那片斑驳的瓦片, 还有散落一地的鹅卵石, 悄悄对着阳光...