站长家园(原代码之家)(www.adminjie.com)网站源码,微信源码,游戏源码,商业源码分享平台。
当前位置:网站首页 技术文章 网络编程 正文

一起聊聊Redis实现秒杀的问题

时间:2022-05-28 [网络编程]作者:fabuyuan 浏览:7 次

本篇文章给大家带来了关于Redis的相关知识,其中主要介绍了关于实现秒杀的相关内容,包括了秒杀逻辑、存在的链接超时、超卖和库存遗留的问题,下面一起来看一下,希望对大家有帮助。

推荐学习:Redis视频教程

1、秒杀逻辑

秒杀:解决计数器和人员记录的事务操作

  1. 1.uid和proid非空判断
  2. 2.连接redis
  3. 3.拼接key
    • 库存key
    • 秒杀成功用户key
  4. 4.获取库存,如果库存为null,秒杀还没开始
  5. 5.判断用户是否重复秒杀操作
  6. 6.判断商品数量,库存数量小于1,秒杀结束
  7. 7.秒杀过程
    • 库存-1
    • 把秒杀成功用户添加清单里面

2、存在问题

2.1、连接超时

原因:由于大量创建连接,十分消耗性能,并且有时获取连接不及时,出现连接超时的情况

2.2、超卖

在并发的情况下发生的,就是在输出没有库存(秒杀结束)后还有商品售出导致库存数量为负数。

2.3、库存遗留

使用乐观锁解决问题2之后,出现问题3

如果库存数量相对并发更多,由于使用乐观锁,第一个用户秒杀成功后会修改库存键的版本号,其他抢到的用户会因为版本号不同导致无法继续购买,就会有库存遗留问题

3、解决

3.1、连接超时

使用连接池,工具类如下:

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(200);
					poolConfig.setMaxIdle(32);
					poolConfig.setMaxWaitMillis(100 * 1000);
					poolConfig.setBlockWhenExhausted(true);
					poolConfig.setTestOnBorrow(true);
					jedisPool = new JedisPool(poolConfig, "127.0.0.1", 6379, 60000);
				}
			}
		}
		return jedisPool;
	}}//使用JedisPool jedisPoolInstance = JedisPoolUtil.getJedisPoolInstance();Jedis jedis = jedisPoolInstance.getResource();

springBoot版本(pom.xml引入,application.yml配置,然后注入对象即可)

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
    <version>3.2.0</version></dependency>
spring:
  redis:
    host: 127.0.0.1    port: 6379
    database: 0
    timeout: 1800000
    lettuce:
      pool:
        max-active: 20
        max-wait: -1
        max-idle: 5
        min-idle: 0
    @Autowired
    private RedisTemplate redisTemplate;

3.2、超卖问题

使用Redis事务,乐观锁 + watch

//监视库存
jedis.watch(kcKey);//中间代码忽略

//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;}

3.3、乐观锁导致的库存遗留问题

使用Lua嵌入式脚本语言

  1. 将复杂的或者多步的 Redis 操作,写为一个脚本,一次提交给Redis运行,减少反复连接 reids的次数。提升性能。
  2. LUA脚本是类似 redis 事务,有一定的原子性,不会被其他命令插队,可以完成redis事务性的操作
  3. LUA脚本功能,在Redis 2.6以上的版本才可以使用
  4. 利用 lua 脚本淘汰用户,解决超卖问题。
  5. redis 2.6 版本以后,通过 lua 脚本解决争抢问题,实际上是 redis 利用其单线程的特性,用任务队列的方式解决多任务并发问题
local userid=KEYS[1];				//1、2行定义两个变量,					
local prodid=KEYS[2];
local qtkey="sk:"..prodid..":qt";	//3,4行定义拼接key
local usersKey="sk:"..prodid..":usr";
local userExists=redis.call("sismember",usersKey,userid); //5-8,判断用户是否存在,不存在return 2
if tonumber(userExists)==1 then
    return2;
end
local num=redis.call("get",qtkey);	//9-11,判断商品是否存在
if tonumber(num)<=0 then
    return 0;
else								//12-15,用户和商品操作
    redis.call("decr",qtkey);
    redis.call("sadd",usersKey,userid);
end
return1;  							//最后一行return 1;  秒杀成功

完整代码如下:

// 定义两段Lua脚本(使用Lua脚本可以解决乐观锁带来的库存遗留问题)
	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" ;
 
 
	public static boolean doSecKill(String uid,String prodid) throws IOException {
 
		JedisPool jedispool =  JedisPoolUtil.getJedisPoolInstance();
		Jedis jedis=jedispool.getResource();
		jedis.select(2);
 
		// 通过jedis的scriptLoad方法加载Lua脚本
		String sha1=  jedis.scriptLoad(secKillScript);
		//通过jedis的evalsha方法调用Lua脚本
		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;
	}

推荐学习:Redis视频教程

以上就是一起聊聊Redis实现秒杀的问题的详细内容,更多请关注站长家园其它相关文章!

本文标签:  redis

转载请注明来源:一起聊聊Redis实现秒杀的问题

本文永久链接地址:https://www.adminjie.com/post/12867.html

免责声明:
本站所发布的一切资源仅限用于学习和研究目的;不得将上述内容用于商业或者非法用途,否则,一切后果请用户自负。本站信息来自网络,版权争议与本站无关。您必须在下载后的24个小时之内,从您的电脑中彻底删除上述内容。如果您喜欢该程序,请支持正版软件,购买注册,得到更好的正版服务。

附:
二○○二年一月一日《计算机软件保护条例》第十七条规定:为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬!鉴于此,也希望大家按此说明研究软件!

版权声明:
一、本站致力于为软件爱好者提供国内外软件开发技术和软件共享,着力为用户提供优资资源。
二、本站提供的部分源码下载文件为网络共享资源,请于下载后的24小时内删除。如需体验更多乐趣,还请支持正版。
三、我站提供用户下载的所有内容均转自互联网。如有内容侵犯您的版权或其他利益的,若有侵犯你的权益请:提交版权证明文件到邮箱 2225329873#qq.com(#换为@) 站长会进行审查之后,情况属实的会在三个工作日内为您删除。

  • 站长家园(原代码之家)会员升级
  • 最新文章
    • 聊聊使用Uniapp怎么实现全局消息提示及其组件

      聊聊使用Uniapp怎么实现全局消息提示及其组件

      Uniapp中怎么实现全局消息提示及其组件?下面本篇文章给大家介绍一下Uniapp全局消息提示及其组件的实现方法,希望对大家有所帮助!最近有项目需求我们能够在H...

    • 归纳总结SQL语句知识点二、基础语法

      归纳总结SQL语句知识点二、基础语法

      本篇文章给大家带来了关于SQL的相关知识,其中主要整理了SQL语句知识的相关问题,包括了一些SQL语句的基础语法、SQL语句提升等等内容,下面一起来看一下,希望...

    • 详细介绍Oracle备份与恢复

      详细介绍Oracle备份与恢复

      本篇文章给大家带来了关于Oracle的相关知识,其中主要整理了备份与恢复的相关问题,包括了一些关于数据保护、Oracle备份技术比较等等内容,下面一起来看一下,...

    • mysql怎么查询最大id值

      mysql怎么查询最大id值

      在mysql中,可以使用SELECT语句查询指定表中的全部数据,然后利用max()函数返回查询结果集中id列的最大值即可,查询语法“SELECTMAX(id)...

    • mysql有触发器吗

      mysql有触发器吗

      mysql有触发器。MySQL触发器是存储在数据库目录中的一组SQL语句集合,是MySQL中管理数据的有力工具,主要用于保护表中的数据。MySQL支持三种触发器...

    热门文章