【springboot】使用redisson分布式锁

redisson是基于redis之上的一款极具高性能、使用更便捷的综合中间件组件,本文记录使用redisson的分布式锁。前面介绍过使用redis实现的分布式锁:基于单节点redis实现分布式锁

通常情况下redis都是集群部署的(这里不区分主从、哨兵、集群),在集群中通过setnx,del操作需要考虑更多的问题(如高并发下redis集群数据同步问题,集群宕机的问题等),正确的处理锁的安全性及活性,需要更复杂的操作,而使用redisson可以轻松搞定这一切。
下面使用redisson测试一下分布式锁的效果,引入pom依赖:

<dependency>
   <groupId>org.redisson</groupId>
   <artifactId>redisson</artifactId>
   <version>3.12.5</version>
</dependency>

本文使用springboot2,初始化redisson实例:

@Data
@Configuration
@ConfigurationProperties(prefix = "spring.redisson")
public class RedissonConfig {
   private String host;
   private String password;
   private int connectTimeout;
   @Bean
   public RedissonClient redissonClient(){
       Config config = new Config();
       config.setTransportMode(TransportMode.NIO);

       config.useSingleServer().setAddress(host)

        .setPassword(password).setConnectTimeout(connectTimeout);
       return

       return Redisson.create(config);
   }
}

相关yml属性如下(简略配置):

spring:
 redisson:
   host: redis://127.0.0.1:6379
   password: redis5
   connection-timeout: 5000

最后,测试验证一下基于单点redis分布式锁中的案例:

@GetMapping("hello")
public String hello() {
   CountDownLatch latch = new CountDownLatch(1000);
   RLock lock = redissonClient.getLock(KEY);
   for (int i = 0; i < 1000; i++) {
       new Thread(() -> {
           boolean res = false;
           try {
               res = lock.tryLock(100, 10, TimeUnit.SECONDS);
               if(res){
                   amount--;
               }
           }finally{
               lock.unlock();
           }
           latch.countDown();
       }).start();
   }
   latch.await();
   return "amount:" + amount;
}

多次测试数据正确无误,且请求处理效率要较之前的单点redis分布式锁更高效,编码更少,操作更简单。redisson强大之处远不止于分布式锁,还包括分布式集合、分布式对象、数据分片等,相关文档说明可参见:

redisson wiki

https://github.com/redisson/redisson/wiki


上一篇:Redisson


下一篇:VUE处理 组件赋值 watch 监听不到赋值问题