1.主类,for循环模拟1000个线程进行秒杀
import redis.clients.jedis.Jedis;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class Application {
//创建线程池
public static ThreadPoolExecutor pool= new ThreadPoolExecutor(
10,100,10, TimeUnit.SECONDS,
new LinkedBlockingDeque<Runnable>()
);
public static void main(String[] args) {
//jedis操作redis,连接配置信息,本地连接
Jedis jedis = new Jedis("localhost", 6379);
//登录redis密码
jedis.auth("abc123456");
//选择操作库
jedis.select(1);
//设置秒杀商品和库存
jedis.set("kill_num", "50");
//删除上一次的秒杀用户信息,然后再次调用该方法时,记录新的秒杀用户信息ID。
jedis.del("kill_list");
//关闭连接
jedis.close();
//for循环,模拟秒杀环境,1000个线程任务
for (int i = 0; i < 1000; i++) {
//线程任务加入到线程池里面
pool.execute(new KillTask());
}
}
}
2.秒杀任务类
import redis.clients.jedis.Jedis;
import redis.clients.jedis.Transaction;
public class KillTask implements Runnable{
@Override
public void run() {
Jedis jedis = new Jedis("localhost", 6379);
jedis.auth("abc123456");
jedis.select(1);
//watch监控key,获得数据的版本号
jedis.watch("kill_num", "kill_list");
int num = Integer.parseInt(jedis.get("kill_num"));
//判断库存
if (num > 0) {
//开启事务
Transaction transaction = jedis.multi();
transaction.decr("kill_num");//库存减一
transaction.rpush("kill_list", "9527");//记录用户ID,自己写的是9527
transaction.exec();//提交事务
}
else {
Application.pool.shutdown();
}
jedis.close();
}
}
3.运行主类时,需要开启redis->start.bat,然后运行成功后,打开redis客户端查看(需要连接),如下图:
因为使用redis的是db1数据库,所以查看db1数据库:
然后查看kill_num,此时键值是0,没有出现超买的现象:
最后查看kill_list,秒杀列表中出现秒杀商品的数量为50个,当初我们设置的也是50个商品数量。因为我们是写死的用户信息ID,所有都是9527这个用户:
好了,使用redis避免了商品秒杀的超卖问题!