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

摘要：

本篇博文是“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等信息，以下所示：

（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将永远存在于缓存中，即对应的用户将不能秒杀该商品了！这一点确实是一个隐患！

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

补充：

一、目前，这一秒杀系统的总体构建与代码实战已经所有完成了，完整的源代码数据库地址能够来这里下载：gitee.com/steadyjack/… 记得Fork跟Star啊！！

二、最后，不要忘记了关注一下Debug的技术微信公众号：