通常情况下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
}
}
相关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