SpringBoot使用Redisson实现分布式锁（秒杀系统）

这篇文章主要为大家详细介绍了SpringBoot使用Redisson实现分布式锁，秒杀系统，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下

前面讲完了Redis的分布式锁的实现，接下来讲Redisson的分布式锁的实现，一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁，Redis的官方也是建议我们这样去做的。Redisson点我可以直接跳转到Redisson的官方文档。

1.1、引入Maven依赖

  org.redissonredisson-spring-boot-starter3.10.6

注意：我这里引入的是redisson和springboot的集成包，网上一些教程可能是引入如下配置

  org.redissonredisson3.6.1

如果你引入的就是redisson的依赖包，如果该依赖包的版本低于3.5会需要你再引入

  io.nettynetty-all4.1.25.Final com.fasterxml.jackson.corejackson-core2.9.0 com.fasterxml.jackson.corejackson-databind2.9.0

这样的一些依赖。

1.2、配置redis信息

spring:
  application:
    name: spring-cloud-product
  redis:
    port: 6379
    host: 127.0.0.1
    password:
    database: 0
    timeout: 2000

1.3、配置redisson

新建一个redisson-single.yml的配置文件下面是单机配置

 singleServerConfig: idleConnectionTimeout: 10000 pingTimeout: 1000 connectTimeout: 10000 timeout: 3000 retryAttempts: 3 retryInterval: 1500 reconnectionTimeout: 3000 failedAttempts: 3 password: null subscriptionsPerConnection: 5 clientName: null address: "redis://127.0.0.1:6379" subscriptionConnectionMinimumIdleSize: 1 subscriptionConnectionPoolSize: 50 connectionMinimumIdleSize: 32 connectionPoolSize: 64 database: 0 #在最新版本中dns的检查操作会直接报错 所以我直接注释掉了 #dnsMonitoring: false dnsMonitoringInterval: 5000 threads: 0 nettyThreads: 0 codec: ! {} transportMode : "NIO"

1.4、写一个RedissonConfig配置类来配置你的redisson

 /** * @Description //TODO * @Date $ $ * @Author huangwb **/ @Configuration public class RedssonConfig { @Bean(destroyMethod="shutdown") public RedissonClient redisson() throws IOException { RedissonClient redisson = Redisson.create( Config.fromYAML(new ClassPathResource("redisson-single.yml").getInputStream())); return redisson; } }

1.5、编写一个秒杀接口

 @Autowired private RedissonClient redissonClient; @Override public boolean decrementProductStore(Long productId, Integer productQuantity) { String key = "dec_store_lock_" + productId; RLock lock = redissonClient.getLock(key); try { //加锁 操作很类似Java的ReentrantLock机制 lock.lock(); ProductInfo productInfo = productInfoMapper.selectByPrimaryKey(productId); //如果库存为空 if (productInfo.getProductStock() == 0) { return false; } //简单减库存操作 没有重新写其他接口了 productInfo.setProductStock(productInfo.getProductStock() - 1); productInfoMapper.updateByPrimaryKey(productInfo); } catch (Exception e) { System.out.println(e.getMessage()); } finally { //解锁 lock.unlock(); } return true; }

1.6、写一个简单的测试请求

 @GetMapping("test") public String createOrderTest() { if (!productInfoService.decrementProductStore(1L, 1)) { return "库存不足"; } OrderMaster orderMaster = new OrderMaster(); //未支付 orderMaster.setOrderStatus(0); //未支付 orderMaster.setPayStatus(0); orderMaster.setBuyerName(name); orderMaster.setBuyerAddress("湖南长沙"); orderMaster.setBuyerPhone("18692794847"); orderMaster.setOrderAmount(BigDecimal.ZERO); orderMaster.setCreateTime(DateUtils.getCurrentDate()); orderMaster.setOrderId(UUID.randomUUID().toString().replaceAll("-", "")); orderMasterService.insert(orderMaster); return "创建订单成功"; }

1.7、使用ab做接口测试