使用redisson实现分布式秒杀功能

　　redisson相比原生的jredis具有排队的功能，不一致秒杀时，一时获取锁失败就返回失败。
　　秒杀的原理就是使用redis的分布式锁的功能，保证每次抢购不会出现超卖的情况
　　1 引入pom                      org.redisson             redisson             3.16.8         2 完整代码及解析如下package htmdemo; import com.ruoyi.common.core.redis.RedisCache; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.ArrayList; import java.util.concurrent.*; /**  * 使用redisson来实现分布式的秒杀功能  * @author Administrator  *  */ @Component public class ReddisonTest { 	@Autowired     private RedisCache redisCache;      @Autowired     RedissonClient redissonClient;     /**      * 秒杀      * @throws ExecutionException      * @throws InterruptedException      */     public void secondkill() throws ExecutionException, InterruptedException {      	 //加锁的实现方式         ExecutorService exec = Executors.newFixedThreadPool(50);         ArrayList> futures = new ArrayList<>();         RLock stockLock = redissonClient.getLock(＂stockLock＂);         for (int i = 0; i < 50; i++) {             Future fsubmit = exec.submit(() -> {                 int doneCount = 0;//初始化做的任务为0                 if(stockLock.tryLock(1,1,TimeUnit.SECONDS)){                 	//获取到锁，则做业务                 	                 	/**                 	 * trylock(param1,param2,param3):尝试获取锁                      * @param1:等待时间（在这个时间内不停获取锁）                      * @param2:获取成功后锁的有效时间                      * @param3:时间单位（秒/分/...)                 	*/                 	                     int stock = redisCache.getCacheObject(＂stock＂);                     stock--;                     redisCache.setCacheObject(＂stock＂, stock);                     doneCount++;                     //isHeldByCurrentThread()的作用是查询当前线程是否保持此锁定                     if(stockLock.isHeldByCurrentThread()){                         stockLock.unlock();                     }                 }                 return doneCount;             });             futures.add(fsubmit);         }          Integer saleToal = 0;          for (int i = 0; i < futures.size(); i++) {             Future count = futures.get(i);             saleToal = saleToal + count.get();         }         System.out.println(＂最终的卖出：＂+saleToal);     } }
　　以上的核心代码为//得到锁对象 RLock stockLock = redissonClient.getLock(＂stockLock＂); //尝试获取锁 if(stockLock.tryLock(1,1,TimeUnit.SECONDS))