首先配置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;imap = 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、同一用户不能秒杀多个商品的代码未模拟