java redis 商品秒杀_java使用redis模拟高并发秒杀活动

àì夳堔傛蜴生んèń 2022-11-08 15:27 304阅读 0赞

首先配置jedis包

redis.clients

jedis

3.0.1

直接上main方法代码，里面注释已经包含了说明 ：

package com.xh.test;

import java.util.HashMap;

import java.util.Map;

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.LinkedBlockingDeque;

import java.util.concurrent.Semaphore;

import java.util.concurrent.ThreadPoolExecutor;

import java.util.concurrent.TimeUnit;

import redis.clients.jedis.Jedis;

public class Main \{

static Boolean isEmpty = false;

public static void main(String\[\] args) \{

int threadNumber = 500;

int goodsNumber = 50;

// TODO Auto-generated method stub

//线程池，无限缓存线程池

ExecutorService excutor = Executors.newCachedThreadPool();

//连接本地的 Redis 服务

Jedis jedis = new Jedis("localhost");

System.out.println("连接成功");

if(!jedis.exists("goods"))\{

System.out.println("无商品数据，开始添加！");

//插入100个商品

for(int i = 0;i

jedis.lpush("goods", "1");

//TODO 还要保证同一个用户不能秒杀两个

Map map = new HashMap<>();

long length = jedis.llen("goods");

System.out.println("商品剩余数量："+length);

//模拟秒杀代码

CountDownLatch countDown = new CountDownLatch(threadNumber);

for (int i = 0; i < threadNumber; i++) \{

final int index = i;

excutor.execute( () ->\{

System.out.println("用户 "+index+" 开始秒杀商品！");

//如果已经被抢完则直接拒绝后面的请求了。

if(isEmpty)\{

System.out.println("用户"+index+" 抱歉商品已秒杀完毕！");

countDown.countDown();

return;

Jedis checkJedis = new Jedis("localhost");

String result = checkJedis.lpop("goods");

//如果成功删除redis里的数据则表示抢到，如果存储数字则还需要事务控制并修改商品数字，比较影响性能，因此使用list比较好。

if(result!=null&&!result.equals(""))\{

System.out.println("用户 "+ index+" 成功抢到！");

map.put(index+"", result);

\}else\{

//只允许一个线程修改状态

synchronized (isEmpty) \{

isEmpty = true;

System.out.println("用户 "+index+" 很遗憾你没有抢到，商品已秒杀完。");

checkJedis.close();

//表示一个线程执行完毕了

countDown.countDown();

\});

try \{

//等待所有线程执行完毕

countDown.await();

System.out.println("所有用户秒杀完毕，开始公布结果：");

for (String key : map.keySet()) \{

System.out.println("恭喜用户"+key+" 成功抢到！");

System.out.println("共"+map.size()+"位用户成功抢到。");

jedis.close();

\} catch (InterruptedException e) \{

// TODO Auto-generated catch block

e.printStackTrace();

System.out.println("done");

小总结

1、结果来看还是无法模拟真正的高并发，秒杀成功的几乎都是前100个线程，后面启动的400个线程根本没有机会。。。

2、如果使用redis存储数字则还需要事务控制并修改商品数字，比较影响性能，因此使用list比较好。

3、一开始用的时候的低级错误： 每个线程都是直接用最开始new的那个jedis对象，这样做的后果就是一个连接发送大量操作请求，然后请求直接被redis的保护模式拒绝了。。

4、同一用户不能秒杀多个商品的代码未模拟

java redis 商品秒杀_java使用redis模拟高并发秒杀活动

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 redis+zookeeper做商品秒杀

相关 Redis-秒杀

相关 Redis实现商品秒杀

相关高并发--秒杀--Redis

相关使用Redis中间件设计商品秒杀活动（使用Java多线程模拟高并发环境）

相关 redis高并发之秒杀活动解决方案

相关 java redis 商品秒杀_java使用redis模拟高并发秒杀活动

相关秒杀活动

相关 java秒杀高并发------秒杀接口高并发秒杀优化 RabbitMQ模式

相关 redis高并发秒杀测试