Redis结合SpringBoot的秒杀案例

﹏ヽ暗。殇╰゛Y 2022-09-13 13:22 186阅读 0赞

### 文章目录 ###

*  1、构建SpringBoot项目
 *  2、启动类
 *  3、在Controller层里定义秒杀接口
 *  4、在Service层里通过lua脚本实现秒杀效果
 *  5、配置redis连接参数
 *  6、演示秒杀效果
 *   *  6.1 准备redis环境
     *  6.2 启动项目
     *  6.3 多线程形式发起秒杀请求

秒杀（也叫限时秒杀），是商家在某特定时间段里大幅降低网络商品价格的一种营销活动。这里用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/> 
        </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等依赖包。  
项目结构  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Yir5Zui562Jc2h55ZOl5Y-R6IKy_size_7_color_FFFFFF_t_70_g_se_x_16]

# 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主从复制集群，一主二从  
![在这里插入图片描述][ee07d02512164b62a7cb046fa28c23b2.png]  
设置10个商品  
![在这里插入图片描述][a0daff3387f249088253dfa4194652c8.png]

## 6.2 启动项目 ##

在浏览器访问`http://localhost:8081/quickBuy/Computer/abc`,测试秒杀接口，该url传入的商品名是“Computer”,需要和上面设置的商品名称一致，传入的发起秒杀请求的客户端名字为abc。输入该url后，能看到表示秒杀成功的如下输出。  
![在这里插入图片描述][94a228a5bf9d483faa18edc049e45f7a.png]  
进入redis查看  
![在这里插入图片描述][c3d146a931744f7b949efe2a09f7a1ea.png]  
发现商品数量变成了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  
![在这里插入图片描述][f2e6ceffdc7446fa9d415b01b965cd3e.png]  
启动上面的程序  
再次进入Redis查看商品数量和秒杀成功的用户  
![在这里插入图片描述][watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Yir5Zui562Jc2h55ZOl5Y-R6IKy_size_13_color_FFFFFF_t_70_g_se_x_16]  
可以看到，15个线程秒杀商品，最终成功的只有10个。

[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Yir5Zui562Jc2h55ZOl5Y-R6IKy_size_7_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/f14fa6f575804911b59273230a93d509.png
[ee07d02512164b62a7cb046fa28c23b2.png]: /images/20220828/5e6e984df21a4ef2b49147961fbf65c2.png
[a0daff3387f249088253dfa4194652c8.png]: /images/20220828/8b53c493cb0049818e53da8537b218a4.png
[94a228a5bf9d483faa18edc049e45f7a.png]: /images/20220828/599c1204a665494184dd0e5491afee59.png
[c3d146a931744f7b949efe2a09f7a1ea.png]: /images/20220828/f63517b70c8542d2afddf5fde82d7cb3.png
[f2e6ceffdc7446fa9d415b01b965cd3e.png]: /images/20220828/8fad51605cab4437821f3adfa173516e.png
[watermark_type_ZHJvaWRzYW5zZmFsbGJhY2s_shadow_50_text_Q1NETiBA5Yir5Zui562Jc2h55ZOl5Y-R6IKy_size_13_color_FFFFFF_t_70_g_se_x_16]: /images/20220828/75bf7be80a56436182a84d37f2eaf7d9.png