SpringBoot如何通过Redisson在秒杀系统中高效实现分布式锁？
- 内容介绍
- 文章标签
- 相关推荐
本文共计999个文字，预计阅读时间需要4分钟。
Redis分布式锁的实现在Redisson中得到了扩展和优化。Redisson的分布式锁提供了更加丰富的功能和更易用的API。Redisson的分布式锁不仅支持基本的锁定和解锁操作，还支持锁的租约、监听器等功能，使得在分布式环境下使用锁更加灵活和安全。
Redisson的分布式锁使用Redis的SET命令来实现锁的锁定和解锁。以下是Redisson分布式锁的基本使用方法：
java// 获取锁RLock lock=redisson.getLock(anyLock);
// 尝试获取锁，最多等待100秒，上锁以后10秒自动解锁RLock lock=redisson.getLock(anyLock).tryLock(100, 10, TimeUnit.SECONDS);
// 锁定资源try { // ... 执行业务逻辑} finally { // 释放锁 lock.unlock();}
Redisson的分布式锁相较于Redis原生锁，提供了以下优势：
1. 租约过期自动解锁：如果客户端在持有锁的期间崩溃，Redisson会自动在锁到期后释放锁。
2.可重入：支持可重入锁，即同一个线程可以多次获取同一个锁。
3.公平锁：支持公平锁，确保按照请求锁的顺序获取锁。
4.锁监听器：支持锁监听器，当锁被释放时，可以立即得到通知。
Redis的官方也推荐使用Redisson来处理分布式锁，因为它提供了更加全面和易用的解决方案。
前面讲完了Redis的分布式锁的实现，接下来讲Redisson的分布式锁的实现，一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁，Redis的官方也是建议我们这样去做的。Redisson点我可以直接跳转到Redisson的官方文档。
1.1、引入Maven依赖
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.10.6</version> </dependency>
注意：我这里引入的是redisson和springboot的集成包，网上一些教程可能是引入如下配置
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.6.1</version> </dependency>
如果你引入的就是redisson的依赖包，如果该依赖包的版本低于3.5会需要你再引入
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.25.Final</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.9.0</version> </dependency>
这样的一些依赖。
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: !<org.redisson.codec.JsonJacksonCodec> {} 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做接口测试
ab -n 300 -c 300请求地址
-n的含义就是你做多少个请求
-c的含义就是多少个用户并发请求
数据库中的商品已经全部被秒杀完并未出现超库存的情况。
如果对ab不是太了解可以看看这篇文章：使用Apache ab进行http性能测试
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持易盾网络。
本文共计999个文字，预计阅读时间需要4分钟。
Redis分布式锁的实现在Redisson中得到了扩展和优化。Redisson的分布式锁提供了更加丰富的功能和更易用的API。Redisson的分布式锁不仅支持基本的锁定和解锁操作，还支持锁的租约、监听器等功能，使得在分布式环境下使用锁更加灵活和安全。
Redisson的分布式锁使用Redis的SET命令来实现锁的锁定和解锁。以下是Redisson分布式锁的基本使用方法：
java// 获取锁RLock lock=redisson.getLock(anyLock);
// 尝试获取锁，最多等待100秒，上锁以后10秒自动解锁RLock lock=redisson.getLock(anyLock).tryLock(100, 10, TimeUnit.SECONDS);
// 锁定资源try { // ... 执行业务逻辑} finally { // 释放锁 lock.unlock();}
Redisson的分布式锁相较于Redis原生锁，提供了以下优势：
1. 租约过期自动解锁：如果客户端在持有锁的期间崩溃，Redisson会自动在锁到期后释放锁。
2.可重入：支持可重入锁，即同一个线程可以多次获取同一个锁。
3.公平锁：支持公平锁，确保按照请求锁的顺序获取锁。
4.锁监听器：支持锁监听器，当锁被释放时，可以立即得到通知。
Redis的官方也推荐使用Redisson来处理分布式锁，因为它提供了更加全面和易用的解决方案。
前面讲完了Redis的分布式锁的实现，接下来讲Redisson的分布式锁的实现，一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁，Redis的官方也是建议我们这样去做的。Redisson点我可以直接跳转到Redisson的官方文档。
1.1、引入Maven依赖
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson-spring-boot-starter</artifactId> <version>3.10.6</version> </dependency>
注意：我这里引入的是redisson和springboot的集成包，网上一些教程可能是引入如下配置
<dependency> <groupId>org.redisson</groupId> <artifactId>redisson</artifactId> <version>3.6.1</version> </dependency>
如果你引入的就是redisson的依赖包，如果该依赖包的版本低于3.5会需要你再引入
<dependency> <groupId>io.netty</groupId> <artifactId>netty-all</artifactId> <version>4.1.25.Final</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <version>2.9.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <version>2.9.0</version> </dependency>
这样的一些依赖。
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: !<org.redisson.codec.JsonJacksonCodec> {} 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做接口测试
ab -n 300 -c 300请求地址
-n的含义就是你做多少个请求
-c的含义就是多少个用户并发请求
数据库中的商品已经全部被秒杀完并未出现超库存的情况。
如果对ab不是太了解可以看看这篇文章：使用Apache ab进行http性能测试
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持易盾网络。