Redis（二十四）-秒杀案例之库存遗留问题解决

Posted 2022-07-29 码农飞哥

您好，我是码农飞哥，感谢您阅读本文，欢迎一键三连哦。
💪🏻 1. Python基础专栏，基础知识一网打尽，9.9元买不了吃亏，买不了上当。 Python从入门到精通
❤️ 2. Python爬虫专栏，系统性的学习爬虫的知识点。9.9元买不了吃亏，买不了上当 。python爬虫入门进阶
❤️ 3. Ceph实战，从原理到实战应有尽有。 Ceph实战
❤️ 4. Java高并发编程入门，打卡学习Java高并发。 Java高并发编程入门
😁 5. 社区逛一逛，周周有福利，周周有惊喜。码农飞哥社区，飞跃计划
全网同名【码农飞哥】欢迎关注，个人VX: wei158556

文章目录

• • 简介
  • • 库存遗留问题的原因分析
    • 库存遗留问题解决
    • • lua脚本
    • 代码实现
  • 总结

简介

上一篇文章Redis（二十三）-秒杀案例之超卖和超时问题解决
我们介绍了超卖和超时问题的解决，最后还留了一个问题—库存遗留问题。这篇文章就来介绍下如何解决库存遗留问题。

库存遗留问题的原因分析

利用乐观锁之所以出现库存遗留问题，在高并发情况下，如果两千个人同时获取到V1.0版本的数据，然后同时提交的话，那么最终将只会有一个人修改成功，其余的1999人都会修改失败。

库存遗留问题解决

库存遗留问题可以通过LUA脚本解决。LUA脚本就是将复杂的或者多步的redis操作，写成一个脚本，一次提交给Redis执行，减少反复连接redis的次数。提升性能。
LUA脚本是类似redis事务，有一定的原子性，不会被其他命令插队，可以完成一些redis事务性的操作。
但是注意redis的lua脚本功能，只有在Redis 2.6以上的版本才可以使用
利用lua脚本淘汰用户，解决超卖问题。
redis 2.6版本以后，通过lua脚本解决争抢问题，实际上是redis利用其单线程的特性，用任务队列的方式解决多任务并发问题。

lua脚本

通过lua脚本将减库存decr命令和淘汰用户的命令sadd放在同一个脚本中，保证了命令的原子性。

local userid=KEYS[1];
local prodid=KEYS[2];
local qtkey="sk:"..prodid..":qt";
local userskey="sk:"..prodid..":user";
local userExists=redis.call("sismember",userskey,userid);
if tonumber(userExists)==1 then
  return 2;
end
local num=redis.call("get",qtkey);
if tonumber(num)<=0 then
  return 0;
else
  redis.call("decr",qtkey);
  redis.call("sadd",userskey,userid);
  end
  return 1

基本逻辑跟前面使用乐观锁实现是一样的。

1. 首先判断当前用户userid是否存在，如果存在返回2；
2. 判断库存是否存在，如果库存小于等于0，则返回0；
3. 执行扣减库存和淘汰用户的命令。

代码实现

将前面定义的lua脚本以字符串常量的形式定义。接着在doSecKill方法中执行该lua脚本。

@Service
public class SeckillByScript 
    static String secKillScript1 = "local userid=KEYS[1];\\n" +
            "local prodid=KEYS[2];\\n" +
            "local qtkey=\\"sk:\\"..prodid..\\":qt\\";\\n" +
            "local userskey=\\"sk:\\"..prodid..\\":user\\";\\n" +
            "local userExists=redis.call(\\"sismember\\",userskey,userid);" +
            "if tonumber(userExists)==1 then\\n" +
            "  return 2;\\n" +
            "end\\n" +
            "local num=redis.call(\\"get\\",qtkey);\\n" +
            "if tonumber(num)<=0 then\\n" +
            "  return 0;\\n" +
            "else\\n" +
            "  redis.call(\\"decr\\",qtkey);\\n" +
            "  redis.call(\\"sadd\\",userskey,userid);\\n" +
            "  end\\n" +
            "  return 1";

    public boolean doSecKill(String userid, String prodid) 
        JedisPool jedisPool = JedisPoolUtil.getJedisPool();
        Jedis jedis = jedisPool.getResource();
        String sha1 = jedis.scriptLoad(secKillScript1);
        Object result = jedis.evalsha(sha1, 2, userid, prodid);
        String reString = String.valueOf(result);
        if ("0".equals(reString)) 
            System.out.println("已抢空！");
            return false;
         else if ("1".equals(reString)) 
            System.out.println("抢购成功");
            return true;
         else if ("2".equals(reString)) 
            System.out.println("该用户已抢过！");
            return false;
         else 
            System.out.println("抢购异常");
            return false;
        
    

最后就是在controller中定义一个接口来调用该方法。通过ab工具模拟并发

ab -n 1000 -c 100 -T 'application/x-www-form-urlencoded' http://192.168.3.69:8080/seckill/skill/do2

最终的执行结果正常。

总结

本文详细介绍了如何通过lua脚本来实现秒杀案例