文档章节

Java秒杀系统实战系列~基于Redis的原子操作优化秒杀逻辑

稳杰
 稳杰
发布于 2019/08/15 09:59
字数 1458
阅读 102
收藏 0

摘要:

本篇博文是“Java秒杀系统实战系列文章”的第十四篇,本文将借助缓存中间件Redis的“单线程”特性及其原子操作一同优化“秒杀系统中秒杀的核心业务逻辑”,彻底初步解决“库存超卖”、“重复秒杀”等问题。

内容:

对于缓存中间件Redis,相信各位小伙伴或多或少都有听说过,甚至实战过,本文我们将基于SpringBoot整合Redis中间件,并基于其优秀的“单线程”特性和原子操作实现一种“分布式锁”,进而控制“高并发情况下多线程对于共享资源的访问”,最终解决“并发安全”,即“库存超卖”或者“重复秒杀”的问题!

(1)按照惯例,首先我们需要加入Redis的第三方依赖,如下所示:

<!-- redis -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-redis</artifactId>
    <version>1.3.5.RELEASE</version>
</dependency>

紧接着,需要在application.properties配置文件中加入Redis服务所在的Host、端口Post、链接密钥Password等信息,如下所示:

#redis
spring.redis.host=127.0.0.1
spring.redis.port=6379
#spring.redis.password=
redis.config.host=redis://127.0.0.1:6379

(2)紧接着,我们还需要自定义注入跟Redis的操作组件相关的Bean配置,在这里主要是自定义注入配置RedisTemplate跟StringRedisTemplate操作组件,并指定其对应的Key、Value的序列化策略:

// redis的通用化配置
@Configuration
public class RedisConfig {
    @Autowired
    private RedisConnectionFactory redisConnectionFactory;

    @Bean
    public RedisTemplate<String,Object> redisTemplate(){
        RedisTemplate<String,Object> redisTemplate=new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        //TODO:指定Key、Value的序列化策略
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());

        redisTemplate.setHashKeySerializer(new StringRedisSerializer());
        return redisTemplate;
    }

    @Bean
    public StringRedisTemplate stringRedisTemplate(){
        StringRedisTemplate stringRedisTemplate=new StringRedisTemplate();
        stringRedisTemplate.setConnectionFactory(redisConnectionFactory);
        return stringRedisTemplate;
    }
}

(3)至此,可以说是做好了充足的准备,接下来我们就可以拿来用了!为了区分之前的秒杀逻辑方法,我们开了一个新的秒杀逻辑方法killItemV3,并采用Redis的原子操作SETNX和EXPIRE方法来实现一种“分布式锁”,进而控制高并发多线程对共享资源的访问,其完整源代码如下所示:

//商品秒杀核心业务逻辑的处理-redis的分布式锁
@Override
public Boolean killItemV3(Integer killId, Integer userId) throws Exception {
    Boolean result=false;

    if (itemKillSuccessMapper.countByKillUserId(killId,userId) <= 0){

        //TODO:借助Redis的原子操作实现分布式锁-对共享操作-资源进行控制
        ValueOperations valueOperations=stringRedisTemplate.opsForValue();
        final String key=new StringBuffer().append(killId).append(userId).append("-RedisLock").toString();
        final String value=RandomUtil.generateOrderCode();
        Boolean cacheRes=valueOperations.setIfAbsent(key,value); 
        if (cacheRes){
            stringRedisTemplate.expire(key,30, TimeUnit.SECONDS);

            try {
                ItemKill itemKill=itemKillMapper.selectByIdV2(killId);
                if (itemKill!=null && 1==itemKill.getCanKill() && itemKill.getTotal()>0){
                    int res=itemKillMapper.updateKillItemV2(killId);
                    if (res>0){
                        commonRecordKillSuccessInfo(itemKill,userId);

                        result=true;
                    }
                }
            }catch (Exception e){
                throw new Exception("还没到抢购日期、已过了抢购时间或已被抢购完毕!");
            }finally {
                if (value.equals(valueOperations.get(key).toString())){
                    stringRedisTemplate.delete(key);
                }
            }
        }
    }else{
        throw new Exception("Redis-您已经抢购过该商品了!");
    }
    return result;
}

在上述代码中,我们主要是通过以下几个操作综合实现了“分布式锁”的功能,其中包括

(1)valueOperations.setIfAbsent(key,value);:表示当前的Key如果不存在于缓存中,那么将设置值成功,反之,如果Key已经存在于缓存中了,那么设置值将不成功!通过这一特性,我们可以将“KillId和UserId的一一对应关系~即一个人只能抢到一个商品”组合在一起作为Key!

(2)设置了Key,那么就需要在某个时间点去释放,即stringRedisTemplate.expire(key,30, TimeUnit.SECONDS);操作可以辅助实现!

(3)然鹅,真正“释放锁”的操作是如下这段代码去实现的,即判断一下当前要释放的锁是否就是之前一开始获取到的锁,如果是,就释放!这一点可以很好的避免误删锁的问题!

if (value.equals(valueOperations.get(key).toString())){
    stringRedisTemplate.delete(key);
}

至此,基于Redis的原子操作实现的分布式锁,进而控制高并发多线程对于共享资源的访问,从而解决秒杀场景下“库存超卖”、“重复秒杀”等问题,下面采用JMeter进行压测,压测的用户列表跟商品的“可秒杀数量total”跟上一篇章是一样的,即total=6本书,用户总共是10个。

点击JMeter的启动按钮,观察控制台的输出信息以及数据库表item_kill和item_kill_success表,可以看到秒杀记录的结果很是令人满意:

即库存为6本的商品~书籍恰好被10个用户中的6个秒杀得到!这种结果其实对于我们、对于用户来讲肯定是皆大欢喜的结局!

虽然演员对于自己的结局很满意,但是导演却察觉到戏中仍然有一些瑕疵!即如果秒杀系统在执行Redis的原子操作SetNX后、执行Expire之前,Redis的节点宕机了,那么此时将很有可能永久进入“Key锁死”的窘境,即重启之后,由于之前的Key没有得到释放,故而这个Key将永远存在于缓存中,即对应的用户将不能秒杀该商品了!这一点确实是一个隐患!

既然存在隐患,那么我们就得想办法解决了!莫急,下一篇章我们继续!

补充:

1、目前,这一秒杀系统的整体构建与代码实战已经全部完成了,完整的源代码数据库地址可以来这里下载:https://gitee.com/steadyjack/SpringBoot-SecondKill 记得Fork跟Star啊!!

2、最后,不要忘记了关注一下Debug的技术微信公众号:

© 著作权归作者所有

稳杰
粉丝 4
博文 18
码字总数 31856
作品 0
广州
高级程序员
私信 提问
加载中

评论(0)

三流程序员与一流程序员之间的区别,看看你是属于哪一类?

源码系列 手写spring mvc框架 基于Spring JDBC手写ORM框架 实现自己的MyBatis Spring AOP实战之源码分析 Spring IOC高级特性应用分析 ORM框架底层实现原理剖析 手写Spring MVC框架实现 手把手...

茶轴的青春
2018/04/17
34
0
Java开发者不会这些永远都只能是三流程序员,细数一下你是不是?

源码系列 手写spring mvc框架 基于Spring JDBC手写ORM框架 实现自己的MyBatis Spring AOP实战之源码分析 Spring IOC高级特性应用分析 ORM框架底层实现原理剖析 手写Spring MVC框架实现 手把手...

美的让人心动
2018/04/16
122
5
Redis是如何实现点赞、取消点赞的?

  20大进阶架构专题每日送达      作者:solocoder   juejin.im/post/5bdc257e6fb9a049ba410098   redis相关文章:   基于redis分布式锁实现“秒杀”(含代码)   正文:   ...

java进阶架构师
01/14
0
0
JavaWeb秒杀业务场景设计

秒杀业务场景设计问题经常被面试的时候被问到,在实际业务中,也常常需要实现,下面我们来看看如何实现秒杀业务. 秒杀业务,是典型的短时大量突发访问类问题 特点: 秒杀时网站的访问量大增; 秒杀...

小红牛
2018/06/11
0
0
【直播预告】Java Spring Boot开发实战系列课程(第16讲):Spring Boot 2.0实战Apache Kafka百万级高并发消息中间件与原理解析

主讲人:徐雷(阿里云栖特邀Java专家) 徐雷,花名:徐雷frank;资深架构师,MongoDB中文社区联席主席,吉林大学计算机学士,上海交通大学硕士。从事了 10年+开发工作,专注于分布式架构,J...

李博bluemind
2019/02/19
0
0

没有更多内容

加载失败,请刷新页面

加载更多

OSChina 周三乱弹 —— 提高不了工作效率和脸有关系

Osc乱弹歌单(2020)请戳(这里) 【今日歌曲】 @薛定谔的兄弟 :分享洛神有语创建的歌单「我喜欢的音乐」: 1 《夏令时记录(piano.ver)》- ゆめこ 手机党少年们想听歌,请使劲儿戳(这里) ...

小小编辑
今天
67
2
List的一波操作

public static void main(String[] args) { List<Entity> list = new ArrayList<>(); list.add(new Entity(1)); list.add(new Entity(2)); list.add(new Entity(3)); ......

那个猩猩很亮
今天
75
0
Spring基础

主要用于service层; 轻量级java开发框架; 各层 web层:struts,spring-MVC service层:spring dao层:hibernate,mybatis , jdbcTemplate --> spring-data Spring核心:控制反转IOC 切面编...

七宝1
今天
30
0
解决overflow+border-radius+transform圆角问题

网上还有其他版本,但是对我来说都不好使,下面是我在Chrome上的代码。overflow:hidden依然是不能正常使用,换成unset就可以,读者如果有更好的解决方案,请留言,谢谢。 <figure> <img...

hi懒喵
今天
53
0
《C语言》—— 数组

书籍使我变成了一个幸福的人,使我的生活变成轻松而舒适的诗。——高尔基 本文已经收录至我的GitHub,欢迎大家踊跃star 和 issues。 https://github.com/midou-tech/articles 点关注,不迷路!...

龙跃十二
今天
84
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部