一、主从一致性问题的产生
Redis 主从集群使用如下:
- 在主节点进行数据的写操作;
- 在节点进行数据的读操作;
- 主节点向从节点同步数据。
主从一致性问题:
当主节点还没来得及将锁信息同步到从节点时,此时主节点宕机了。然后,从节点被设为主节点,这个从节点中无锁信息,因此产生了锁失效问题。
二、multiLock 方案解决
Redisson 提供了 multiLock 方案解决主从一致性问题,其思路如下:
设置多个并列的 Rediss 节点,对锁信息,将其写入每个 Redis 节点中。
-
获取锁时,向多个 Redis 节点中获取锁,只有每个节点都获取锁成功,才算获取锁成功。实现了,只要有一个节点存活,其他线程就不能获取锁,锁不会失效。
-
当其中有节点宕机时,其他节点仍然含有锁信息,其他节点仍然有效
-
multiLock 思路也可搭建主从同步集群,实现了灵活性和高可用性
三、multiLock 的使用
- 配置 Redis 客户端,搭建三个 Redis 节点 (出于简单,未设置主从)
@Configuration
public class RedisConfig {
@Bean
public RedissonClient redissonClient(){
// 配置类
Config config = new Config();
// 设置 redis 地址
config.useSingleServer().setAddress("redis://192.168.244.130:6379");
// 返回
return Redisson.create(config);
}
@Bean
public RedissonClient redissonClient2(){
// 配置类
Config config = new Config();
// 设置 redis 地址
config.useSingleServer().setAddress("redis://192.168.244.131:6379");
// 返回
return Redisson.create(config);
}
@Bean
public RedissonClient redissonClient3(){
// 配置类
Config config = new Config();
// 设置 redis 地址
config.useSingleServer().setAddress("redis://192.168.244.132:6379");
// 返回
return Redisson.create(config);
}
}
- 使用 SpringBoot 提供的测试类进行测试
@Slf4j
@SpringBootTest
class HmDianPingApplicationTests {
// 注入三个 Client
@Resource
private RedissonClient redissonClient;
@Resource
private RedissonClient redissonClient2;
@Resource
private RedissonClient redissonClient3;
private RLock lock;
// 创建连锁
@BeforeEach
void setup() {
RLock lock1 = redissonClient.getLock("order");
RLock lock2 = redissonClient2.getLock("order");
RLock lock3 = redissonClient3.getLock("order");
// 创建连锁 —— 用 redissonClient2、redissonClient3 也行
lock = redissonClient.getMultiLock(lock1, lock2, lock3);
}
// 测试连锁
@Test
public void HmDianPingApplicationTests() throws InterruptedException {
boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS);
if(!isLock){
System.out.println("获取锁失败");
} else{
System.out.println("获取锁成功");
lock.unlock();
}
}
}