Redis分布式锁核心代码
redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set –有序集合)和hash（哈希类型）。这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。在此基础上，redis支持各种不同方式的排序。与memcached一样，为了保证效率，数据都是缓存在内存中。区别的是redis会周期性的把更新的数据写入磁盘或者把修改操作写入追加的记录文件，并且在此基础上实现了master-slave(主从)同步
/**
* Created on 2017/11/11 0011.
*
* @author zlf
* @email i@merryyou.cn
* @since 1.0
*/
@Component
@Slf4j
public class RedisLock {
@Autowired
private StringRedisTemplate redisTemplate;
/**
* 加锁
*
* @param key
* @param value 当前时间+ 超时时间
* @return
*/
public boolean lock(String key, String value) {
if (redisTemplate.opsForValue().setIfAbsent(key, value)) {
return true;
}
String currentValue = redisTemplate.opsForValue().get(key);
//如果锁过期
if (!StringUtils.isEmpty(currentValue) && Long.parseLong(currentValue) < System.currentTimeMillis()) {
//获得上一个锁的时间
String olcValue = redisTemplate.opsForValue().getAndSet(key, value);
if (!StringUtils.isEmpty(olcValue) && olcValue.equals(currentValue)) {
return true;
}
}
return false;
}
/**
* 解锁
*
* @param key
* @param value
*/
public void unlock(String key, String value) {
try {
String currentVlue = redisTemplate.opsForValue().get(key);
if (!StringUtils.isEmpty(currentVlue) && currentVlue.equals(value)) {
redisTemplate.opsForValue().getOperations().delete(key);
;
}
} catch (Exception e) {
log.error("【redis分布式锁】 解锁异常" + e.getMessage());
}
}
}本文参与?腾讯云自媒体分享计划，分享自作者个人站点/博客。
原始发表：2017/11/13，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
相关产品与服务
云数据库 Redis
腾讯云数据库 Redis（TencentDB for Redis）是腾讯云打造的兼容 Redis 协议的缓存和存储服务。丰富的数据结构能帮助您完成不同类型的业务场景开发。支持主从热备，提供自动容灾切换、数据备份、故障迁移、实例监控、在线扩容、数据回档等全套的数据库服务。