广告

扫码关注官方微信

扫码下载APP
返回顶部
首页 > 资讯 > 后端开发 > Python >Springboot+redis+Vue实现秒杀的项目实践
  • 358

0
分享到

Springboot+redis+Vue实现秒杀的项目实践

Springboot+redis+Vue 秒杀Springboot redis秒杀 2022-11-13 14:11:39 358人浏览 八月长安

Python 官方文档：入门教程 => 点击学习

摘要

目录1、Redis简介2、实现代码3、启动步骤4、使用ab进行并发测试5、线程安全6、总结7、参考资料1、Redis简介 Redis是一个开源的key-value存储系统。 Redi

1、Redis简介

Redis是一个开源的key-value存储系统。

Redis的五种基本类型：String（字符串），list（链表），set（集合），zset（有序集合），hash，stream（Redis5.0后的新数据结构）

这些数据类型都支持push/pop、add/remove及取交集并集和差集及更丰富的操作，而且这些操作都是原子性的。

Redis的应用场景为配合关系型数据库做高速缓存，降低数据库io

需要注意的是，Redis是单线程的，如果一次批量处理命令过多，会造成Redis阻塞或网络拥塞（传输数据量大）

2、实现代码

pom.xml

<?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 http://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.2.1.RELEASE</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>org.example</groupId>
    <artifactId>seckill</artifactId>
    <version>1.0-SNAPSHOT</version>
    <properties>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-WEB</artifactId>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-test -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.2.1.RELEASE</version>
            <scope>test</scope>
        </dependency>

        <!-- redis -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

        <!-- spring2.X集成redis所需common-pool2-->
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-pool2</artifactId>
            <version>2.6.0</version>
        </dependency>

        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastJSON</artifactId>
            <version>1.2.24</version>
        </dependency>

    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <fork>true</fork>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

application.properties.xml

#Redis服务器地址
spring.redis.host=192.168.1.2
#Redis服务器连接端口
spring.redis.port=6379
#Redis数据库索引（默认为0）
spring.redis.database=0
#连接超时时间（毫秒）
spring.redis.timeout=1800000
#连接池最大连接数（使用负值表示没有限制）
spring.redis.lettuce.pool.max-active=20
#最大阻塞等待时间(负数表示没限制)
spring.redis.lettuce.pool.max-wait=-1
#连接池中的最大空闲连接
spring.redis.lettuce.pool.max-idle=5
#连接池中的最小空闲连接
spring.redis.lettuce.pool.min-idle=0
# 关闭超时时间
#pring.redis.lettuce.shutdown-timeout=100
#配置spring启动端口号
server.port=8080

前端界面

seckillpage.html

<!DOCTYPE html>
<html lang="en" xmlns:v-on="http://www.w3.org/1999/xhtml" xmlns:v-bind="http://www.w3.org/1999/xhtml">
<head>
    <meta charset="UTF-8">
    <title>redis秒杀</title>
</head>
<body>
<!-- 开发环境版本，包含了有帮助的命令行警告 -->
<script src="https://cdn.jsdelivr.net/npm/Vue/dist/vue.js"></script>
<!-- 官网提供的 axiOS 在线地址 -->
<script src="https://cdn.bootcdn.net/ajax/libs/axios/0.20.0-0/axios.min.js"></script>
<div id="app">
    <h1>商品1元秒杀</h1>
    <!-- 左箭头 -->
    <input type="button" value="<" v-on:click="prov" v-show="this.index>-1"/>
    <img v-bind:src="imgArr[index]" width="200px" />
    <!-- 右箭头 -->
    <input type="button" value=">" v-on:click="next" v-show="this.index<2"/><br>
    <input type="button" v-on:click="seckill" value="秒 杀"/>
</div>
<script>
    var app = new Vue({
        el: "#app",
        data: {
            productId: "01234",
            imgArr:[
                "/image/phone1.png",
                "/image/phone2.png",
                "/image/phone3.png",
            ],
            index:0
        },
        methods: {
            seckill: function () {
                let param = new URLSearchParams()
                param.append('productId', this.productId)
                param.append('index', this.index)
                axios({
                    method: 'post',
                    url: 'http://192.168.1.6:8080/index/doSeckill',
                    data: param
                }).then(function (response) {
               
                    if (response.data == true) {
                        alert("秒杀成功");
                    } else {
                        alert("抢光了");
                    }
                 
                },
                    function(error){
                    alert("发生错误");
                });

            },

            prov:function(){
                this.index--;
            },
            next:function(){
                this.index++;
            }
        }
    });

</script>
</body>
</html>

相关配置类

Redis配置类

RedisConfig.java

package com.SpringBoot_redis_seckill.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.cache.CacheManager;
import org.springframework.cache.annotation.CachinGConfigurerSupport;
import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.cache.RedisCacheConfiguration;
import org.springframework.data.redis.cache.RedisCacheManager;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.RedisSerializationContext;
import org.springframework.data.redis.serializer.RedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.time.Duration;


@EnableCaching
@Configuration
public class RedisConfig extends CachingConfigurerSupport {

    @Bean
    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        template.setConnectionFactory(factory);
        template.seTKEySerializer(redisSerializer); //key序列化方式
        template.setValueSerializer(jackson2JsonRedisSerializer); //value序列化
        template.setHashValueSerializer(jackson2JsonRedisSerializer); //value HashMap序列化
        return template;
    }

    @Bean(name = "cacheManager")
    public CacheManager cacheManager(RedisConnectionFactory factory) {
        RedisSerializer<String> redisSerializer = new StringRedisSerializer();
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
        //解决查询缓存转换异常的问题
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);
        // 配置序列化（解决乱码的问题）,过期时间600秒
        RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig()
                .entryTtl(Duration.ofSeconds(600))
                .serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(redisSerializer))
                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(jackson2JsonRedisSerializer))
                .disableCachingNullValues();
        RedisCacheManager cacheManager = RedisCacheManager.builder(factory)
                .cacheDefaults(config)
                .build();
        return cacheManager;
    }
}

配置Vue获取后端接口数据时出现的跨域请求问题。

CorsConfig.java

package com.springboot_redis_seckill.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import org.springframework.web.filter.CorsFilter;




@Configuration
public class CorsConfig {
    private CorsConfiguration buildConfig() {
        CorsConfiguration corsConfiguration = new CorsConfiguration();
        corsConfiguration.addAllowedOrigin("*"); //允许任何域名
        corsConfiguration.addAllowedHeader("*"); //允许任何头
        corsConfiguration.addAllowedMethod("*"); //允许任何方法
        return corsConfiguration;
    }

    @Bean
    public CorsFilter corsFilter() {
        UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
        source.reGISterCorsConfiguration("
@Service
public class SecKillServiceImpl implements SecKillService {
    @Autowired
    @Qualifier("redisTemplate")
    private RedisTemplate redisTemplate;

    @Override
    public synchronized boolean doSecKill(String uid, String productId) {
        //1、uid和productId非空判断
        if (uid == null || productId == null) {
            return false;
        }

        //2、拼接key
        String kcKey = "sk:" + productId + ":Qt";   //库存
        String userKey = "sk:" + productId + ":user";  //秒杀成功的用户

        //3、获取库存
        String kc = String.valueOf(redisTemplate.opsForValue().get(kcKey)) ;
        if (kc == null) {
            System.out.println("秒杀还没有开始，请等待");
            return false;
        }

        //4、判断用户是否已经秒杀成功过了
        if (redisTemplate.opsForSet().isMember(userKey, uid)) {
            System.out.println("已秒杀成功，不能重复秒杀");
            return false;
        }
        //5、如果库存数量小于1，秒杀结束
        if (Integer.parseInt(kc) <=0) {
            System.out.println("秒杀结束");
            return false;
        }

        //6、秒杀过程
        redisTemplate.opsForValue().decrement(kcKey);  //库存数量减1
        redisTemplate.opsForSet().add(userKey, uid);
        System.out.println("秒杀成功。。。");
        return true;
    }
}

控制层

package com.springboot_redis_seckill.controller;

import com.alibaba.fastjson.JSONObject;
import com.springboot_redis_seckill.service.SecKillService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.Random;


@Controller
@RequestMapping("/index")
public class MyController {
    @Autowired
    @Qualifier("secKillServiceImpl")
    private SecKillService secKillService;

    @RequestMapping(value = {"/seckillpage"}, method = RequestMethod.GET)
    public String seckillpage() {
        return "/html/seckillpage.html";
    }


    @RequestMapping(value = {"/doSeckill"}, method = RequestMethod.POST)
    @ResponseBody  //自动返回json格式的数据
    public Object doSeckill(HttpServletRequest request, HttpServletResponse response) {
        System.out.println("doSeckill");
        String productId = request.getParameter("productId");  
        String index = request.getParameter("index");
        System.out.println(productId+index);  //拼接成为商品ID
        int id = new Random().nextInt(50000);  //使用随机数生成用户ID
        String uid = String.valueOf(id) + " ";
        boolean flag = secKillService.doSecKill(uid, productId+index);
        System.out.println(flag);
        return flag;
    }
}

启动类

RunApplication.java

package com.springboot_redis_seckill;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;


@SpringBootApplication
public class RunApplication {
    public static void main(String[] args) {
        SpringApplication.run(RunApplication.class, args);
    }
}

3、启动步骤

因为一共有三件商品要秒杀，所以在redis里面设置三个商品的库存数量。这里数量都设置为10。

127.0.0.1:6379> set sk:012340:qt 10
OK
127.0.0.1:6379> set sk:012341:qt 10
OK
127.0.0.1:6379> set sk:012342:qt 10
OK

要确保redis能够被访问，要确保关闭linux的防火墙，以及关闭redis的保护模式。

vim redis.conf   --打开redis配置
 
service iptables stop   --关闭防火墙
 
 
//关闭redis保护模式
redis-cli    --进入redis客户端
config set protected-mode "no"   --配置里面关闭redis保护模式（只是进入redis.conf把protected-mode变为no是不行的，还要加一句config set protected-mode "no"

启动springboot项目

秒杀成功后，该商品在redis中的数量就减1。

当数量减为0时，则提示“抢光了”。

4、使用ab进行并发测试

如果是Centos 6版本的linux都是默认按照了ab工具的。

如果没有安装ab工具，可在linux终端用命令联网下载安装。

yum install httpd-tools

安装完成后，就可以使用ab工具进行并发测试了。

在linux终端输入如下命令：

ab -n 2000  -c 200 -p '/root/Desktop/post.txt' -T 'application/x-www-fORM-urlencoded' 'http://192.168.1.6:8080/index/doSeckill/'

012341这个商品库存变为0了

5、线程安全

为了防止出现“超买”的现象，需要让操作redis的方法是线程安全的（即在方法上加上一个“悲观锁”synchronized）。

如果不加synchronized就会出现“超买”现象，即redis库存会出现负数

之所以产生这种现象是由于并发导致多个用户同时调用了doSecKill()方法，多个用户同时修改了redis中的sk:012342:qt的值，但暂时都没有提交存入到redis中去。等到后来一起提交，导致了sk:012342:qt的值被修改了多次，因此会出现负数。

因此在doSecKill()方法加上悲观锁，用户调用该方法就对该方法加锁，修改了sk:012342:qt的值后并提交存入redis中之后，才会释放锁。其他用户才能得到锁并操作该方法。

6、总结

redis作为一种NoSQL的非关系型数据库，因为其单实例，简单高效的特性通常会被作为其他关系型数据库的高速缓存。尤其是在秒杀这样的高并发操作。先将要秒杀的商品信息从数据库读入到redis中，秒杀的过程实际上是在与redis进行交互。等秒杀完成后再将秒杀的结果存入数据库。可以有效降低降低数据库IO，防止数据库宕机。

7、参考资料

https://www.bilibili.com/video/BV1Rv41177Af?p=27

https://www.cnblogs.com/taiyonghai/p/5810150.html

到此这篇关于Springboot+redis+Vue实现秒杀的项目实践的文章就介绍到这了,更多相关Springboot+redis+Vue 秒杀内容请搜索编程网以前的文章或继续浏览下面的相关文章希望大家以后多多支持编程网！

您可能感兴趣的文档:
点击免费下载>>软考高级考试备考技巧/历年真题/备考精华资料

--结束END--

本文标题: Springboot+redis+Vue实现秒杀的项目实践

本文链接: https://www.lsjlt.com/news/171931.html(转载时请注明来源链接)

有问题或投稿请发送至: 邮箱/279061341@qq.com    QQ/279061341

本篇文章演示代码以及资料文档资料下载

下载Word文档到电脑，方便收藏和打印～

下载Word文档
去做题
猜你喜欢
  • Springboot+redis+Vue实现秒杀的项目实践
    目录1、Redis简介2、实现代码3、启动步骤4、使用ab进行并发测试5、线程安全6、总结7、参考资料1、Redis简介 Redis是一个开源的key-value存储系统。 Redi...
    99+
    2022-11-13
    Springboot+redis+Vue 秒杀 Springboot redis秒杀
  • springboot +rabbitmq+redis实现秒杀示例
    目录实现说明1、工具准备2、数据表3、pom4、代码结构5、配置config6、订单业务层7、redis实现层8、mq实现层9、redis模拟初始化库存量10、controller控...
    99+
    2022-11-13
  • redis秒杀系统的实现
    目录1.如何设计一个秒杀系统2.秒杀流程2.1 前端处理2.2 后端处理3.超卖问题4.总体思路1.如何设计一个秒杀系统 在设计任何系统之前，我们首先都需要先理解秒杀系统的业务背景 ...
    99+
    2022-11-13
  • SpringBoot+RabbitMQ+Redis实现商品秒杀的示例代码
    目录业务分析创建表功能实现1.用户校验2.下单3.减少库存4.支付总结业务分析 一般而言，商品秒杀大概可以拆分成以下几步： 用户校验 校验是否多次抢单，保证每个商品每个用户只能秒杀一...
    99+
    2022-11-12
  • Springboot-Management的项目实践
    目录准备工作1.新建一个项目2.导入静态资源3.创建实体类4.编写dao层首页实现中英文切换自定义地区的解析器组件登录功能1.页面调整2.编写LoginController3.登录拦...
    99+
    2022-11-13
  • SpringBoot之使用Redis实现分布式锁(秒杀系统)
    目录一、Redis分布式锁概念篇1.1、为什么要使用分布式锁1.2、分布式锁应具备哪些条件1.3、分布式锁的三种实现方式二、Redis分布式锁实战篇2.1、导入依赖2.2、配置Red...
    99+
    2022-11-12
  • SpringBoot实现扫码登录的项目实践
    目录一、首先咱们需要一张表二、角色都有哪些三、接口都需要哪些？四、步骤五、疯狂贴代码Spring Boot中操作WebSocket一、首先咱们需要一张表 这表是干啥的呢？就是记录一下...
    99+
    2022-11-13
  • SpringBoot整合chatGPT的项目实践
    目录1 添加依赖2 创建相关文件2.1 实体类:OpenAi.java2.2 配置类:OpenAiProperties.java2.3 核心业务逻辑OpenAiUtils.java2...
    99+
    2023-03-24
    SpringBoot整合chatGPT SpringBoot chatGPT
  • Redis实现秒杀的问题怎么解决
    本篇内容介绍了“Redis实现秒杀的问题怎么解决”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！1、秒杀逻辑...
    99+
    2022-10-19
  • 超详细讲解Java秒杀项目登陆模块的实现
    目录一、项目前准备1、新建项目2、导入依赖3、执行sql脚本4、配置yml文件5、在启动类加入注解6、自动生成器二、前端构建1、导入layui2、将界面放到template3、在js...
    99+
    2022-11-13
  • SpringBoot实现模块日志入库的项目实践
    目录1.简述2.LoginController3.Action4.TransactionUtils5.LoginService6.LoginLogService6.1 @Async实...
    99+
    2023-05-18
    SpringBoot 模块日志入库 SpringBoot 模块日志
  • SpringBoot整合SpringSecurity实现JWT认证的项目实践
    目录前言1、创建SpringBoot工程2、导入SpringSecurity与JWT的相关依赖3.定义SpringSecurity需要的基础处理类4. 构建JWT token工具类5...
    99+
    2022-11-13
  • 使用Redis实现秒杀功能的简单方法
    1. 怎样预防数据库超售现象 设置数据库事务的隔离级别为Serializable（不可用） Serializable就是让数据库去串行化的去执行事务，一个事务执行完才能去执行下一个事...
    99+
    2022-11-12
  • 超详细讲解Java秒杀项目用户验证模块的实现
    目录一、用户验证1、在方法内添加请求与反应2、cookie操作的封装3、UserServiceImpl4、跳转界面PathController 二、全局session1、导...
    99+
    2022-11-13
  • vue+jsplumb实现工作流程图的项目实践
    最近接到一个需求——给后台开发一个工作流程图，方便给领导看工作流程具体到哪一步。 先写了一个demo，大概样子如下： 官网文档Home | jsPlumb ...
    99+
    2022-11-13
  • SpringBoot项目实现短信发送接口开发的实践
    一. 短信接口实现 描述:请求第三方短信接口平台(而第三方短信平台的接口请求是webservice方式实现的),此时我们要测试接口是否通,要用的工具SoapUI测试工具, 不能用P...
    99+
    2022-11-12
  • springboot创建的web项目整合Quartz框架的项目实践
    目录介绍基于springboot创建的web项目整合Quartz框架依次实现mvc三层介绍 Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源...
    99+
    2022-11-13
  • 如何通过redis减库存的秒杀场景实现
    目录使用思路：第一步：系统初始化后就将所有商品库存放入缓存第二步： 预减库存从缓存中减库存内存标记Redis扣库存，主要目的是减少对数据库的访问，之前的减库存，直接访问数据库，读取库...
    99+
    2022-11-13
  • 怎么通过redis实现减库存的秒杀场景
    这篇“怎么通过redis实现减库存的秒杀场景”文章的知识点大部分人都不太理解，所以小编给大家总结了以下内容，内容详细，步骤清晰，具有一定的借鉴价值，希望大家阅读完这篇文章能有所收获，下面我们一起来看看这篇“怎么通过redis实现减库存的秒杀...
    99+
    2023-06-30
  • 记一次Maven项目改造成SpringBoot项目的过程实践
    目录背景概述过程加依赖修改main方法所在类引入数据库依赖启动类上加入mapper扫描添加application.ymlsqlSessionFactory空指针异常分析改造Mybat...
    99+
    2022-11-13
软考高级职称资格查询
软考职称历年真题下载
软考职称资料下载
热门wiki
近期文章
推荐阅读
热门问答
热门标签
编程网，编程工程师的家园，是目前国内优秀的开源技术社区之一，形成了由开源软件库、代码分享、资讯、协作翻译、讨论区和博客等几大频道内容，为IT开发者提供了一个发现、使用、并交流开源技术的平台。

  • 官方手机版

  • 微信公众号

  • 商务合作