分布式锁之Redisson入门

蔚落 2023-07-01 15:59 339阅读 0赞

Redisson是一个在Redis的基础上实现的Java驻内存数据网格（In-Memory Data Grid）。它不仅提供了一系列的分布式的Java常用对象，还提供了许多分布式服务。其中包括(BitSet, Set, Multimap, SortedSet, Map, List, Queue, BlockingQueue, Deque, BlockingDeque, Semaphore, Lock, AtomicLong, CountDownLatch, Publish / Subscribe, Bloom filter, Remote service, Spring cache, Executor service, Live Object service, Scheduler service) Redisson提供了使用Redis的最简单和最便捷的方法。Redisson的宗旨是促进使用者对Redis的关注分离（Separation of Concern），从而让使用者能够将精力更集中地放在处理业务逻辑上。

官方文档地址：[https://github.com/redisson/redisson/wiki][https_github.com_redisson_redisson_wiki]

### 3.3.1. 快速入门 ###

1.  引入依赖

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

1.  添加配置

@Configuration
    public class RedissonConfig {
    
        @Bean
        public RedissonClient redissonClient(){
            Config config = new Config();
            // 可以用"rediss://"来启用SSL连接
            config.useSingleServer().setAddress("redis://172.16.116.100:6379");
            return Redisson.create(config);
        }
    }

1.  代码实现

@Autowired
    private RedissonClient redissonClient;
    
    @Override
    public void testLock() {
    
        RLock lock = this.redissonClient.getLock("lock"); // 只要锁的名称相同就是同一把锁
        lock.lock(); // 加锁
    
        // 查询redis中的num值
        String value = this.redisTemplate.opsForValue().get("num");
        // 没有该值return
        if (StringUtils.isBlank(value)) {
            return;
        }
        // 有值就转成成int
        int num = Integer.parseInt(value);
        // 把redis中的num值+1
        this.redisTemplate.opsForValue().set("num", String.valueOf(++num));
    
        lock.unlock(); // 解锁
    }

### 闭锁（CountDownLatch）演示代码(分布式秒杀场景使用) ###

public class IndexController {
    	@Autowired
    	private IndexService indexService;
    
    	@GetMapping("/main")
    	public String testMain() throws InterruptedException {
    		return indexService.testMain();
    	}
    
    	@GetMapping("/sub")
    	public String testSub() {
    		return indexService.testSub();
    	}
    
    }

@Service
    public class IndexService {
    	@Autowired
    	private RedissonClient redissonClient;
    
    	public String testMain() throws InterruptedException {
    		RCountDownLatch latch = this.redissonClient.getCountDownLatch("latch");
    		latch.trySetCount(5L);
    
    		latch.await();
    		return "主业务开始执行";
    
    	}
    
    	public String testSub() {
    		RCountDownLatch latch = this.redissonClient.getCountDownLatch("latch");
    		latch.countDown();
    
    		return "分支业务执行了一次";
    	}
    }

[https_github.com_redisson_redisson_wiki]: https://github.com/redisson/redisson/wiki