基于redis分布式锁实现“秒杀”
作者丨lsfire
https://blog.csdn.net/u010359884/article/details/50310387
最近在项目中遇到了类似“秒杀”的业务场景,在本篇博客中,我将用一个非常简单的demo,阐述实现所谓“秒杀”的基本思路。
业务场景
所谓秒杀,从业务角度看,是短时间内多个用户“争抢”资源,这里的资源在大部分秒杀场景里是商品;
将业务抽象,技术角度看,秒杀就是多个线程对资源进行操作,所以实现秒杀,就必须控制线程对资源的争抢,既要保证高效并发,也要保证操作的正确。
一些可能的实现
刚才提到过,实现秒杀的关键点是控制线程对资源的争抢,根据基本的线程知识,可以不加思索的想到下面的一些方法:
1、秒杀在技术层面的抽象应该就是一个方法,在这个方法里可能的操作是将商品库存-1,将商品加入用户的购物车等等,在不考虑缓存的情况下应该是要操作数据库的。
那么最简单直接的实现就是在这个方法上加上synchronized
关键字,通俗的讲就是锁住整个方法;
2、锁住整个方法这个策略简单方便,但是似乎有点粗暴。可以稍微优化一下,只锁住秒杀的代码块,比如写数据库的部分;
3、既然有并发问题,那我就让他“不并发”,将所有的线程用一个队列管理起来,使之变成串行操作,自然不会有并发问题。
上面所述的方法都是有效的,但是都不好。
为什么?
第一和第二种方法本质上是“加锁”,但是锁粒度依然比较高。
什么意思?试想一下,如果两个线程同时执行秒杀方法,这两个线程操作的是不同的商品,从业务上讲应该是可以同时进行的,但是如果采用第一二种方法,这两个线程也会去争抢同一个锁,这其实是不必要的。
第三种方法也没有解决上面说的问题。
那么如何将锁控制在更细的粒度上呢?
可以考虑为每个商品设置一个互斥锁,以和商品ID相关的字符串为唯一标识,这样就可以做到只有争抢同一件商品的线程互斥,不会导致所有的线程互斥。
分布式锁恰好可以帮助我们解决这个问题。
何为分布式锁
分布式锁是控制分布式系统之间同步访问共享资源的一种方式。
在分布式系统中,常常需要协调他们的动作。
如果不同的系统或是同一个系统的不同主机之间共享了一个或一组资源,那么访问这些资源的时候,往往需要互斥来防止彼此干扰来保证一致性,在这种情况下,便需要使用到分布式锁。
我们来假设一个最简单的秒杀场景:
数据库里有一张表,column分别是商品ID,和商品ID对应的库存量,秒杀成功就将此商品库存量-1。
现在假设有1000个线程来秒杀两件商品,500个线程秒杀第一个商品,500个线程秒杀第二个商品。
我们来根据这个简单的业务场景来解释一下分布式锁。
通常具有秒杀场景的业务系统都比较复杂,承载的业务量非常巨大,并发量也很高。
这样的系统往往采用分布式的架构来均衡负载。
那么这1000个并发就会是从不同的地方过来,商品库存就是共享的资源,也是这1000个并发争抢的资源,这个时候我们需要将并发互斥管理起来。
这就是分布式锁的应用。
而key-value存储系统,如redis,因为其一些特性,是实现分布式锁的重要工具。
具体的实现
先来看看一些redis的基本命令:
SETNX key value
如果key不存在,就设置key对应字符串value。
在这种情况下,该命令和SET一样。
当key已经存在时,就不做任何操作。
SETNX是”SET if Not eXists”。
expire KEY seconds
设置key的过期时间。如果key已过期,将会被自动删除。
del KEY
删除key
由于笔者的实现只用到这三个命令,就只介绍这三个命令,更多的命令以及redis的特性和使用,可以参考redis官网。
需要考虑的问题
1、用什么操作redis?幸亏redis已经提供了jedis客户端用于java应用程序,直接调用jedis API即可。
2、怎么实现加锁?“锁”其实是一个抽象的概念,将这个抽象概念变为具体的东西,就是一个存储在redis里的key-value对,key是于商品ID相关的字符串来唯一标识,value其实并不重要,因为只要这个唯一的key-value存在,就表示这个商品已经上锁。
3、如何释放锁?既然key-value对存在就表示上锁,那么释放锁就自然是在redis里删除key-value对。
4、阻塞还是非阻塞?笔者采用了阻塞式的实现,若线程发现已经上锁,会在特定时间内轮询锁。
5、如何处理异常情况?比如一个线程把一个商品上了锁,但是由于各种原因,没有完成操作(在上面的业务场景里就是没有将库存-1写入数据库),自然没有释放锁,这个情况笔者加入了锁超时机制,利用redis的expire命令为key设置超时时长,过了超时时间redis就会将这个key自动删除,即强制释放锁(可以认为超时释放锁是一个异步操作,由redis完成,应用程序只需要根据系统特点设置超时时间即可)。
talk is cheap,show me the code
在代码实现层面,注解有并发的方法和参数,通过动态代理获取注解的方法和参数,在代理中加锁,执行完被代理的方法后释放锁。
几个注解定义:
cachelock是方法级的注解,用于注解会产生并发问题的方法:
lockedObject
是参数级的注解,用于注解商品ID等基本类型的参数:
LockedComplexObject
也是参数级的注解,用于注解自定义类型的参数:
CacheLockInterceptor
实现InvocationHandler
接口,在invoke方法中获取注解的方法和参数,在执行注解的方法前加锁,执行被注解的方法后释放锁:
最关键的RedisLock类中的lock方法和unlock方法:
上述的代码是框架性的代码,现在来讲解如何使用上面的简单框架来写一个秒杀函数。
先定义一个接口,接口里定义了一个秒杀方法:
上述SeckillInterface
接口的实现类,即秒杀的具体实现:
模拟秒杀场景,1000个线程来争抢两个商品:
在正确的预想下,应该每个商品的库存都减少了500,在多次试验后,实际情况符合预想。
如果不采用锁机制,会出现库存减少499,498的情况。
这里采用了动态代理的方法,利用注解和反射机制得到分布式锁ID,进行加锁和释放锁操作。
当然也可以直接在方法进行这些操作,采用动态代理也是为了能够将锁操作代码集中在代理中,便于维护。
通常秒杀场景发生在web项目中,可以考虑利用spring的AOP特性将锁操作代码置于切面中,当然AOP本质上也是动态代理。
小结
这篇文章从业务场景出发,从抽象到实现阐述了如何利用redis实现分布式锁,完成简单的秒杀功能,也记录了笔者思考的过程,希望能给阅读到本篇文章的人一些启发。
长按订阅更多精彩▼
基于redis分布式锁实现“秒杀”相关推荐
- Java程序猿笔记——基于redis分布式锁实现“秒杀”
最近在项目中遇到了类似"秒杀"的业务场景,在本篇博客中,我将用一个非常简单的demo,阐述实现所谓"秒杀"的基本思路. 业务场景 所谓秒杀,从业务角度看,是短时 ...
- Java版基于Redis分布式锁的实现方式
一.什么是分布式锁? 要介绍分布式锁,首先要提到分布式锁相对应的线程锁和进程锁, 线程锁:组要是给方法.代码块加锁,当方法或者代码块使用锁时,在同一时刻只有一个线程可以执行该方法或者代码块,线程锁只在 ...
- redis分布式锁及秒杀系统实战
本文分为两部分: 一.介绍redis分布式锁的原理和使用方法: 二.使用redis分布式锁实现一个简单的秒杀系统. 注意:本文使用java1.8,最后的例子为springboot项目. 目录 redi ...
- 基于redis分布式锁实现的多线程并发程序(原创)
前两个版本的代码 都或多或少存在一定的问题,虽然可能微乎其微,但是程序需要严谨再严谨 第一个版本问题: 局限于单机版,依赖于 Jvm的锁 第二个版本问题: 极端情况下,解锁逻辑的问题,线程B的锁, ...
- 基于redis分布式锁实现的多线程并发程序
前两个版本的代码 都或多或少存在一定的问题,虽然可能微乎其微,但是程序需要严谨再严谨, 第一个版本问题: 局限于单机版,依赖于 Jvm的锁 第二个版本问题: 极端情况下,解锁逻辑的问题,线程B的锁,可 ...
- Redis分布式锁实现秒杀
版权声明:本文为博主原创文章,未经博主允许不得转载. https://blog.csdn.net/u010359884/article/details/50310387 最近在项目中遇到了类似&quo ...
- redis分布式锁实现秒杀活动
最近,参与和负责公司的一次秒杀活动的设计开发,收获颇多,与大家分享.其实大家在生活中或见过或参见过秒杀活动,用户以极低的成本获得高价值的商品,所以也导致活动期间出现拥挤现象,进而导致一些高并发问题,所 ...
- @scheduled cron启动后和每小时执行_小耶哥: 一个Redis分布式锁又要和小鑫同学扯半个小时!...
1 Redis分布式锁 |1-1 定时任务重复执行-问题引入 最近小耶哥在做一个功能, 什么功能呢? 就是超时未支付的订单我们要定时关闭, 释放库存, 并且短信通知用户该订单因超时被取消了.由于小耶哥 ...
- 微服务架构之:Redis的分布式锁---搭建生产可用的Redis分布式锁
Redis分布式锁 集群架构下的并发问题 分布式锁的实现原理和不同方式的实现对比 基于Redis实现的分布式锁 Redis分布式锁1.0版 基于Redis分布式锁1.0版的误删问题 解决误删问题,Re ...
最新文章
- centos7 开启 关闭 NetworkManager
- 010 Editor v8.0.1_x32分析以及注册机制作
- python编程需要安装什么软件_[零基础学pythyon]安装python编程环境
- 不要轻易修改ESX主机的主机名
- python导入自定义文件_python引入导入自定义模块和外部文件的实例
- php curl hostname,php – 如何解决cURL错误(7):无法连接到主机?
- 常识推理相关最新研究进展
- java 偏向锁 怎么用_Java锁升级、偏向锁、轻量级锁
- 按图索骥:SQL中数据倾斜问题的处理思路与方法
- factorybean 代理类不能按照类型注入_快速理解Spring中的FactoryBean接口
- redis学习笔记二
- 区间合数的最小公倍数(质数+因数分解)
- 108次练习之模拟实现STL中的Vector(一)
- 【数据结构】----将一个链表拆分为两个链表
- PLSQL官网下载地址
- python~运算符_python运算符
- 艺赛旗(RPA)国家企业信用信息公示系统验证码破解(二)
- 医疗设备维修保养及常见故障维修技术学习
- 读书笔记-《像高手一样发言》
- 【git】No supported authentication methods available(server sent:pubickey)
热门文章
- android底部滑出view,Android CoordinatorLayout与NestedScrollView基于Behavior几行代码实现底部View滑入滑出...
- 第k大的数python代码_【Python】【输出前m大的数】
- lamp不解析php,LAMP环境下不能解析php原因及排查步骤
- C - 食物链 POJ - 1182
- 服务器 上传文件 杀毒,一种实现文件上传网站后自动进行杀毒的方法及系统
- python的and是什么_Python初学者:“==”and“is”的区别是什么?
- Selenium 2.0的由来及设计架构(三)
- 2014年第五届蓝桥杯决赛Java本科B组试题解析
- 微服务之API网关接口设计
- [SF] Symfony 组件 BrowserKit 原理