Redis-10-Redis的事务使用案例-秒杀

以你之姓@ 2023-09-30 08:13 4阅读 0赞

### 文章目录 ###

*  1:简单版本使用redis控制秒杀
 *  2：使用乐观锁解决超卖问题
 *  3：使用redis连接池管理redis连接，设置超时时间
 *  4:使用lua脚本方法解决少买问题

# 1:简单版本使用redis控制秒杀 #

这是不考虑任何逻辑产生的一个秒杀demo，经过试验后发现问题，当并发情况下会产生超卖和连接超时问题

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

# 2：使用乐观锁解决超卖问题 #

当使用redis乐观锁，通过watch对库存进行监控，当其他人使用库存key时，发现和原来的库存版本号不一致就提示秒杀失败。但是经过试验在并发下会发生连接超时和少买情况（即高并发下，300个人并发，只有一个成功，其他人都失败了，因为成功的那个人修改了版本号）；

//秒杀过程
        public static boolean doSecKill(String uid,String prodid) throws IOException {
        
            //1 uid和prodid非空判断
            if(uid == null || prodid == null) {
        
                return false;
            }
    
            //2 连接redis
            Jedis jedis = new Jedis("192.168.44.168",6379);
    
            //3 拼接key
            // 3.1 库存key
            String kcKey = "sk:"+prodid+":qt";
            // 3.2 秒杀成功用户key
            String 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 判断用户是否重复秒杀操作
            if(jedis.sismember(userKey, uid)) {
        
                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;
            }
    
            //7.1 库存-1
            //jedis.decr(kcKey);
            //7.2 把秒杀成功用户添加清单里面
            //jedis.sadd(userKey,uid);
    
            System.out.println("秒杀成功了..");
            jedis.close();
            return true;
        }

# 3：使用redis连接池管理redis连接，设置超时时间 #

/*
    	* 链接池参数
    		MaxTotal：控制一个pool可分配多少个jedis实例，通过pool.getResource()来获取；如果赋值为-1，则表示不限制；如果pool已经分配了MaxTotal个jedis实例，则此时pool的状态为exhausted。
    		maxIdle：控制一个pool最多有多少个状态为idle(空闲)的jedis实例；
    		MaxWaitMillis：表示当borrow一个jedis实例时，最大的等待毫秒数，如果超过等待时间，则直接抛JedisConnectionException；
    		testOnBorrow：获得一个jedis实例的时候是否检查连接可用性（ping()）；如果为true，则得到的jedis实例均是可用的；
    	* 
    	* */
    	public static JedisPool getJedisPoolInstance() {
        
    		if (null == jedisPool) {
        
    			synchronized (JedisPoolUtil.class) {
        
    				if (null == jedisPool) {
        
    					JedisPoolConfig poolConfig = new JedisPoolConfig();
    					poolConfig.setMaxTotal(200);
    					poolConfig.setMaxIdle(32);
    					poolConfig.setMaxWaitMillis(100*1000);
    					poolConfig.setBlockWhenExhausted(true);
    					poolConfig.setTestOnBorrow(true);  // ping  PONG
    				 
    					jedisPool = new JedisPool(poolConfig, "192.168.44.168", 6379, 60000 );
    				}
    			}
    		}
    		return jedisPool;
    	}

//通过连接池得到jedis对象
    		JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();
    		Jedis jedis = jedisPoolInstance.getResource();

# 4:使用lua脚本方法解决少买问题 #

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

import org.slf4j.LoggerFactory;
    import redis.clients.jedis.HostAndPort;
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    
    import java.io.IOException;
    import java.util.HashSet;
    import java.util.Set;
    
    public class SecKill_redisByScript {
        
    
        private static final org.slf4j.Logger logger = LoggerFactory.getLogger(SecKill_redisByScript.class);
    
        public static void main(String[] args) {
        
            JedisPool jedispool = JedisPoolUtil.getJedisPoolInstance();
    
            Jedis jedis = jedispool.getResource();
            System.out.println(jedis.ping());
    
            Set<HostAndPort> set = new HashSet<HostAndPort>();
    
            //	doSecKill("201","sk:0101");
        }
    
        static String secKillScript = "local userid=KEYS[1];\r\n" +
                "local prodid=KEYS[2];\r\n" +
                "local qtkey='sk:'..prodid..\":qt\";\r\n" +
                "local usersKey='sk:'..prodid..\":usr\";\r\n" +
                "local userExists=redis.call(\"sismember\",usersKey,userid);\r\n" +
                "if tonumber(userExists)==1 then \r\n" +
                "   return 2;\r\n" +
                "end\r\n" +
                "local num= redis.call(\"get\" ,qtkey);\r\n" +
                "if tonumber(num)<=0 then \r\n" +
                "   return 0;\r\n" +
                "else \r\n" +
                "   redis.call(\"decr\",qtkey);\r\n" +
                "   redis.call(\"sadd\",usersKey,userid);\r\n" +
                "end\r\n" +
                "return 1";
    
        static String secKillScript2 =
                "local userExists=redis.call(\"sismember\",\"{sk}:0101:usr\",userid);\r\n" +
                        " return 1";
    
        public static boolean doSecKill(String uid, String prodid) throws IOException {
        
    
            JedisPool jedispool = JedisPoolUtil.getJedisPoolInstance();
            Jedis jedis = jedispool.getResource();
    
            //String sha1=  .secKillScript;
            String sha1 = jedis.scriptLoad(secKillScript);
            Object result = jedis.evalsha(sha1, 2, uid, prodid);
    
            String reString = String.valueOf(result);
            if ("0".equals(reString)) {
        
                System.err.println("已抢空！！");
            } else if ("1".equals(reString)) {
        
                System.out.println("抢购成功！！！！");
            } else if ("2".equals(reString)) {
        
                System.err.println("该用户已抢过！！");
            } else {
        
                System.err.println("抢购异常！！");
            }
            jedis.close();
            return true;
        }
    }