首頁 >後端開發 >php教程 >php使用Redis實作防止大並發下二次寫入的方法

php使用Redis實作防止大並發下二次寫入的方法

黄舟
黄舟原創
2017-10-10 09:16:531801瀏覽

這篇文章主要介紹了PHP使用Redis實現防止大並發下二次寫入的方法,結合實例形式分析了php使用鎖機制實現並發讀寫redis情況下的讀寫錯誤,需要的朋友可以參考下

本文實例講述了PHP使用Redis實作防止大並發下二次寫入的方法。分享給大家供大家參考,具體如下:

PHP呼叫redis進行讀寫操作,大並發下會出現:讀取key1,沒有內容則寫入內容,但是大並發下會出現同時多個php進程寫入的情況,這個時候需要加一個鎖,也就是取得鎖的php進程有權限寫入。


$lock_key = 'LOCK_PREFIX' . $redis_key;
$is_lock = $redis->setnx($lock_key, 1); // 加锁
if($is_lock == true){ // 获取锁权限
  $redis->setex($redis_key, $expire, $data); // 写入内容
  // 释放锁
  $redis->del($lock_key);
}else{
  return true; // 获取不到锁权限,直接返回
}

思路是:設定一個鎖的key,setnx是原子操作,只能一個行程寫入成功,寫入成功回傳true(表示取得鎖定權限),然後寫入內容再釋放鎖定即刪除鎖定key。取得不到鎖的進程直接返回。但是這裡有種情況,取得鎖權限的進程,取得鎖後運行報錯了,導致沒有釋放鎖,那麼一直就不能寫入內容,這時就需要拿不到鎖權限的進程去判斷鎖的剩餘有效時間,如果為-1則設定鎖的有效時間為5秒(預留5秒給拿到鎖的進程的運作時間,足夠多了)。改良後的程式碼:


$lock_key = 'LOCK_PREFIX' . $redis_key;
$is_lock = $redis->setnx($lock_key, 1); // 加锁
if($is_lock == true){ // 获取锁权限
  $redis->setex($redis_key, $expire, $data); // 写入内容
  // 释放锁
  $redis->del($lock_key);
}else{
  // 防止死锁
  if($redis->ttl($lock_key) == -1){
    $redis->expire($lock_key, 5);
  }
  return true; // 获取不到锁权限,直接返回
}

以上是php使用Redis實作防止大並發下二次寫入的方法的詳細內容。更多資訊請關注PHP中文網其他相關文章!

陳述:
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn