Redis实现分布式锁
2023-06-13 09:11:31 时间
Redis被经常用来实现分布式锁,本文主要讲述redis如何实现一个分布式锁的demo。
获取锁
redis分布式锁的实现主要是通过redis的set命令实现:
SET key value nx PX milliseconds
nx
: 当key存在的时候才将set对应的key,value写入到redis数据库里面。如果设置成功之后,就返回OK
,已经存在就返回nil
,当前set命令也是一个原子操作,可以作为分布式锁。px milliseconds
: 为当前key设置过期时间,当时间过了之后会将当前key删除。主要是方式获取锁之后未正常释放,导致死锁,一直无法获取锁。超时时间需要合理设置,需要保证当前业务能够处理完。
private static final String LOCK_SUCCESS = "OK";
private static final Long UNLOCK_SUCCESS = 1L;
//
private static final String UNLOCK_SCRIPT = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
private final JedisCluster cluster;
private final long lockTimeout;
private final String lockKey;
public RedisDistributedLockImpl(JedisCluster cluster, String lockKey, long lockTimeout) {
this.cluster = cluster;
this.lockTimeout = lockTimeout;
this.lockKey = lockKey;
}
@Override
public String lock() {
long end = System.currentTimeMillis() + lockTimeout;
String requireToken = String.valueOf(System.currentTimeMillis());
int expireTime = 300 * 1000;
SetParams params = new SetParams().nx().px(expireTime);
while (System.currentTimeMillis() < end) {
try {
String result = cluster.set(lockKey, requireToken, params);
if (LOCK_SUCCESS.equals(result)) {
System.out.println("lock success");
return requireToken;
}
System.out.println("lock failed trying");
Thread.sleep(100);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
return requireToken;
}
释放锁
释放锁,主要是需要通过原子操作将锁对应的key删除,可以通过下面lua脚本删除。
if redis.call('get', KEYS[1]) == ARGV[1] then
return redis.call('del', KEYS[1])
else
return 0
end
释放锁的详细代码:
@Override
public boolean unlock(String identify) {
if (identify == null || identify.trim().length() == 0) {
return false;
}
Object obj = new Object();
try {
obj = cluster.eval(UNLOCK_SCRIPT, Collections.singletonList(lockKey), Collections.singletonList(identify));
if (UNLOCK_SUCCESS.equals(obj)) {
System.out.println("release lock success, requestToken:" + identify);
return true;
}
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("release lock failed, requestToken:" + identify + ", result:" + obj);
return false;
}
测试分布式锁
使用下面代码模拟秒杀场景:
public class RedisDistributedLockTest {
static int n = 500;
public static void secKill() {
System.out.println("商品数量:" + --n);
}
public static void main(String[] args) {
Runnable runnable = () -> {
RedisDistributedLockImpl lock = null;
String unLockIdentify = null;
try {
Set<HostAndPort> set = new HashSet<>();
set.add(new HostAndPort("127.0.0.1", 30001));
JedisPoolConfig config = new JedisPoolConfig();
JedisCluster cluster = new JedisCluster(set, config);
lock = new RedisDistributedLockImpl(cluster, "test1", 20000);
unLockIdentify = lock.lock();
System.out.println(Thread.currentThread().getName() + "正在运行");
secKill();
} finally {
if (lock != null) {
lock.unlock(unLockIdentify);
}
}
};
System.out.println("------------------开始--------------");
for (int i = 0; i < 100; i++) {
Thread t = new Thread(runnable);
t.start();
}
}
}
执行结果如下:
相关文章
- Redis实现数据冗余的策略(redis冗余)
- 优点:利用 Redis 提高效率(redis优点)
- Redis的魔力:超速的分布式存储神器(redis为什么那么快)
- 体验分布式及稳定性——Redis实现负载均衡(redis实现负载均衡)
- 实现高可用的 Redis 分布式系统(redis分布式实现原理)
- 解锁微服务Redis守护(微服务redis锁)
- 异步实现快速批量写入Redis(异步批量写入redis)
- 研究Redis中缓存一致性协议实现机制(缓存一致性协议redis)
- 线上Redis升级提升访问性能(线上redis升级)
- 谨防电脑重启后Redis信息丢失(电脑重启 redis丢失)
- 电商多点利用Redis优化体验(电商分布式redis)
- 有赞之恩Redis 的数据存储催化剂(有赞redis)
- 管理Redis实现数据持久化及权限管理(数据持久化redis权限)
- 分布式Redis数据库性能测试YCSB方案(ycsb redis)
- 编码必备Redis字符串介绍(string redis)
- 基于Redis的分布式锁实现方案(分布式锁redis的实现)
- 技术分布式部署的Redis缓存提升系统效率(分布式部署redis缓存)
- Redis实现轻量级的分布式计数器(分布式计数器 redis)
- 分布式环境下更高效地更新Redis缓存(分布式更新redis)
- 设计可靠的分布式ID策略基于Redis的实现(分布式id策略redis)
- Redis守护进程让服务器安全运行(什么是redis守护进程)
- 复盘Redis分布式锁实现良好的分布式协作(复盘redis分布式锁)
- 利用Redis主备架构构建高可用的分布式缓存(基于redis主备)
- Redis高可用实践实现健壮的分布式缓存(redis高可用实战)
- 测试Redis集群探索可靠性和性能(redis集群的测试)
- 生成分布式唯一ID生成方案基于Redis集群的全局ID生成(redis 集群全局id)
- Redis实现强一致性的隔离级别研究(redis 隔离级别)
- Redis锁防止雪崩的强大守护者(redis锁雪崩)
- Redis是否适合用作分布式锁(redis适合分布式锁吗)
- Redis外网配置快速指南(redis配置外网地址)
- Redis实现分布式锁,解决多线程安全问题(redis能做分布式锁)