redis怎麼實現分散式事務

問題描述:

某電商平台,首發一款新品手機,每人限購2台,預計會有10W的並發,在該情況下,如果扣減庫存,保證不會超賣

解決方案一

利用資料庫鎖定機制,對記錄進行鎖定,再進行操作

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

利用排它鎖定將並行轉換為序列操作,但此方案的效能和使用者體驗較差

解決方案二

利用redis 實作分散式鎖定,

使用setnx指令(在key不存在時,建立並設定value 回傳1,key存在時,會反回0)來取得鎖定,在業務邏輯中,我們可以透過這樣的方案來操作

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

方案二進階

考慮到死鎖問題,即現成A取得鎖後,宕機了,導致鎖一直無法釋放,我們可以透過get命令獲取鎖的時間戳,透過他進行超時判斷,並進行釋放

    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")

方案二加強

方案2的演算法中,為了確保在非超時情況下,鎖只能由有鎖的線程進行釋放,可以在value的時間戳中,拼上線程特徵碼

    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相關技術文章，請訪問Redis教程欄位進行學習！

#

以上是redis怎麼實現分散式事務的詳細內容。更多資訊請關注PHP中文網其他相關文章！