SpringBoot中如何使用Redisson实现分布式锁

本篇文章为大家展示了SpringBoot中如何使用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-productredis:port: 6379host: 127.0.0.1password:database: 0timeout: 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: 5000threads: 0nettyThreads: 0codec: !<org.redisson.codec.JsonJacksonCodec> {}transportMode : "NIO"

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

/*** @Description //TODO* @Date $ $* @Author huangwb**/@Configurationpublic 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、编写一个秒杀接口

@Autowiredprivate RedissonClient redissonClient; @Overridepublic 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性能测试

上述内容就是SpringBoot中如何使用Redisson实现分布式锁，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注创新互联行业资讯频道。

文章名称：SpringBoot中如何使用Redisson实现分布式锁
文章转载：https://www.cdcxhl.com/article24/pdphje.html

成都网站建设公司_创新互联，为您提供企业建站、网站导航、虚拟主机、网站制作、、App设计

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容