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
3.3.1. 快速入门
-
引入依赖
<dependency>
<groupId>org.redisson</groupId>
<artifactId>redisson</artifactId>
<version>3.11.2</version>
</dependency>
-
添加配置
@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);
}
}
-
代码实现
@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 "分支业务执行了一次";
}
}