Redis之秒杀系统

目录

Redis 秒杀

Mysql数据库设计

Mysql秒杀实现

Mysql+Redis秒杀实现

秒杀是一种高并发场景，通常指的是在短时间内（秒级别）有大量用户同时访问某个商品或服务，争相抢购的情景。在这种情况下，系统需要处理大量并发请求，确保公平性、一致性，并防止因并发而导致的问题，例如超卖、恶意请求等。以下是在高并发秒杀场景下需要考虑的一些关键问题和解决方案：

  1. 超卖问题： 大量用户同时抢购同一商品可能导致超卖（卖出超过库存数量）的问题。为了解决这个问题，可以采用悲观锁或乐观锁的方式来控制库存的访问。数据库的行级锁、分布式锁等技术都可以用来防止超卖。

  2. 性能优化： 高并发场景下，系统性能是关键。使用缓存、异步处理、CDN 加速等手段可以显著提升系统的性能。缓存可以存储商品信息、用户状态等，减轻数据库压力。异步处理可以将一些不需要即时返回结果的操作异步执行，减轻请求的响应时间。

  3. 并发控制： 在高并发场景下，为了防止系统崩溃或服务不可用，需要对并发进行控制。可以使用队列、限流等技术，确保系统在承受能力范围内处理请求，防止系统超负荷崩溃。

  4. 秒杀令牌和时间窗口： 可以在系统中引入秒杀令牌，只有携带有效令牌的用户才能参与秒杀。同时，可以设置一个时间窗口，只在特定的时间范围内允许秒杀操作，有效控制请求的涌入。

  5. 用户鉴权和防刷： 针对恶意请求，需要进行用户鉴权，并采用防刷策略。例如，限制同一用户在短时间内的请求次数，通过验证码等方式增加用户请求的成本，防止恶意请求。

  6. 队列和异步处理： 使用消息队列将用户的秒杀请求进行排队，然后异步处理。这样可以有效地削峰填谷，减轻系统瞬时的压力，提高系统的容错能力。

  7. 分布式事务： 如果系统是分布式的，需要考虑分布式事务的问题。确保在秒杀过程中的各个阶段，包括扣减库存、生成订单等，能够保持事务的一致性。

  8. 实时监控和日志记录： 在高并发场景下，实时监控是及时发现问题、解决问题的关键。记录详细的日志信息，包括用户请求日志、系统性能日志等，便于事后分析和优化。

Redis 秒杀

Mysql数据库设计

/*
SQLyog Community v11.26 (32 bit)
MySQL - 8.0.33 : Database - test
*********************************************************************
*//*!40101 SET NAMES utf8 */;/*!40101 SET SQL_MODE=''*/;/*!40014 SET @OLD_UNIQUE_CHECKS=@@UNIQUE_CHECKS, UNIQUE_CHECKS=0 */;
/*!40014 SET @OLD_FOREIGN_KEY_CHECKS=@@FOREIGN_KEY_CHECKS, FOREIGN_KEY_CHECKS=0 */;
/*!40101 SET @OLD_SQL_MODE=@@SQL_MODE, SQL_MODE='NO_AUTO_VALUE_ON_ZERO' */;
/*!40111 SET @OLD_SQL_NOTES=@@SQL_NOTES, SQL_NOTES=0 */;
CREATE DATABASE /*!32312 IF NOT EXISTS*/`test` /*!40100 DEFAULT CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci */ /*!80016 DEFAULT ENCRYPTION='N' */;USE `test`;/*Table structure for table `stock` */DROP TABLE IF EXISTS `stock`;CREATE TABLE `stock` (`id` BIGINT NOT NULL AUTO_INCREMENT,`name` VARCHAR(20) DEFAULT NULL,`count` INT DEFAULT NULL,`create_time` TIMESTAMP NULL DEFAULT CURRENT_TIMESTAMP,PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;/*Data for the table `stock` */INSERT  INTO `stock`(`id`,`name`,`count`,`create_time`) VALUES (1,'apple',500,'2023-11-28 19:02:04'),(2,'huawei',500,'2023-11-28 19:02:26');/*Table structure for table `stock_order` */DROP TABLE IF EXISTS `stock_order`;CREATE TABLE `stock_order` (`id` BIGINT NOT NULL AUTO_INCREMENT,`name` VARCHAR(20) DEFAULT NULL,`price` INT DEFAULT NULL,`create_time` TIMESTAMP NULL DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=1729467951815541250 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;/*Data for the table `stock_order` *//*Table structure for table `article_select` */DROP TABLE IF EXISTS `article_select`;/*!50001 DROP VIEW IF EXISTS `article_select` */;
/*!50001 DROP TABLE IF EXISTS `article_select` */;/*!50001 CREATE TABLE  `article_select`(`a` bigint ,`b` varchar(11) ,`c` varchar(20) ,`d` bigint 
)*/;/*View structure for view article_select *//*!50001 DROP TABLE IF EXISTS `article_select` */;
/*!50001 DROP VIEW IF EXISTS `article_select` */;/*!50001 CREATE ALGORITHM=UNDEFINED DEFINER=`root`@`localhost` SQL SECURITY DEFINER VIEW `article_select` (`a`,`b`,`c`,`d`) AS select `article`.`id` AS `id`,`article`.`name` AS `name`,`article`.`des` AS `des`,`article`.`categoryid` AS `categoryid` from `article` */;/*!40101 SET SQL_MODE=@OLD_SQL_MODE */;
/*!40014 SET FOREIGN_KEY_CHECKS=@OLD_FOREIGN_KEY_CHECKS */;
/*!40014 SET UNIQUE_CHECKS=@OLD_UNIQUE_CHECKS */;
/*!40111 SET SQL_NOTES=@OLD_SQL_NOTES */;

Mysql秒杀实现

秒杀代码设计初步代码如下:

@RestController
public class MyController {@AutowiredStockMapper stockMapper;@AutowiredStockOrderMapper stockOrderMapper;@Transactional@GetMapping("/order/{id}")public String order(@PathVariable("id") Long id){Stock stock = stockMapper.selectById(id);Integer count = stock.getCount();if(count<=0){throw new RuntimeException("库存不足");}StockOrder stockOrder=new StockOrder();stockOrder.setName(stock.getName());stockOrderMapper.insert(stockOrder);UpdateWrapper<Stock> updateWrapper=new UpdateWrapper<>();updateWrapper.setSql("count = count - 1 where count > 0 and id ="+id); //在mysql这里执行的时候，数据库会加行锁，所以相对是安全的int update = stockMapper.update(null, updateWrapper);if(update<=0){throw new RuntimeException("库存不足");}return "success";}
}

由于业务代码直接与mysql数据库进行交互，mysql一秒支持的并发量低，性能较低，然后下面进行压测：

压测得到的汇总报告如下图：

Mysql+Redis秒杀实现

使用redis修改代码如下：

@RestController
public class MyController {@AutowiredStringRedisTemplate stringRedisTemplate;@AutowiredStockMapper stockMapper;@AutowiredStockOrderMapper stockOrderMapper;@PostConstructpublic void init(){List<Stock> stocks = stockMapper.selectList(null);for (Stock stock : stocks) {stringRedisTemplate.opsForValue().set("product_"+stock.getId(),stock.getCount()+"");}}@GetMapping("/order/{id}")public String order(@PathVariable("id") Long id){Long decrement = stringRedisTemplate.opsForValue().decrement("product_" + id);if(decrement<0){stringRedisTemplate.opsForValue().increment("product_"+id);return "库存不足";}try {((MyController)AopContext.currentProxy()).mys_order(id);}catch (Exception e){stringRedisTemplate.opsForValue().increment("product_"+id);return "库存不足";}return "购买成功";}@Transactionalpublic void mys_order(Long id){Stock stock = stockMapper.selectById(id);if(stock.getCount()<=0){throw new RuntimeException("库存不足");}StockOrder stockOrder=new StockOrder();stockOrder.setName(stock.getName());stockOrderMapper.insert(stockOrder);UpdateWrapper<Stock> updateWrapper=new UpdateWrapper<>();updateWrapper.setSql("count = count - 1 where count > 0 and id ="+id); //在mysql这里执行的时候，数据库会加行锁，所以相对是安全的int update = stockMapper.update(null, updateWrapper);if(update<=0){throw new RuntimeException("库存不足");}}
}

压测结果吞吐量如下图，使用redis作为缓存相对于仅仅使用mysql数据库吞吐量提升了不少，性能得到了提升。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/209817.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

SQL Server 数据库，创建数据表

SQL Server 数据库，创建数据表

2.3表的基本概念 表是包含数据库中所有数据的数据库对象。数据在表中的组织方式与在电子表格中相似&#xff0c;都是 按行和列的格式组织的&#xff0c;每行代表一条唯一的记录&#xff0c;每列代表记录中的一个字段.例如&#xff0c;在包含公 司员工信息的表中&#xff0c;每行…
阅读更多...
深圳市左下右上百度坐标

深圳市左下右上百度坐标

爬取百度POI的时候&#xff0c;别人的代码中有提到左下&#xff0c;右上坐标&#xff0c;但是没有说从哪里来&#xff0c;而且还是百度的坐标。 经纬度:左下角,右上角&#xff1a;113.529103,37.444122;115.486183,38.768031 墨卡托坐标:左下角,右上角&#xff1a;12638139.45,…
阅读更多...
练习十二：利用SRAM设计一个FIFO

练习十二：利用SRAM设计一个FIFO

利用SRAM设计一个FIFO 1&#xff0c;任务目的2&#xff0c;设计要求3&#xff0c;FIFO接口的设计思路4&#xff0c;FIFO接口的测试&#xff0c;top.v5&#xff0c;FIFO接口的参考设计&#xff0c;fifo_interface.v6&#xff0c;SRAM模型&#xff0c;sram.v代码7&#xff0c;viv…
阅读更多...
Javaweb之Vue路由的详细解析

Javaweb之Vue路由的详细解析

5 Vue路由 5.1 路由介绍 将资代码/vue-project(路由)/vue-project/src/views/tlias/DeptView.vue拷贝到我们当前EmpView.vue同级&#xff0c;其结构如下&#xff1a; 此时我们希望基于4.4案例中的功能&#xff0c;实现点击侧边栏的部门管理&#xff0c;显示部门管理的信息&am…
阅读更多...
新的 BLUFFS 攻击导致蓝牙连接不再私密

新的 BLUFFS 攻击导致蓝牙连接不再私密

蓝牙是一种连接我们设备的低功耗无线技术&#xff0c;有一个新的漏洞需要解决。 中间的攻击者可以使用新的 BLUFFS 攻击轻松窥探您的通信。 法国研究中心 EURECOM 的研究员 Daniele Antonioli 演示了六种新颖的攻击&#xff0c;这些攻击被定义为 BLUFFS&#xff08;蓝牙转发和…
阅读更多...
计算机操作系统1

计算机操作系统1

.11.操作系统的基本定义 2.操作系统的四大特征 2.1.操作系统的虚拟特征 3.操作系统的功能&#xff1a; 1.处理器管理 2.存储器管理 3.文件管理 4.设备管理 4.总结&#xff1a; 1.并发和共享互为存在&#xff0c;没有并发也就没有共享&#xff0c;反之也是。 2.并发和并行的…
阅读更多...
基于PHP的在线日语学习平台

基于PHP的在线日语学习平台

有需要请加文章底部Q哦 可远程调试 PHP在线日语学习平台 一 介绍 此日语学习平台基于原生PHP开发&#xff0c;数据库mysql。系统角色分为用户和管理员。(附带参考设计文档) 技术栈&#xff1a;phpmysqlphpstudyvscode 二 功能 学生 1 注册/登录/注销 2 个人中心 3 查看课程…
阅读更多...
【MySQL的DQL查询语句】

【MySQL的DQL查询语句】

MySQL的DQL查询语句-----在Navicat下 将学生表导入Navicat中查询语句查询一整张表查询年龄大于22年龄大于22的女生查找文科的学生查找六班的学生计算学生的总分 &#xff08;group by&#xff09;合并两表 &#xff08;join on xxxx&#xff09;合并两张表 并求总分先合并在聚合…
阅读更多...
今日实施｜解读新国标对数据库审计的能力要求

今日实施｜解读新国标对数据库审计的能力要求

数据库审计是数据安全建设不可或缺的技术工具之一&#xff0c;无论是国家级的法律或标准&#xff0c;还是等保以及行业级的安全标准均对使用数据库审计有明确要求。据相关数据统计显示&#xff0c;数据库审计产品的市场需求已占据中国数据库安全市场容量的6成以上。 12月1日&am…
阅读更多...
rabbitMQ镜像队列的使用

rabbitMQ镜像队列的使用

在rabbitMQ集群中&#xff0c;默认发送消息时&#xff0c;队列默认时在一个节点上存在的。 我们以node01 node02 node03三节点集群为例&#xff0c;在node01声明队列发送消息后&#xff0c;发现&#xff1a; 测试队列只在节点node01上出现。 我们手动停止node01后&#xff0c…
阅读更多...
为什么Nginx被称为反向代理

为什么Nginx被称为反向代理

下图显示了 &#x1d41f;&#x1d428;&#x1d42b;&#x1d430;&#x1d41a;&#x1d42b;&#x1d41d; &#x1d429;&#x1d42b;&#x1d428;&#x1d431;&#x1d432; 和 &#x1d42b;&#x1d41e;&#x1d42f;&#x1d41e;&#x1d42b;&#x1d42c;&#…
阅读更多...
有哪些可信的SSL证书颁发机构？

有哪些可信的SSL证书颁发机构？

目前市面上所显示的SSL证书颁发机构可所谓不计其数&#xff0c;类型也是多样&#xff0c;就好比我们同样是买一件T恤&#xff0c;却有百家不同类型的店铺一个道理。根据CA里面看似很多&#xff0c;但能拿到99%浏览器及设备信任度的寥寥无几&#xff0c;下面小编整理出几家靠谱可…
阅读更多...
Day50力扣打卡

Day50力扣打卡

打卡记录 三个无重叠子数组的最大和 链接 滑动窗口 class Solution:def maxSumOfThreeSubarrays(self, nums: List[int], k: int) -> List[int]:n, ans len(nums), []sum1 sum2 sum3 0maxsum1idx, maxsum12idx 0, ()maxsum1 maxsum12 total 0for i in range(2 * …
阅读更多...
Ubuntu Server 20.04.6下Anaconda3安装Pytorch

Ubuntu Server 20.04.6下Anaconda3安装Pytorch

环境 Ubuntu 20.04.6 LTS Anaconda3-2023.09-0-Linux-x86_64.sh conda 23.7.4 Pytorch 1.11.0 安装 先创建一个工作环境&#xff0c;环境名叫lia&#xff1a; conda create -n lia python3.8环境的使用方法如下&#xff1a; conda activate lia # 激活环境 conda deactiv…
阅读更多...
centos7 设置静态ip

centos7 设置静态ip

文章目录 设置VMware主机设置centos7 设置 设置VMware 主机设置 centos7 设置 vim /etc/sysconfig/network-scripts/ifcfg-ens33重启网络服务 service network restart检验配置是否成功 ifconfig ip addr
阅读更多...
用python写一个简单的爬虫

用python写一个简单的爬虫

爬虫是一种自动化程序&#xff0c;用于从互联网上获取数据。它能够模拟人类浏览网页的行为&#xff0c;访问网页并提取所需的信息。爬虫在很多领域都有广泛的应用&#xff0c;例如数据采集、信息监控、搜索引擎索引等。 下面是一个使用Python编写的简单爬虫示例&#xff1a; …
阅读更多...
【蓝桥杯】带分数

【蓝桥杯】带分数

带分数 题目要求用一个ab/c的形式得到一个值&#xff0c;而且只能在1~9里面不重复的组合。 可以对1~9进行全排列&#xff0c;然后不断划分区间。 #include<iostream> #include<vector> using namespace std; int st[15]; int num[15]; int res; int n;int calc(i…
阅读更多...
SQL Server 数据库，创建数据表（使用T-SQL语句）

SQL Server 数据库，创建数据表（使用T-SQL语句）

2.3表的基本概念 表是包含数据库中所有数据的数据库对象。数据在表中的组织方式与在电子表格中相似&#xff0c;都是 按行和列的格式组织的&#xff0c;每行代表一条唯一的记录&#xff0c;每列代表记录中的一个字段.例如&#xff0c;在包含公 司员工信息的表中&#xff0c;每行…
阅读更多...
Echarts大屏可视化_05 折线图的定制开发

Echarts大屏可视化_05 折线图的定制开发

继续跟着pink老师学习Echarts相关内容&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01;&#xff01; 折线图1 1.引入 折线图选取示例地址 标题没有用到就给他删了 直接引入 注意这里是line下面的chart 获取dom元素一定不…
阅读更多...
采集工具-免费采集器下载

采集工具-免费采集器下载

在当今信息时代&#xff0c;互联网已成为人们获取信息的主要渠道之一。对于研究者和开发者来说&#xff0c;如何快速准确地采集整个网站数据是至关重要的一环。以下将从九个方面详细探讨这一问题。 确定采集目标 在着手采集之前&#xff0c;明确目标至关重要。这有助于确定采集…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023