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