分布式锁功效初探——以电商问题为例

news2024/11/26 0:44:18

文章目录

电商库存问题
- 单机处理-Sychronized
- 多机器处理-分布式锁
- - 入门级别，用redis实现，setnx
  - - 问题1：逻辑可能异常，造成死锁
    - 问题2：机器宕机
    - 问题3：锁一直失效，乱套
    - 锁续命
  - redisson
  - 分布式丢锁问题
  - - 主从、分布式的情况下锁丢失
    - 红锁问题
  - 分布式锁性能优化
  - - 锁的粒度越小越好
    - 分段锁
电商可能存在问题（下单链路）
- 订单重复生成
- 付钱了，后台状态取消了
Future（成功监听处理）
Lua脚本（redisson内部加锁实现）
Apache JMeter工具（压测）

电商库存问题

redis里面存储库存
程序里面减
多并发可能会有问题（超卖）

单机处理-Sychronized

可以加锁解决（Sychronized），但是只能解决单机问题，在分布式多机器上用谨慎，很可能出BUG

多机器处理-分布式锁

前台Nginx，后台代码部署于多个tomcat，共用redis
多台机器，并发越多，超卖的情况就越明显

入门级别，用redis实现，setnx

setnx key value，当且仅当key不存在，否则会使用第一次的值，后续不会覆盖
利用这个特性去实现锁
因为redis核心命令执行是单线程，库存计算需要存redis，多次进来需要排队，根据是否存在指定key去判断

Boolean result = stringRedisTemplate.opsForValue().setIfAbsent("lockKey", "aaa");
//用返回结果去判断锁
if(!result){
	return "系统正在执行"
}
// 执行业务逻辑
// 注意删除锁
stringRedisTemplate.delete("lockKey")

问题1：逻辑可能异常，造成死锁

加try catch，删除放到finaly

try{
	// 执行业务逻辑
}finally{
	stringRedisTemplate.delete("lockKey")
}

问题2：机器宕机

锁，加过期时间

// 不要这样分开执行，因为宕机无时不在
stringRedisTemplate.expire("lockKey", 10, TimeUnit.SECONDS);

// 使用元执行
 stringRedisTemplate.opsForValue().setIfAbsent("lockKey", "aaa", 10, TimeUnit.SECONDS);

问题3：锁一直失效，乱套

线程运行时间无法预料，会出现下面的问题
逻辑执行一半，过期时间到时，第二次请求又会进去，但是第一次把第二次的锁删了，第三次请求又会进去，第二次又将锁删除
问题根本点：自己的锁，被别的请求删除
解决：每一个锁的值用唯一值及进行标识，删除时做判断

// 设置锁，值为唯一值
String clientId = UUID.randomUUID().toString();
stringRedisTemplate.opsForValue().setIfAbsent("lockKey", clientId, 10, TimeUnit.SECONDS);

// 删除锁，进行值判断
if(clientId.equals(stringRedisTemplate.opsForValue().get("lockKey"))){
	// 这儿又可能出现锁到时问题，也会有并发问题
	stringRedisTemplate.delete("lockKey")
}

锁续命

当一个请求过来，加锁成功，开始执行代码逻辑；
这时，在后台开启一个分线程，进行一个定时任务，定时给锁续命；
检查主线程锁是否被删掉，如果删掉了说明任务执行完成了，否则锁快到过期时间时，去延长锁的超时时间

redisson

jedis儿子
redisson github地址
引入依赖

<dependency>
	<groupId>org.redisson</groupId>
	<artifacId>redisson</artifacId>
	<version>3.6.5</version>
</dependency>

配置

@Bean
public Redisson redisson(){
	// 此为单机模式
	Config config = new Config();
	config.useSingleServer().setAddress("redis://localhost:6379").setDatabase(8);
	return (Redisson) Redisson.create(config);
}

使用

@Autoried
private Redisson redisson;

// 获取一把锁对象
RLock redissonLock = redisson.getLock("lockKey");
// 加锁
redissonLock.lock();

try{
	// 执行业务逻辑
}finally{
	// 删锁
	redissonLock.unlock();
}