Redisson 主從一致性問題詳解

2022-08-26 14:01:21

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 主從一致的資料請關注it145.com其它相關文章！

Redisson 主從一致性問題詳解

目錄

Redisson 主從一致性

Java 實現 mutilLock

RedissonConfig.java

TestRedisson.java

熱門文章