简介
上一篇文章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脚本来实现秒杀案例