0
点赞
收藏
分享

微信扫一扫

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

陬者 2022-06-15 阅读 58

​作者:码农飞哥,

感谢您阅读本文,欢迎一键三连哦


文章目录

  • ​​简介​​
  • ​​库存遗留问题的原因分析​​
  • ​​库存遗留问题解决​​
  • ​​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脚本来实现秒杀案例


举报

相关推荐

0 条评论