基于Redis结合SpringBoot的秒杀案例详解基于Redis结合SpringBoot的秒杀案

1、构建SpringBoot项目
2、启动类
3、在Controller层里定义秒杀接口
4、在Service层里通过lua脚本实现秒杀效果
5、配置redis连接参数
6、演示秒杀效果

6.1 准备redis环境
6.2 启动项目
6.3 多线程形式发起秒杀请求

1、构建SpringBoot项目搭建名为quickbuy的springboot项目，相关的依赖包如下所示：

4.0.0org.springframework.bootspring-boot-starter-parent2.1.13.RELEASE com.baizhiquickbuy0.0.1-SNAPSHOTquickbuyDemo project for Spring Boot1.8org.springframework.bootspring-boot-starter-data-redisorg.springframework.bootspring-boot-starter-weborg.springframework.bootspring-boot-starter-testtestorg.apache.httpcomponentshttpclient4.5.5org.apache.httpcomponentshttpcore4.4.10org.springframework.bootspring-boot-maven-plugin

引入了Redis、HttpClient等依赖包。
项目结构

文章图片

2、启动类

package com.baizhi; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; @SpringBootApplicationpublic class QuickbuyApplication {public static void main(String[] args) {SpringApplication.run(QuickbuyApplication.class, args); }}

3、在Controller层里定义秒杀接口

@RestControllerpublic class QuickBuyController {@Autowiredprivate 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; @Servicepublic class SellService {@Resourceprivate 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 redisScript=new DefaultRedisScript(); 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脚本。

【基于Redis结合SpringBoot的秒杀案例详解】在调用redisTemplate.execute方法执行lua脚本时请注意以下三点：

需要以butes方式传入脚本
需要指定返回类型
传入该lua脚本所包含的KEYS类型参数的个数是1.
传入的KEYS和ARGV类型的参数需要转换成bytes类型

5、配置redis连接参数 application.properties

server.port=8081spring.redis.host=192.168.159.22spring.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{@Overridepublic 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