共计 2683 个字符，预计需要花费 7 分钟才能阅读完成。
本篇内容主要讲解“redis 中的分布式锁有哪些特点”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让丸趣 TV 小编来带大家学习“redis 中的分布式锁有哪些特点”吧!
分布式锁的特点
1. 独占性
不论在任何情况下都只能有一个线程持有锁。
2. 高可用
redis 集群环境不能因为某一个节点宕机而出现获取锁或释放锁失败。
3. 防死锁
必须有超时控制机制或者撤销操作。
4. 不乱抢
自己加锁，自己释放。不能释放别人加的锁。
5. 重入性
同一线程可以多次加锁。
redis 单机怎么实现
一般情况下都是使用 setnx+lua 脚本实现。
直接贴代码
package com.fandf.test.redis;
import cn.hutool.core.util.IdUtil;
import cn.hutool.core.util.RandomUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.Collections;
import java.util.concurrent.TimeUnit;
* redis 单机锁
*
* @author fandongfeng
* @date 2023/3/29 06:52
*/
@Slf4j
@Service
public class RedisLock {
@Resource
RedisTemplate String, Object redisTemplate;
private static final String SELL_LOCK = kill:
/**
* 模拟秒杀
*
* @return 是否成功
*/
public String kill() {
String productId = 123
String key = SELL_LOCK + productId;
// 锁 value, 解锁时 用来判断当前锁是否是自己加的
String value = IdUtil.fastSimpleUUID();
// 加锁 十秒钟过期 防死锁
Boolean flag = redisTemplate.opsForValue().setIfAbsent(key, value, 10, TimeUnit.SECONDS);
if (!flag) {
return 加锁失败
}
try {
String productKey = good123
// 获取商品库存
Integer stock = (Integer) redisTemplate.opsForValue().get(productKey);
if (stock == null) {
// 模拟录入数据， 实际应该加载时从数据库读取
redisTemplate.opsForValue().set(productKey, 100);
stock = 100;
}
if (stock = 0) {
return 卖完了，下次早点来吧
}
// 扣减库存, 模拟随机卖出数量
int randomInt = RandomUtil.randomInt(1, 10);
redisTemplate.opsForValue().decrement(productKey, randomInt);
// 修改 db, 可以丢到队列里慢慢处理
return 成功卖出 + randomInt + 个，库存剩余 + redisTemplate.opsForValue().get(productKey) + 个
} finally {
// // 这种方法会存在删除别人加的锁的可能
// redisTemplate.delete(key);
// if(value.equals(redisTemplate.opsForValue().get(key))){
// // 因为 if 条件的判断和 delete 不是原子性的，// //if 条件判断成功后，恰好锁到期自己解锁
// // 此时别的线程如果持有锁了，就会把别人的锁删除掉
// redisTemplate.delete(key);
// }
// 使用 lua 脚本保证判断和删除的原子性
String luaScript =
if (redis.call( get ,KEYS[1]) == ARGV[1]) then +
return redis.call(del ,KEYS[1]) +
else +
return 0 +
end
redisTemplate.execute(new DefaultRedisScript (luaScript, Boolean.class), Collections.singletonList(key), value);
}
}
}进行单元测试，模拟一百个线程同时进行秒杀
package com.fandf.test.redis;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.RepeatedTest;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.parallel.Execution;
import org.springframework.boot.test.context.SpringBootTest;
import javax.annotation.Resource;
import static org.junit.jupiter.api.parallel.ExecutionMode.CONCURRENT;
* @Description:
* @author: fandongfeng
* @date: 2023-3-24 16:45
*/
@SpringBootTest
class SignServiceTest {
@Resource
RedisLock redisLock;
正文完
