最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

redis深入淺出分布式鎖實(shí)現(xiàn)下篇

 更新時(shí)間:2022年08月30日 17:10:40   作者:一個(gè)風(fēng)輕云淡  
在單體應(yīng)用中,如果我們對(duì)共享數(shù)據(jù)不進(jìn)行加鎖操作,會(huì)出現(xiàn)數(shù)據(jù)一致性問題,我們的解決辦法通常是加鎖。下面我們一起聊聊使用redis來實(shí)現(xiàn)分布式鎖

優(yōu)化之UUID防誤刪

問題:刪除操作缺乏原子性。

場(chǎng)景:

index1執(zhí)行刪除時(shí),查詢到的lock值確實(shí)和uuid相等

uuid=v1

set(lock,uuid);

index1執(zhí)行刪除前,lock剛好過期時(shí)間已到,被redis自動(dòng)釋放,在redis中沒有了lock,沒有了鎖。

index2獲取了lock

index2線程獲取到了cpu的資源,開始執(zhí)行方法

uuid=v2

set(lock,uuid);

index1執(zhí)行刪除,此時(shí)會(huì)把index2的lock刪除

index1 因?yàn)橐呀?jīng)在方法中了,所以不需要重新上鎖。index1有執(zhí)行的權(quán)限。index1已經(jīng)比較完成了,這個(gè)時(shí)候,開始執(zhí)行

刪除的index2的鎖!

優(yōu)化之LUA腳本保證刪除的原子性

@GetMapping("testLockLua")
public void testLockLua() {
    //1 聲明一個(gè)uuid ,將做為一個(gè)value 放入我們的key所對(duì)應(yīng)的值中
    String uuid = UUID.randomUUID().toString();
    //2 定義一個(gè)鎖:lua 腳本可以使用同一把鎖,來實(shí)現(xiàn)刪除!
    String skuId = "25"; // 訪問skuId 為25號(hào)的商品 100008348542
    String locKey = "lock:" + skuId; // 鎖住的是每個(gè)商品的數(shù)據(jù)
   // 3 獲取鎖
    Boolean lock = redisTemplate.opsForValue().setIfAbsent(locKey, uuid, 3, TimeUnit.SECONDS);
    // 第一種: lock 與過期時(shí)間中間不寫任何的代碼。
    // redisTemplate.expire("lock",10, TimeUnit.SECONDS);//設(shè)置過期時(shí)間
    // 如果true
    if (lock) {
        // 執(zhí)行的業(yè)務(wù)邏輯開始
        // 獲取緩存中的num 數(shù)據(jù)
        Object value = redisTemplate.opsForValue().get("num");
        // 如果是空直接返回
        if (StringUtils.isEmpty(value)) {
            return;
        }
        // 不是空 如果說在這出現(xiàn)了異常! 那么delete 就刪除失??! 也就是說鎖永遠(yuǎn)存在!
        int num = Integer.parseInt(value + "");
        // 使num 每次+1 放入緩存
        redisTemplate.opsForValue().set("num", String.valueOf(++num));
        /*使用lua腳本來鎖*/
        // 定義lua 腳本
        String script = "if redis.call('get', KEYS[1]) == ARGV[1] then return redis.call('del', KEYS[1]) else return 0 end";
        // 使用redis執(zhí)行l(wèi)ua執(zhí)行
        DefaultRedisScript<Long> redisScript = new DefaultRedisScript<>();
        redisScript.setScriptText(script);
        // 設(shè)置一下返回值類型 為L(zhǎng)ong
        // 因?yàn)閯h除判斷的時(shí)候,返回的0,給其封裝為數(shù)據(jù)類型。如果不封裝那么默認(rèn)返回String 類型,
        // 那么返回字符串與0 會(huì)有發(fā)生錯(cuò)誤。
        redisScript.setResultType(Long.class);
        // 第一個(gè)要是script 腳本 ,第二個(gè)需要判斷的key,第三個(gè)就是key所對(duì)應(yīng)的值。
        redisTemplate.execute(redisScript, Arrays.asList(locKey), uuid);
    } else {
        // 其他線程等待
        try {
            // 睡眠
            Thread.sleep(1000);
            // 睡醒了之后,調(diào)用方法。
            testLockLua();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Lua 腳本詳解:

項(xiàng)目中正確使用

定義key,key應(yīng)該是為每個(gè)sku定義的,也就是每個(gè)sku有一把鎖。

String locKey ="lock:"+skuId; // 鎖住的是每個(gè)商品的數(shù)據(jù)
Boolean lock = redisTemplate.opsForValue().setIfAbsent(locKey, uuid,3,TimeUnit.SECONDS);

總結(jié)

加鎖

使用lua釋放鎖

重試

為了確保分布式鎖可用,我們至少要確保鎖的實(shí)現(xiàn)同時(shí)滿足以下四個(gè)條件:

- 互斥性。在任意時(shí)刻,只有一個(gè)客戶端能持有鎖。

- 不會(huì)發(fā)生死鎖。即使有一個(gè)客戶端在持有鎖的期間崩潰而沒有主動(dòng)解鎖,也能保證后續(xù)其他客戶端能加鎖。

- 解鈴還須系鈴人。加鎖和解鎖必須是同一個(gè)客戶端,客戶端自己不能把別人加的鎖給解了。

- 加鎖和解鎖必須具有原子性

到此這篇關(guān)于redis深入淺出分布式鎖實(shí)現(xiàn)下篇的文章就介紹到這了,更多相關(guān)redis分布式鎖內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!

相關(guān)文章

最新評(píng)論

专栏| 项城市| 蚌埠市| 衡水市| 丰宁| 湖州市| 图们市| 龙游县| 湖州市| 洱源县| 玛多县| 湘潭市| 历史| 阜阳市| 乌鲁木齐县| 桦南县| 赣州市| 武威市| 东海县| 雅江县| 深泽县| 长岭县| 肥城市| 罗定市| 衡南县| 金溪县| 华容县| 宝鸡市| 小金县| 苏尼特右旗| 沈阳市| 玉门市| 镇雄县| 宁陵县| 河北区| 秦安县| 大洼县| 周口市| 浦县| 呼图壁县| 姚安县|