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.mzph.cn/news/186689.shtml

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

相关文章

LSTM seq2seq 模型之英语到法语翻译

LSTM seq2seq 模型之英语到法语翻译

1. 数据集下载 Machine-Translation-eng-fra | Kaggle 2. 预处理的完整的代码 import os.pathimport numpy as np import tensorflow as tf import keras from keras.callbacks import EarlyStopping, ModelCheckpoint from keras.preprocessing.text import Tokenizer from …
阅读更多...
Openai通用特定领域的智能语音小助手

Openai通用特定领域的智能语音小助手

无穷尽的Q&A 钉钉...钉钉... 双双同学刚到工位,报销答疑群的消息就万马纷沓而来。她只能咧嘴无奈的摇摇头。水都还没有喝一口就开始“人工智能”的去回复。原本很阳光心情开始蒙上一层薄薄阴影。在这无休无止的Q&A中&#xff0c;就算你对工作有磐石一般强硬&#xff0…
阅读更多...
Linux C/C++高级全栈开发（后端/游戏/嵌入式/高性能网络/存储/基础架构）

Linux C/C++高级全栈开发（后端/游戏/嵌入式/高性能网络/存储/基础架构）

Linux C/C高级全栈开发是一个涉及到多个领域的综合性技术要求&#xff0c;需要对Linux系统、C/C编程语言以及各种相关的技术进行深入的理解和应用。 下面是一些涵盖的主要技术领域和技能要点&#xff1a; Linux系统基础&#xff1a;熟悉Linux操作系统的原理和常用命令&#xf…
阅读更多...
Linux下的文件IO之系统IO

Linux下的文件IO之系统IO

1. 知识点 读入写出&#xff0c;切记以我们程序为中心向文件或者别的什么东西读入写出&#xff08;输入流输出流&#xff09; 人话就是 文件向我们程序就是读入 程序向文件或者别的什么就是写出 2. open打开文件 open.c /****************************************************…
阅读更多...
手写VUE后台管理系统5 - 整合状态管理组件pinia

手写VUE后台管理系统5 - 整合状态管理组件pinia

整合状态管理组件 安装整合创建实例挂载使用 pinia 是一个拥有组合式 API 的 Vue 状态管理库。 pinia 官方文档&#xff1a;https://pinia.vuejs.org/zh/introduction.html 安装 yarn add pinia整合 所有与状态相关的文件都放置于项目 src/store 目录下&#xff0c;方便管理 在…
阅读更多...
2021年6月3日 Go生态洞察：Fuzzing技术的Beta测试

2021年6月3日 Go生态洞察：Fuzzing技术的Beta测试

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
电子学会C/C++编程等级考试2023年03月（三级）真题解析

电子学会C/C++编程等级考试2023年03月（三级）真题解析

C/C++等级考试（1~8级）全部真题・点这里 第1题：和数(2023.3) 给定一个正整数序列，判断其中有多少个数，等于数列中其他两个数的和。 比如，对于数列1 2 3 4, 这个问题的答案就是2, 因为3 = 2 + 1, 4 = 1 + 3。 时间限制：10000 内存限制：65536输入 共两行，第一行是数列中…
阅读更多...
8. 队列

8. 队列

队列(queue)是一种遵循先入先出规则的线性数据结构。顾名思义&#xff0c;队列模拟了排队现象&#xff0c;即新来的人不断加入队列的尾部&#xff0c;而位于队列头部的人逐个离开。 如下图所示&#xff0c;我们将队列的头部称为“队首”&#xff0c;尾部称为“队尾”&#xff…
阅读更多...
HuggingFace学习笔记--Model的使用

HuggingFace学习笔记--Model的使用

1--Model介绍 Transformer的 model 一般可以分为&#xff1a;编码器类型&#xff08;自编码&#xff09;、解码器类型&#xff08;自回归&#xff09;和编码器解码器类型&#xff08;序列到序列&#xff09;&#xff1b; Model Head&#xff08;任务头&#xff09;是在base模型…
阅读更多...
Rust UI开发（5）：iced中如何进行页面布局（pick_list的使用）？（串口调试助手）

Rust UI开发（5）：iced中如何进行页面布局（pick_list的使用）？（串口调试助手）

注&#xff1a;此文适合于对rust有一些了解的朋友 iced是一个跨平台的GUI库&#xff0c;用于为rust语言程序构建UI界面。 这是一个系列博文&#xff0c;本文是第五篇&#xff0c;前四篇链接&#xff1a; 1、Rust UI开发&#xff08;一&#xff09;&#xff1a;使用iced构建UI时…
阅读更多...
神经影像和人类基因组关联分析的实践过程

神经影像和人类基因组关联分析的实践过程

神经影像和人类基因组关联分析的实践过程 摘要引言实施步骤1. 阶段1:处理转录图谱数据1.1 步骤1:验证探针到基因的注释1.2 步骤2:过滤探针1.3 步骤3:选择代表性探针1.4 步骤4:将组织样本分配到分块状的大脑区域1.5 步骤5:规范表达测量1.6 步骤6:选择在供体大脑中具有一致表达模…
阅读更多...
MySQL实现（高可用方案-MHA安装及配置）

MySQL实现（高可用方案-MHA安装及配置）

MySQL高可用性解决方案Master High Availability (MHA) 是一种在 MySQL 故障转移环境中实现快速故障转移和数据保护的开源软件。MHA 能在 MySQL 主节点发生故障时&#xff0c;自动将备节点提升为主节点&#xff0c;并且不会中断正在进行的 SQL 操作。 需求&#xff1a;主从配置…
阅读更多...
力扣295. 数据流的中位数（java，堆解法）

力扣295. 数据流的中位数（java，堆解法）

Problem: 295. 数据流的中位数 文章目录 题目描述思路解题方法复杂度Code 题目描述 思路 由于该题目的数据是动态的我们可以维护两个堆来解决该问题 1.维护一个大顶堆&#xff0c;一个小顶堆 2.每个堆中元素个数接近n/2&#xff1b;如果n是偶数&#xff0c;两个堆中的数据个数…
阅读更多...
【UGUI】实现UGUI背包系统的六个主要交互功能

【UGUI】实现UGUI背包系统的六个主要交互功能

在这篇教程中&#xff0c;我们将详细介绍如何在Unity中实现一个背包系统的六个主要功能&#xff1a;添加物品、删除物品、查看物品信息、排序物品、搜索物品和使用物品。让我们开始吧&#xff01; 一、添加物品 首先&#xff0c;我们需要创建一个方法来添加新的物品到背包中。…
阅读更多...
使用开源PolarDB和imgsmlr进行高效的图片存储和相似度搜索

使用开源PolarDB和imgsmlr进行高效的图片存储和相似度搜索

PolarDB的云原生架构提供高性价比的数据存储、可扩展的灵活性、高效的并行计算能力以及快速的数据搜索和处理能力。PolarDB通过结合计算算法&#xff0c;挖掘业务数据的价值&#xff0c;将其转化为生产力。 本文介绍如何使用开源PolarDB和imgsmlr存储图像特征值&#xff0c;并…
阅读更多...
MyBatis的强大特性--动态SQL

MyBatis的强大特性--动态SQL

目录 前言 if trim where set foreach 前言 动态 SQL 是 MyBatis 的强大特性之一。如果你使用过 JDBC 或其它类似的框架&#xff0c;你应该能理解根据不同条件拼接 SQL 语句有多痛苦&#xff0c;例如拼接时要确保不能忘记添加必要的空格&#xff0c;还要注意去掉列表…
阅读更多...
【java】记一次Java应用查询不到最新数据的问题

【java】记一次Java应用查询不到最新数据的问题

文章目录 项目第一次上线前&#xff0c;生产环境调试阶段&#xff0c;项目经理反馈在备机房所在环境验证时报错&#xff1a;id不存在。 我赶紧去排查&#xff0c;查看日志&#xff0c;发现日志里打印的id是旧数据记作A&#xff0c;拿着这个数据去调其他系统提示id不存在。 查看…
阅读更多...
JC/T 2087-2011建筑装饰用仿自然面艺术石检测

JC/T 2087-2011建筑装饰用仿自然面艺术石检测

建筑装饰用仿自然面艺术石是指以硅酸盐水泥、轻质骨料为主要原料经浇筑成型的饰面装饰材料。 JC/T 2087-2011建筑装饰用仿自然面艺术石测试&#xff1a; 测试项目 测试方法 外观质量 GB/T 18601 尺寸偏差 GB/T 18601 体积密度 GB/T 9966.3 吸水率 GB/T 9966.3 压缩强…
阅读更多...
File类

File类

File 概述 File: 路径 IO流: 传输 路径 相对路径, 绝对路径 File File对象就表示一个路径&#xff0c;可以是文件的路径、也可以是文件夹的路径这个路径可以是存在的&#xff0c;也允许是不存在的 构造方法 代码示例: package FileTest1;import java.io.File;public c…
阅读更多...
1+X网络系统建设与运维练习题

1+X网络系统建设与运维练习题

1.OSPF的最优路由&#xff0c;会放到IP路由表中指导数据转发 &#xff08;x&#xff09; 2.当AP工作在2.4GHz频段的时候&#xff0c;AP工作的频率范围是2.4GHz~2.4835GHZ。在此频率范围内又划分出14个信道。每信道的中心频率相隔5MHz&#xff0c;每个信道可供占用的带宽为22MHz…
阅读更多...
最新文章

Copyright @ 2022~2023