redis實(shí)現(xiàn)分布式事務(wù)的方法

小編給大家分享一下redis實(shí)現(xiàn)分布式事務(wù)的方法，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

10年積累的成都網(wǎng)站設(shè)計(jì)、網(wǎng)站制作經(jīng)驗(yàn)，可以快速應(yīng)對(duì)客戶對(duì)網(wǎng)站的新想法和需求。提供各種問題對(duì)應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認(rèn)識(shí)你，你也不認(rèn)識(shí)我。但先網(wǎng)站設(shè)計(jì)后付款的網(wǎng)站建設(shè)流程，更有徐聞免費(fèi)網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。

問題描述:

某電商平臺(tái),首發(fā)一款新品手機(jī),每人限購2臺(tái),預(yù)計(jì)會(huì)有10W的并發(fā),在該情況下,如果扣減庫存,保證不會(huì)超賣

解決方案一

利用數(shù)據(jù)庫鎖機(jī)制,對(duì)記錄進(jìn)行鎖定,再進(jìn)行操作

SELECT * from goods where ID =1 for update;
UPDATE goods set stock = stock - 1;

利用排它鎖將并行轉(zhuǎn)化為串行操作,但該方案的性能和用戶體驗(yàn)較差

解決方案二

利用redis 實(shí)現(xiàn)分布式鎖,

使用setnx命令(在key不存在時(shí),創(chuàng)建并設(shè)置value 返回1,key存在時(shí),會(huì)反回0)來獲取鎖,在業(yè)務(wù)邏輯中,我們可以通過這樣的方案來操作

Jedis client = jedisPool.getResource();
        while(client.setnx("lock",String.valueOf(System.currentTimeMillis())) == 0){
            Thread.sleep(10000);
        }
        //coding here 
       client.del("lock")

方案二進(jìn)階

考慮到死鎖問題,即現(xiàn)成A獲取鎖后,宕機(jī)了,導(dǎo)致鎖一直無法釋放,我們可以通過get命令獲取鎖的時(shí)間戳,通過他進(jìn)行超時(shí)判斷,并進(jìn)行釋放

    Long TIMEOUT_SECOUND = 120000L;
        Jedis client = jedisPool.getResource();
        while(client.setnx("lock",String.valueOf(System.currentTimeMillis())) == 0){
            Long lockTime = Long.valueOf(client.get("lock"));
            if (lockTime!=null && System.currentTimeMillis() > lockTime+TIMEOUT_SECOUND) {
                client.del("lock");
            }
            Thread.sleep(10000);
        }
        ...........................
        ...........................
        client.del("lock")

方案二加強(qiáng)

方案2的算法中,為了確保在非超時(shí)情況下,鎖只能由有鎖的線程進(jìn)行釋放,可以在value的時(shí)間戳中,拼上線程特征碼

    Long TIMEOUT_SECOUND = 120000L;
        String featureCode = "machine01";
        Jedis client = jedisPool.getResource();
        while(client.setnx("lock",featureCode+":"+String.valueOf(System.currentTimeMillis())) == 0){
            Long lockTime = Long.valueOf(client.get("lock").substring(9));
            if (lockTime!=null && System.currentTimeMillis() > lockTime+TIMEOUT_SECOUND) {
                client.del("lock");
            }
            Thread.sleep(10000);
        }
        ...........................
        ...........................
        if (featureCode.equals(client.get("lock").substring(0, 8))) {
            client.del("lock");
        }

以上是redis實(shí)現(xiàn)分布式事務(wù)的方法的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道！

標(biāo)題名稱：redis實(shí)現(xiàn)分布式事務(wù)的方法
鏈接地址：http://muchs.cn/article46/pgogeg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站維護(hù)、搜索引擎優(yōu)化、網(wǎng)站改版、App開發(fā)、全網(wǎng)營銷推廣、品牌網(wǎng)站建設(shè)

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源：創(chuàng)新互聯(lián)

猜你還喜歡下面的內(nèi)容