PHP如何基於redis的分散式鎖防止高並行重複請求

2020-07-16 10:05:51

需求:

我們先舉個某系統驗證的列子:(A渠道系統,業務B系統,外部廠商C系統)

(1)B業務系統呼叫A渠道系統,驗證傳入的手機、身份證、姓名三要素是否一致。

(2)A渠道系統再呼叫外部廠商C系統。

(3)A渠道系統將結果返回給B業務系統。

這3個過程中,(2)過程,呼叫外部廠商是需要計費的。

當B業務系統併行量很高時,有100筆相同的三要素校驗,由於是相同的三要素,A渠道只要呼叫一次廠商即可知道結果。為了防止在某一請求還沒響應結束的同時,其他請求也去呼叫外部系統,這個時候就需要加鎖處理

分散式鎖的特點

 ● 原子性:同一時刻,只能有一個機器的一個執行緒得到鎖;

 ● 可重入性:同一物件(如執行緒、類)可以重複、遞回呼叫該鎖而不發生死鎖;

 ● 可阻塞:在沒有獲得鎖之前,只能阻塞等待直至獲得鎖;

 ● 高可用:哪怕發生程式故障、機器損壞,鎖仍然能夠得到被獲取、被釋放;

 ● 高效能:獲取、釋放鎖的操作消耗小。

要實現:加鎖,減鎖,鎖超時

實現方式可以是:資料庫 mc redis 系統檔案 zookeeper

我現在就是渠道系統,當100個相同的業務請求傳遞過來,我的第一個請求要先加鎖,然後請求外部廠商系統,等響應結果以後,插入另一個key中,然後再刪除鎖。

其他請求先去獲取下鎖,如果已經存在鎖就輪尋等待,如果鎖不在了,直接去查詢結果。

如果第一個請求失敗了,結果並沒有插入到位,就繼續獲取鎖再去查詢外部系統。

獲取鎖:

$redis->set('lock:手機號&身份證&姓名', 1, ['nx', 'ex'=>10]);

釋放鎖:

就是直接刪除這個key

鎖超時:

lock的key有超時時間

新版的redis set命令就可以實現分散式鎖,可以同時實現如果不存在時才去set和超時時間兩項。


<?php
$redis=new Redis();
$redis->connect("127.0.0.1",6379);
//高並行時防止重複請求

//渠道系統傳遞過來的key
$lockKey='lock:18806767777&37781991111629092&taoshihan';
$resultKey='res:18806767777&37781991111629092&taoshihan';

//如果已經查詢過值,可以直接返回
$info=$redis->get($resultKey);
if($info){
    exit($info);
}

//如果沒有值的,獲取鎖
$lock=$redis->set($lockKey, 1, ['nx', 'ex'=>10]);
if($lock){
    //請求外部系統獲取結果,比如響應結果比較慢
    sleep(8);
    $info='{"name":"taoshihan"}';
    $ret=$redis->set($resultKey,$info);
    if($ret){
        //刪除鎖
        $redis->del($lockKey);
        exit($info);
    }
}
echo "請稍後重試!";

推薦學習:PHP教學

以上就是PHP如何基於redis的分散式鎖防止高並行重複請求的詳細內容,更多請關注TW511.COM其它相關文章!