Redis学习之秒杀案例

记录每次学习的过程，总结学习的内容，希望能给到自己和别人帮助。

Redis学习之秒杀案例

基础设计思路
1.uid和prodid的非空判断
2.连接redis
3.拼接key，包括库存的和成功秒杀的用户的
4.获取库存，如果库存null，表示秒杀还没开始
5.判断用户是否重复秒杀操作(使用set集合中的sismember)
6.判断如果商品数量，库存数量小于1，秒杀结束
7.每当有一次秒杀成功，库存-1，并且把秒杀成功用户添加到清单里面
基础代码如下：

public class doSecKill {//秒杀实例public static boolean doSecKill(String uid, String prodid) throws IOException {//1.uid和prodid的非空判断if (uid == null || prodid == null) {return false;}//2.连接reidsJedis jedis = new Jedis("192.168.92.131", 6379);//3.拼接key//3.1库存keyString kcKey = "sk:" + prodid + ":qt";//3.2秒杀成功用户keyString userKey = "sk:" + prodid + ":user";//4.获取库存，如果库存null，表示秒杀还没开始String kc = jedis.get(kcKey);if (kc == null) {System.out.println("秒杀还没有开始，请等待");jedis.close();return false;}//5.判断用户是否重复秒杀操作(使用set集合 中的sismember)Boolean sismember = jedis.sismember(userKey, uid);if (sismember) {System.out.println("已经秒杀成功了，不能重复秒杀");jedis.close();return false;}//6.判断如果商品数量，库存数量小于1，秒杀结束if (Integer.parseInt(kc) <= 0) {System.out.println("秒杀已经结束了");jedis.close();return false;}//7.秒杀过程//7.1库存-1jedis.decr(kcKey);//7.2把秒杀成功用户添加到清单里面jedis.sadd(userKey, uid);System.out.println("秒杀成功");jedis.close();return true;}
}

秒杀中会遇到的问题

问题1：连接超时的问题
----解决方法：通过连接池处理超时的问题
问题2：超卖的问题
----解决方法：通过乐观锁的方式，使用事务

问题1：连接超时的问题
----解决方法：通过连接池处理超时的问题

配置一个JedisPoolUtil

public class JedisPoolUtil {private static volatile JedisPool jedisPool = null;private JedisPoolUtil() {}public static JedisPool getJedisPoolInstance() {if (null == jedisPool) {synchronized (JedisPoolUtil.class) {if (null == jedisPool) {//配置池JedisPoolConfig poolConfig = new JedisPoolConfig();//最大链接数poolConfig.setMaxTotal(1000);//最大空闲poolConfig.setMaxIdle(32);//最大等待时间poolConfig.setMaxWaitMillis(100 * 1000);//测试连接poolConfig.setTestOnBorrow(true);//jedis连接池的配置jedisPool = new JedisPool(poolConfig, "192.168.92.131", 6379,60000);}}}return jedisPool;}//关闭链接池，释放对象public static void release(JedisPool jedisPool, Jedis jedis) {if (null != jedis) {jedisPool.returnResource(jedis);}}
}

将上面基础的代码改造：

//改造前：//2.连接reidsJedis jedis = new Jedis("192.168.92.131", 6379);//改造后：//通过连接池得到jedis对象JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();Jedis jedis = jedisPoolInstance.getResource();

问题2：超卖的问题
----解决方法：通过乐观锁的方式，使用事务
（把他放到一个事务中，进行组队，进行执行）

//1.监视库存
Jedis.watch(kcKey);
//2.使用事务
multi.decr(kcKey);
multi.sadd(userKey, uid);
//执行
List<Object> results = multi.exec();

综上，全改造代码

public class doSecKill {//秒杀实例public static boolean doSecKill(String uid, String prodid) throws IOException {//1.uid和prodid的非空判断if (uid == null || prodid == null) {return false;}//2.连接reids，通过连接池得到jedis对象JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();Jedis jedis = jedisPoolInstance.getResource();//3.拼接key// 3.1库存keyString kcKey = "sk:" + prodid + ":qt";//3.2秒杀成功用户keyString userKey = "sk:" + prodid + ":user";//监视库存jedis.watch(kcKey);//4.获取库存，如果库存null，表示秒杀还没开始String kc = jedis.get(kcKey);if (kc == null) {System.out.println("秒杀还没有开始，请等待");jedis.close();return false;}//5.判断用户是否重复秒杀操作(使用set集合 中的sismember)Boolean sismember = jedis.sismember(userKey, uid);if (sismember) {System.out.println("已经秒杀成功了，不能重复秒杀");jedis.close();return false;}//6.判断如果商品数量，库存数量小于1，秒杀结束if (Integer.parseInt(kc) <= 0) {System.out.println("秒杀已经结束了");jedis.close();return false;}//7.秒杀过程// 改造秒杀过程，使用事务Transaction multi = jedis.multi();//组队操作multi.decr(kcKey);multi.sadd(userKey, uid);//执行List<Object> results = multi.exec();if (results == null || results.size() == 0) {System.out.println("秒杀失败了");jedis.close();return false;} else {System.out.println("秒杀成功");jedis.close();return true;}}
}

另外，会有乐观锁造成的库存遗留问题
----使用LUA脚本可以解决（我也不太懂，先记录，以后再进行补充）

1.Lua 语言
Lua 是一个小巧的脚本语言，Lua脚本可以很容易的被C/C++ 代码调用，也可以反过来调用C/C++的函数，Lua并没有提供强大的库，一个完整的Lua解释器不过200k，所以Lua不适合作为开发独立应用程序的语言，而是作为嵌入式脚本语言。
很多应用程序、游戏使用LUA作为自己的嵌入式脚本语言，以此来实现可配置性、可扩展性。

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

local userid=KEYS[1];
local prodid=KEYS[2];
local qtkey="sk:"..prodid..":qt";
local usersKey="sk:"..prodid.":usr';
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;

凡心所向，素履以往，生如逆旅，一苇以航。