文章目录
- 分布式锁的应用场景及实现
- 1. 应用场景
- 2. 分布式锁原理
- 3. 分布式锁的实现
- 3.1 基于数据库
分布式锁的应用场景及实现
1. 应用场景
电商网站在进行秒杀、特价等大促活动时,面临访问量激增和高并发的挑战。由于活动商品通常是有限库存的,为了避免库存超卖和并发问题,分布式锁是一种有效的解决方案。
2. 分布式锁原理
分布式锁是一种多节点共享的同步机制,通过在多个节点之间协调访问资源,确保在同一时间只有一个节点能够获取锁并执行关键操作。
分布式锁的目的就是保证在分布式部署的应用集群中,多个服务在请求同一个方法或者同一个业务操作的情况下,对应业务逻辑只能被一台机器上的一个线程执行,避免出现并发问题。
在电商网站中,商品的库存即为共享资源,可以使用分布式锁来控制并发访问。
3. 分布式锁的实现
3.1 基于数据库
基于关系型数据库实现分布式锁是根据数据库的唯一性约束特性来实现资源的锁定。数据库的唯一性约束是指数据库表的某个字段值或者多个列组合的值不能重复。据此,我们可以创建一个锁表,包含资源名等字段,并为要锁定的资源名添加唯一索引。
当需要给某个资源加锁时,通过向数据库插入对应的资源来获取锁:
- 如果插入成功,表示成功获取锁;
- 如果插入失败,表示锁已经被占用。
- 在成功获取锁并处理完流程后要释放锁,删除对应的表记录即可。
创建一张分布式资源锁表:
CREATE TABLE `resourceLock` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
`resource_name` varchar(64) NOT NULL DEFAULT '' COMMENT '锁定的资源',
PRIMARY KEY (`id`),
UNIQUE KEY `uidx` (`resource_name `) USING BTREE
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='对资源加锁';
如上,resource_name
字段做了唯一性约束,要对某个资源加锁时,执行
insert into resourceLock(resource_name) values ("resource_name");
根据insert
语句的执行结果判断是否加锁成功。
基于数据库实现分布式锁有一些问题需要注意:
- 超时无法失效。需要通过定时任务或时间戳对比来删除超时数据。
- 数据库实现方式无法实现阻塞,需要重试insert操作来阻塞其他线程,但会带来服务器和数据库资源的浪费。