springboot简单实现redis商品秒杀功能，成功解决商品超售问题

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数据库：