基于SpringBoot+Redis+MySQL实现秒杀系统(一)
秒杀系统
本专栏使用SpringBoot框架从零搭建秒杀系统,采用乐观锁、悲观锁或Redis解决商品超卖现象,采用令牌桶算法来实现限流,采用URL加盐的方式对URL加密,采用Redis控制用户单位时间的请求次数。
1. 开发背景及项目创建
1.1 为什么要做个系统?
如果你的项目流量非常小,完全不用担心有并发的购买请求,那么做这样一个系统意义不大。
但如果你的系统要像12306那样,接受高并发访问和下单的考验,那么你就需要一套完整的流程保护措施
,来保证你系统在用户流量高峰期不会被搞挂了。
-
严格防止超卖:库存100件你卖了120件,等着辞职吧
-
防止黑产:防止不怀好意的人群通过各种技术手段把你本该下发给群众的利益全收入了囊中。
-
保证用户体验:高并发下,别网页打不开了,支付不成功了,购物车进不去了,地址改不了了。这个问题非常之大,涉及到各种技术,也不是一下子就能讲完的,甚至根本就没法讲完。
1.2 用什么手段解决哪些问题?
乐观锁CAS防止超卖
令牌桶限流
Redis 缓存
消息队列异步处理订单
- …
2 开发步骤
2.1 创建数据库表
创建一个名为miaosha的mysql数据库,然后执行以下SQL语句即可创建3个数据库表。
-- ----------------------------
-- Table structure for stock
-- ----------------------------
DROP TABLE IF EXISTS `stock`;
CREATE TABLE `stock` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`name` varchar(50) NOT NULL DEFAULT '' COMMENT '名称',
`count` int(11) NOT NULL COMMENT '库存',
`sale` int(11) NOT NULL COMMENT '已售',
`version` int(11) NOT NULL COMMENT '乐观锁,版本号',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for stock_order
-- ----------------------------
DROP TABLE IF EXISTS `stock_order`;
CREATE TABLE `stock_order` (
`id` int(11) unsigned NOT NULL AUTO_INCREMENT,
`sid` int(11) NOT NULL COMMENT '库存ID',
`name` varchar(30) NOT NULL DEFAULT '' COMMENT '商品名称',
`create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',
PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;
-- ----------------------------
-- Table structure for user
-- ----------------------------
DROP TABLE IF EXISTS `user`;
CREATE TABLE `user` (
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
`name` varchar(80) DEFAULT NULL COMMENT '用户名',
`password` varchar(40) DEFAULT NULL COMMENT '用户密码',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8;
SET FOREIGN_KEY_CHECKS = 1;
2.2利用IDEA创建一个SpringBoot项目
- 选择Spring Initializr,点击“Next”按钮
2. 选择自己的Java Version(一般选择Java 8)
3.选择Spirng WEB、MySQL Driver和MyBatis Framework、Lombok(可选)
2.3 创建entity、dao、service和controller以及mapper
2.4 根据前面选择的模块生成对应的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 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.5.2</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.liuke</groupId>
<artifactId>miaosha</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>miaosha</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-web</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<configuration>
<excludes>
<exclude>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</exclude>
</excludes>
</configuration>
</plugin>
</plugins>
</build>
</project>
2.5 编写application.properties文件
注意:
1.MySQL数据库中需要创建一个名为miaosha的数据库
2.数据库中用户名和密码需要根据自己的数据库来修改
#springboot服务器的端口
server.port=8082
#应用的上下文路径,也可以称为项目路径,是构成url地址的一部分 访问项目路径变为 http://127.0.0.1:8082/ms/
server.servlet.context-path=/ms
#配置数据库连接池的类型
spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
#配置数据库连接池的连接驱动
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
#MySQL数据库的链接路径和数据库名 miaosha
spring.datasource.url=jdbc:mysql://localhost:3306/miaosha
#数据库用户名
spring.datasource.username=root
#数据库密码
spring.datasource.password=root
#Redis数据库索引(默认为0)
spring.redis.database=0
#Redis服务器地址
spring.redis.host=localhost
#Redis服务器连接端口
spring.redis.port=6379
#mybatis配置
#指定mapper配置文件位置
mybatis.mapper-locations=classpath:com/liuke/mapper/*.xml
#指定起别名来的类
mybatis.type-aliases-package=com.liuke.entity
#配置logging.level.*来具体输出哪些包的日志级别 默认有ERROR、WARN、INFO DEBUG需要设置
logging.level.root=info
logging.level.com.baizhi.dao=debug