14251104246 / Redis Demo
spring boot高并发秒杀测试
Stars: ✭ 64
Programming Languages
java
68154 projects - #9 most used programming language
Labels
Projects that are alternatives of or similar to Redis Demo
Boot React
A starter application with spring boot and react
Stars: ✭ 605 (+845.31%)
Mutual labels: redis, spring-boot
Febs Shiro
Spring Boot 2.4.2,Shiro1.6.0 & Layui 2.5.6 权限管理系统。预览地址:http://47.104.70.138:8080/login
Stars: ✭ 5,655 (+8735.94%)
Mutual labels: redis, spring-boot
Shirojwt
API SpringBoot + Shiro + Java-Jwt + Redis(Jedis)
Stars: ✭ 503 (+685.94%)
Mutual labels: redis, spring-boot
Taroco
整合Nacos、Spring Cloud Alibaba,提供了一系列starter组件, 同时提供服务治理、服务监控、OAuth2权限认证,支持服务降级/熔断、服务权重,前端采用vue+elementUI+webpack,可以很好的解决转向Spring Cloud的一系列问题。
Stars: ✭ 545 (+751.56%)
Mutual labels: redis, spring-boot
Mica
Spring Cloud 微服务开发核心工具集。工具类、验证码、http、redis、ip2region、xss 等,开箱即用。 🔝 🔝 记得右上角点个star 关注更新!
Stars: ✭ 749 (+1070.31%)
Mutual labels: redis, spring-boot
Spring Boot Study
SpringBoot框架源码实战(已更新到springboot2版本实现)~基本用法,Rest,Controller,事件监听,连接数据库MySQL,jpa,redis集成,mybatis集成(声明式与xml两种方式~对应的添删查改功能),日志处理,devtools配置,拦截器用法,资源配置读取,测试集成,Web层实现请求映射,security安全验证,rabbitMq集成,kafka集成,分布式id生成器等。项目实战:https://github.com/hemin1003/yfax-parent 已投入生产线上使用
Stars: ✭ 440 (+587.5%)
Mutual labels: redis, spring-boot
Springbootunity
rabbitmq、redis、scheduled、socket、mongodb、Swagger2、spring data jpa、Thymeleaf、freemarker etc. (muti module spring boot project) (with spring boot framework,different bussiness scence with different technology。)
Stars: ✭ 845 (+1220.31%)
Mutual labels: redis, spring-boot
Goods Seckill
高性能电商秒杀解决方案,redis预减库存,消息队列异步下单,订单防重,订单防刷,秒杀接口地址隐藏,数学公式验证码
Stars: ✭ 61 (-4.69%)
Mutual labels: redis, spring-boot
Springboot Project
这是一个用SpringBoot+JPA打造的基于微信服务号平台的点餐系统的后端,前端是一个使用Vue.js构建的运行于微信公众号的WebApp。前后端完全分离,前后端之间通过RESTful风格的接口相连。
Stars: ✭ 1,034 (+1515.63%)
Mutual labels: redis, spring-boot
Uexam
学之思在线考试系统,支持多种题型:选择题、多选题、判断题、填空题、解答题以及数学公式,包含PC端、小程序端,扩展性强,部署方便、界面设计友好、代码结构清晰
Stars: ✭ 473 (+639.06%)
Mutual labels: redis, spring-boot
Spring Boot Klock Starter
基于redis的分布式锁组件,简单方便快捷接入项目,使项目拥有分布式锁能力
Stars: ✭ 546 (+753.13%)
Mutual labels: redis, spring-boot
Testcontainers Spring Boot
Container auto-configurations for spring-boot based integration tests
Stars: ✭ 460 (+618.75%)
Mutual labels: redis, spring-boot
Spring boot
Spring Boot 使用总结 和 demo。 如果您觉得本代码对您有所帮助,请点击页面右上方"Star"
Stars: ✭ 431 (+573.44%)
Mutual labels: redis, spring-boot
Redis Admin
redis client tool,redis web client,redis web ui,spring-boot support
Stars: ✭ 436 (+581.25%)
Mutual labels: redis, spring-boot
redis高并发秒杀测试
准备
- 使用
docker-compose
命令启动redis服务器(可以用其他方式启动) - idea启动测试项目
- jmeter测试脚本
重现秒杀时出现的超卖问题
- 核心测试代码如下:
/**
* 用于测试redis秒杀
*/
@RestController
@RequestMapping("/api/spike")
@Slf4j
public class SpikeController {
@Resource(name = "stringRedisTemplate")
private StringRedisTemplate stringRedisTemplate;
@Autowired
private RedissonClient redissonClient;
//记录实际卖出的商品数量
private AtomicInteger successNum = new AtomicInteger(0);
@RequestMapping(value = "/initSku", method = RequestMethod.GET)
public String initSku() {
//初始化库存数量
stringRedisTemplate.opsForValue().set("product_sku", "5");
//初始化实际卖出的商品数量0
successNum.set(0);
return "初始化库存成功";
}
/**
* 会出现超卖情况的减少库存方式
* @return
*/
@RequestMapping(value = "/reduceSku", method = RequestMethod.GET)
public String reduceSku() {
Integer sku = Integer.parseInt(stringRedisTemplate.opsForValue().get("product_sku"));
sku = sku - 1;
if (sku < 0) {
return "库存不足";
}
stringRedisTemplate.opsForValue().set("product_sku", sku.toString());
//记录实际卖出的商品数量
return "减少库存成功,共减少" + successNum.incrementAndGet();
}
@RequestMapping(value = "/successNum", method = RequestMethod.GET)
public String successNum() {
return "顾客成功抢到的商品数量:" + successNum.get();
}
}
- 测试api:
API{初始化库存数量} >> http://127.0.0.1:8090/api/spike/initSku
API{减少库存数量} >> http://127.0.0.1:8090/api/spike/reduceSku
API{查看共减少库存数量} >> http://127.0.0.1:8090/api/spike/successNum
-
第一个api用于:初始化库存中的商品数量为5
-
第二个api用于:减少库存1个商品(即客户购买一个商品)
-
第三个api用于:查看用户实际购买的商品
-
少量用户请求的情况展示:
- redis数据库中商品库存记录,结果为5
- 查看用户实际购买的商品,结果为0
- 客户购买5次商品(调用5次
减少库存数量
api),下面只列出3个图
-
客户继续购买(继续调用
减少库存数量
api)时,会提示库存不足 -
再次查看redis数据库中商品库存记录,结果为0
- 再次查看用户实际购买的商品,结果为5
-
大量用户请求的情况(高并发秒杀)展示
- redis数据库中商品库存记录,结果为5
- 查看用户实际购买的商品,结果为0
- 使用jmeter打开测试脚本,可以看到基本配置如下
- jmeter并发配置如下(当用户数达到 1000 的时候才开始测试)
-
点击jmeter的
start
按钮,开始1000个并发请求 -
再次查看redis数据库中商品库存记录,结果为0
- 注意:再次查看用户实际购买的商品,结果超过5,出现超卖情况!!!
超卖问题原因分析
- 从上面测试结果,我们知道,高并发请求
http://127.0.0.1:8090/api/spike/reduceSku
,会出现超卖的情况 - 下面我们看下超卖问题的原因
/**
* 会出现超卖情况的减少库存方式
* @return
*/
@RequestMapping(value = "/reduceSku", method = RequestMethod.GET)
public String reduceSku() {
Integer sku = Integer.parseInt(stringRedisTemplate.opsForValue().get("product_sku"));
sku = sku - 1;
if (sku < 0) {
return "库存不足";
}
stringRedisTemplate.opsForValue().set("product_sku", sku.toString());
//记录实际卖出的商品数量
return "减少库存成功,共减少" + successNum.incrementAndGet();
}
- 从代码片可以看出,问题原因是库存数量
sku
的读和写操作不在同一个原子操作上,导致类似不可重复读
的现象。可以类比多线程的问题。
通过redis事务解决超卖问题
使用redis原生的sdk
- 如下改造
reduceSku()
方法,作为一个新接口http://127.0.0.1:8090/api/spike/reduceSku3
/**
* 加入事务的减少库存方式
* @return
*/
@RequestMapping(value = "/reduceSku3", method = RequestMethod.GET)
public String reduceSku3() {
Jedis jedis = new Jedis("127.0.0.1", 6379);
List<Object> result ;
Transaction transaction = null;
try {
jedis.watch("product_sku");
int sku = Integer.parseInt(jedis.get("product_sku"));
if (sku > 0) {
transaction = jedis.multi();
transaction.set("product_sku", String.valueOf(sku - 1));
// int exp = 1/0;
result = transaction.exec();
if (result == null || result.isEmpty()) {
System.out.println("Transaction error...");// 可能是watch-key被外部修改,或者是数据操作被驳回
// transaction.discard(); //watch-key被外部修改时,discard操作会被自动触发
return "Transaction error...";
}
} else {
return "库存不足";
}
return "减少库存成功,共减少" + successNum.incrementAndGet();
} catch (Exception e) {
log.error(e.getMessage());
transaction.discard();
return "fail";
}
}
-
大量用户请求
reduceSku3
接口的情况(高并发秒杀)展示- redis数据库中商品库存记录,结果为5
- 查看用户实际购买的商品,结果为0
- 使用jmeter打开测试脚本,可以看到基本配置如下
- jmeter并发配置如下(当用户数达到 1000 的时候才开始测试)
-
点击jmeter的
start
按钮,开始1000个并发请求 -
再次查看redis数据库中商品库存记录,结果为0
- 注意:再次查看用户实际购买的商品,结果为5,超卖情况消失
-
上面是直接用redis原生的sdk对象
jredis
执行的事务
redisTemplate
执行事务
spring的- 注意: 若要使用spring的
redisTemplate
执行事务,需要在开启事务后执行一个redis的查询操作(但不能使用查询到的值)。原因有两点:- spring对redis事务的
exec()
方法返回结果做了处理(把返回值的OK
结果删掉)。- 导致在事务中只有
set
等更新操作时,事务执行失败与成功返回的结果一样
- 导致在事务中只有
- 事务过程中查询redis的值只会在事务执行成功后才放回。而在事务执行过程中只会返回
null
- spring对redis事务的
- 接口
http://127.0.0.1:8090/api/spike/reduceSku3
是使用spring的redisTemplate
执行事务的例子。代码如下
@RequestMapping(value = "/reduceSku2", method = RequestMethod.GET)
public String reduceSku2() {
stringRedisTemplate.setEnableTransactionSupport(true);
List<Object> results = stringRedisTemplate.execute(new SessionCallback<List<Object>>() {
@Override
public List<Object> execute(RedisOperations operations) throws DataAccessException {
operations.watch("product_sku");
String product_sku = (String) operations.opsForValue().get("product_sku");
operations.multi();
operations.opsForValue().get("product_sku");//必要的空查询
Integer sku = Integer.parseInt(product_sku);
sku = sku - 1;
if (sku < 0) {
return null;
}
operations.opsForValue().set("product_sku", sku.toString());
return operations.exec();
// operations.unwatch(); //执行exec()后自动unwatch()
}
});
if (results != null && results.size() > 0) {
return "减少库存成功,共减少" + successNum.incrementAndGet();
}
return "库存不足";
// return result.toString();
}
- 测试结果为:成功解决超卖问题
- 不再另外贴图片出来
redisTemplate
执行事务(使用zset
)
spring的- 接口
http://127.0.0.1:8090/api/set/reduceSku
是使用zset
的方式
@RequestMapping(value = "/reduceSku", method = RequestMethod.GET)
public String reduceSku5(String pid) {
pid = pid==null? String.valueOf(1) :pid;
String finalPid = pid;
List<Object> results = redisTemplate.execute(new SessionCallback<List<Object>>() {
@Override
public List<Object> execute(RedisOperations redisOperations) throws DataAccessException {
String key = "product";
redisOperations.watch(key);
ZSetOperations<String, String> kvzSetOperations = redisOperations.opsForZSet();
Object score = kvzSetOperations.score(key, finalPid);
redisOperations.multi();
if (score != null && Double.valueOf(score.toString()) > 0) {
kvzSetOperations.incrementScore("product", finalPid, -1);
}
return redisOperations.exec();
}
});
if (results != null && results.size() > 0) {
return "减少库存成功,共减少" + successNum.incrementAndGet();
}
return "库存不足";
}
- 测试结果为:成功解决超卖问题
- 不再另外贴图片出来
通过加锁方式解决超卖问题
- 如下改造
reduceSku()
方法,作为一个新接口http://127.0.0.1:8090/api/spike/reduceSku4
@RequestMapping(value = "/reduceSku4", method = RequestMethod.GET)
public String reduceSku4() {
RLock rLock = redissonClient.getLock("product_sku");
try {
rLock.lock();
Integer sku = Integer.parseInt(stringRedisTemplate.opsForValue().get("product_sku"));
sku = sku - 1;
if (sku < 0) {
return "库存不足";
}
stringRedisTemplate.opsForValue().set("product_sku", sku.toString());
return "减少库存成功,共减少" + successNum.incrementAndGet();
} finally {
rLock.unlock();
}
}
- 测试结果为:成功解决超卖问题
- 不再另外贴图片出来
Note that the project description data, including the texts, logos, images, and/or trademarks,
for each open source project belongs to its rightful owner.
If you wish to add or remove any projects, please contact us at [email protected].