基于Redis结合SpringBoot的秒杀案例详解
1、构建SpringBoot项目
搭建名为quickbuy的springboot项目,相关的依赖包如下所示:
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.1.13.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>com.baizhi</groupId> <artifactId>quickbuy</artifactId> <version>0.0.1-SNAPSHOT</version> <name>quickbuy</name> <description>Demo project for Spring Boot</description> <properties> <java.version>1.8</java.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpclient</artifactId> <version>4.5.5</version> </dependency> <dependency> <groupId>org.apache.httpcomponents</groupId> <artifactId>httpcore</artifactId> <version>4.4.10</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
引入了Redis、HttpClient等依赖包。
项目结构
2、启动类
package com.baizhi; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplication public class QuickbuyApplication { public static void main(String[] args) { SpringApplication.run(QuickbuyApplication.class, args); } }
3、在Controller层里定义秒杀接口
@RestController public class QuickBuyController { @Autowired private SellService sellService; @RequestMapping("/quickBuy/{item}/{owner}") public String quickbuy(@PathVariable String item,@PathVariable String owner){ String result=sellService.quickBuy(item,owner); if(!result.equals("0")){ return owner+"success"; }else{ return owner+"fail"; } } }
通过@RequestMapping注解们可以把"/quickBuy/{item}/{owner}"格式的url映射到quickBuy方法上。
quickBuy是秒杀接口,该接口包含的两个参数是item和owner,分别表示待秒杀的商品名和发起秒杀请求的用户。这两个参数均被@PathVariable注解修饰,说明来自于url里的{item}和{owner}部分。
在这个quickBuy秒杀接口中调用了SellService类里的quickBuy方法实现了秒杀功能,并根据SellService类quickBuy方法返回的结果,向外部返回“秒杀成功”或“秒杀失败”的字符串语句。
4、在Service层里通过lua脚本实现秒杀效果
package com.baizhi.service; import org.springframework.data.redis.connection.RedisConnection; import org.springframework.data.redis.connection.ReturnType; import org.springframework.data.redis.core.RedisTemplate; import org.springframework.data.redis.core.script.DefaultRedisScript; import org.springframework.stereotype.Service; import javax.annotation.Resource; @Service public class SellService { @Resource private RedisTemplate redisTemplate; public String quickBuy(String item, String owner) { //用lua脚本实现秒杀 String luaScript="local owner=ARGV[1]\n" + "local item=KEYS[1] \n" + "local leftNum=tonumber(redis.call('get',item)) \n" + "if(leftNum>=1)\n" + "then redis.call('decrby',item,1)\n" + "redis.call('rpush','ownerList',owner)\n" + "return 1 \n" + "else \n" + "return 0 \n" + "end\n" + "\n"; String key=item; String args=owner; DefaultRedisScript<String> redisScript=new DefaultRedisScript<String>(); redisScript.setScriptText(luaScript); //调用lua脚本,请注意传入的参数 Object luaResult=redisTemplate.execute((RedisConnection connection)->connection.eval( redisScript.getScriptAsString().getBytes(), ReturnType.INTEGER, 1, key.getBytes(), args.getBytes() )); //根据lua脚本的执行情况返回结果 return luaResult.toString(); } }
对lua脚本的解释如下:
通过ARGV[1]参数传入发起秒杀请求的用户,用KEYS[1]参数传入待秒杀的商品。通过get item命令判断item商品在Redis里还有多少库存。
if语句中判定剩余库存大于等于1,就会先执行decrby命令把库存数减1,随后调用第6行的rpush命令,在ownerList里记录当前秒杀成功的用户,并通过return 1表示秒杀成功。如果判断库存数已经小于1,那么return 0表示秒杀失败。
其中将lua脚本赋予redisScript对象,并通过redisTemplate.execute方法执行lua脚本。
在调用redisTemplate.execute方法执行lua脚本时请注意以下三点:
- 需要以butes方式传入脚本
- 需要指定返回类型
- 传入该lua脚本所包含的KEYS类型参数的个数是1.
- 传入的KEYS和ARGV类型的参数需要转换成bytes类型
5、配置redis连接参数
application.properties
server.port=8081 spring.redis.host=192.168.159.22 spring.redis.port=6379
6、演示秒杀效果
6.1 准备redis环境
我用的刚搭建的redis主从复制集群,一主二从
设置10个商品
6.2 启动项目
在浏览器访问http://localhost:8081/quickBuy/Computer/abc
,测试秒杀接口,该url传入的商品名是“Computer”,需要和上面设置的商品名称一致,传入的发起秒杀请求的客户端名字为abc。输入该url后,能看到表示秒杀成功的如下输出。
进入redis查看
发现商品数量变成了9,且能看到秒杀成功的用户列表。
6.3 多线程形式发起秒杀请求
QuickBuyClients.java
package com.baizhi.client; import org.apache.http.HttpEntity; import org.apache.http.client.ClientProtocolException; import org.apache.http.client.methods.CloseableHttpResponse; import org.apache.http.client.methods.HttpGet; import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.HttpClientBuilder; import org.apache.http.util.EntityUtils; public class QuickBuyClients extends Thread{ @Override public void run() { QuickBuyUtil.quickBuy(); } public static void main(String[] args) { //开启15个线程,线程数多余秒杀商品数 for(int cnt=0;cnt<15;cnt++){ new QuickBuyClients().start(); } } } //封装秒杀方法的工具类 class QuickBuyUtil{ //在这个方法里,用HttpGet对象发起秒杀请求 public static void quickBuy(){ String user=Thread.currentThread().getName(); CloseableHttpClient httpClient= HttpClientBuilder.create().build(); //创建秒杀Get类型的url请求 HttpGet httpGet=new HttpGet("http://localhost:8081/quickBuy/Computer/"+user); //得到响应结果 CloseableHttpResponse res=null; try{ res=httpClient.execute(httpGet); HttpEntity responseEntity=res.getEntity(); if(res.getStatusLine().equals("200")&&responseEntity!=null){ System.out.println("秒杀结果:"+ EntityUtils.toString(responseEntity)); } }catch (ClientProtocolException e){ e.printStackTrace(); }catch (Exception e){ e.printStackTrace(); }finally { try{ //回收http连接资源 if(httpClient!=null){ httpClient.close(); } if(res!=null){ res.close(); } }catch (Exception e){ e.printStackTrace(); } } } }
先重新设置商品数量为10
启动上面的程序
再次进入Redis查看商品数量和秒杀成功的用户
可以看到,15个线程秒杀商品,最终成功的只有10个。
到此这篇关于Redis结合SpringBoot的秒杀案例的文章就介绍到这了,更多相关Redis结合SpringBoot秒杀内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
相关文章
解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题
这篇文章主要介绍了解决springboot使用logback日志出现LOG_PATH_IS_UNDEFINED文件夹的问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-04-28- 这篇文章主要介绍了详解如何清理redis集群的所有数据,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-18
- 这篇文章主要介绍了Redis连接池配置及初始化实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-03-29
- 这篇文章主要为大家详细介绍了SpringBoot实现excel文件生成和下载,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2021-02-09
详解redis desktop manager安装及连接方式
这篇文章主要介绍了redis desktop manager安装及连接方式,本文图文并茂给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下...2021-01-15- 这篇文章主要介绍了浅谈redis key值内存消耗以及性能影响,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-02-07
- 这篇文章主要介绍了详解springBoot启动时找不到或无法加载主类解决办法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-16
- 最近在工作中遇到了一个问题,通过查找相关资料才得知原因是因为返回结果的问题,下面这篇文章主要给大家介绍了关于lua读取redis数据的null判断的相关资料,文中通过示例代码介绍的非常详细,需要的朋友可以参考下...2020-06-30
- 这篇文章主要介绍了SpringBoot集成Redis实现消息队列的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-02-10
redis setIfAbsent和setnx的区别与使用说明
这篇文章主要介绍了redis setIfAbsent和setnx的区别与使用,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-08-04- 这篇文章主要介绍了解决Springboot get请求是参数过长的情况,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-09-17
- 这篇文章主要介绍了Redis的Expire与Setex区别说明,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2021-01-15
Spring Boot项目@RestController使用重定向redirect方式
这篇文章主要介绍了Spring Boot项目@RestController使用重定向redirect方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-02- 这篇文章主要介绍了Springboot+TCP监听服务器搭建过程,本文通过图文并茂的形式给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下...2020-10-28
- 这篇文章主要介绍了springBoot 项目排除数据库启动方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-09-10
详解SpringBoot之访问静态资源(webapp...)
这篇文章主要介绍了详解SpringBoot之访问静态资源(webapp...),文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-14- 这篇文章主要介绍了SpringBoot接口接收json参数解析,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-10-19
springboot中使用@Transactional注解事物不生效的坑
这篇文章主要介绍了springboot中使用@Transactional注解事物不生效的原因,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2021-01-26- Redis 是一个开源、高性能的Key-Value数据库,被广泛应用在服务器各种场景中。本文介绍几个查看Redis内存信息的命令,包括常用的info memory、info keyspace、bigkeys等。...2021-01-15
- 这篇文章主要介绍了springboot多模块包扫描问题的解决方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧...2020-09-16