Redisson 主從一致性問題詳解
Redisson 主從一致性
- 我們先來說一下 Redis 的主從模式,
Redis Master
(主節點)中處理所有發向 Redis 的寫操作(增刪改),Redis Slave
(從節點)隻負責處理讀操作,主節點會不斷將自己的數據同步給從節點,確保主從之間的數據一致性,但是數據同步會存在一定的延時,主從一致性問題就是因為延時而導致的 - 比如我們通過
set lock thread1 nx ex 10
來獲取鎖,主節點就會保存這個鎖的標識 thread1,然後主節點會向從節點進行同步,但在同步尚未完成時時主節點發生故障,Redis 哨兵發現主節點宕機後,客戶端連接會斷開,然後從從節點中選出一個作為新的主節點,但是由於之前主從同步未完成,即 thread1 這個鎖已經丟失,所以此時 Java 應用再來訪問新的主節點時就會發現鎖失效瞭,此時其他線程來獲取鎖時也能獲取成功,這時就可能出現並發安全問題,以上就是主從一致性導致的鎖失效問題 - 那麼 Redisson 是如何解決上述問題的呢?既然導致主從一致性問題發生的主要原因是主從同步延時問題,Redisson 幹脆直接舍棄瞭主從節點,所有 Redis 節點都是獨立的節點,相互之間無任何關系,都可以做讀寫操作。此時,我們想獲取鎖就必須依次向多個 Redis 都去獲取鎖(之前直接向 Master 節點獲取就可以),多個 Redis 節點都保存鎖的標識,才算獲取成功
- 這樣一來,由於所有節點都是獨立的,所以避免瞭主從一致性問題;又由於所有的節點都保存瞭鎖標識,即使由一個節點宕機,其他的節點也保存有鎖的標識,保證瞭高可用,並且可用性會隨著節點的增多而增高
- 此外,我們還以為給這些獨立的節點再加上從節點 Slave,即使一個獨立節點宕機瞭導致其對應的從節點變成新的主節點,且節點上鎖標識丟失瞭也沒有關系,因為我們隻有在每一個節點都拿到鎖才算成功, 盡管可以在這個空虛的節點上獲取到鎖,但在其他節點上是獲取不到的,最終仍然是失敗,因此隻要有任意一個節點存貨,其他線程就不可能拿到鎖,就不會出現鎖失效問題。這樣,既保留瞭主從同步機制,又確保瞭 Redis 集群的高可用特性,同時還避免瞭主從一致所引發的鎖失效問題,這個方案就叫做
mutilLock
Java 實現 mutilLock
RedissonConfig.java
package com.hmdp.config; import org.redisson.Redisson; import org.redisson.api.RedissonClient; import org.redisson.config.Config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RedissonConfig { @Bean public RedissonClient redissonClient() { // 配置 Config config = new Config(); // 地址 & 密碼 config.useSingleServer().setAddress("redis://ip:端口").setPassword("pwd"); // 創建 RedissonClient 對象 return Redisson.create(config); } @Bean public RedissonClient redissonClient2() { // 配置 Config config = new Config(); // 地址 & 密碼 config.useSingleServer().setAddress("redis://ip:端口").setPassword("pwd"); // 創建 RedissonClient 對象 return Redisson.create(config); } @Bean public RedissonClient redissonClient3() { // 配置 Config config = new Config(); // 地址 & 密碼 config.useSingleServer().setAddress("redis://ip:端口").setPassword("pwd"); // 創建 RedissonClient 對象 return Redisson.create(config); } }
TestRedisson.java
package com.hmdp; import lombok.extern.slf4j.Slf4j; import org.junit.jupiter.api.BeforeEach; import org.junit.jupiter.api.Test; import org.redisson.api.RLock; import org.redisson.api.RedissonClient; import org.springframework.boot.test.context.SpringBootTest; import javax.annotation.Resource; import java.util.concurrent.TimeUnit; @Slf4j @SpringBootTest public class TestRedisson { @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"); // 創建連鎖 multiLock lock = redissonClient.getMultiLock(lock1, lock2, lock3); } @Test void method1() throws InterruptedException { // 嘗試獲取鎖 boolean isLock = lock.tryLock(1L, TimeUnit.SECONDS); if (!isLock) { log.error("獲取鎖失敗 .... 1"); return; } try { log.info("獲取鎖成功 .... 1"); method2(); log.info("開始執行業務 .... 1"); } finally { log.warn("準備釋放鎖 .... 1"); lock.unlock(); } } void method2() { // 嘗試獲取鎖 boolean isLock = lock.tryLock(); if (!isLock) { log.error("獲取鎖失敗 .... 2"); return; } try { log.info("獲取鎖成功 .... 2"); log.info("開始執行業務 .... 2"); } finally { log.warn("準備釋放鎖 .... 2"); lock.unlock(); } } }
跟蹤源碼,我們發現隻有所有的鎖都獲取成功瞭才會返回 true
以上就是Redisson 主從一致性問題詳解的詳細內容,更多關於Redisson 主從一致的資料請關註WalkonNet其它相關文章!
推薦閱讀:
- Java Redis Redisson配置教程詳解
- Redisson實現Redis分佈式鎖的幾種方式
- redisson分佈式鎖的用法大全
- SpringBoot整合Redisson的步驟(單機版)
- Redis分佈式鎖之紅鎖的實現