一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務器之家:專注于服務器技術及軟件下載分享
分類導航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務器之家 - 編程語言 - PHP教程 - PHP+redis實現的悲觀鎖機制示例

PHP+redis實現的悲觀鎖機制示例

2019-09-27 10:02grey256 PHP教程

這篇文章主要介紹了PHP+redis實現的悲觀鎖機制,簡單介紹了redis鎖機制與樂觀鎖、悲觀鎖等概念,并結合實例形式分析了php+redis實現悲觀鎖相關操作技巧,需要的朋友可以參考下

本文實例講述了PHP+redis實現的悲觀鎖。分享給大家供大家參考,具體如下:

鎖機制

通常使用的鎖分為樂觀鎖,悲觀鎖這兩種,簡單介紹下這兩種鎖,作為本文的背景知識,對這類知識已經有足夠了解的同學可以跳過這部分。

樂觀鎖

先來看下百度百科上的解釋:大多是基于數據版本( Version )記錄機制實現。何謂數據版本?即為數據增加一個版本標識,在基于數據庫表的版本解決方案中,一般是通過為數據庫表增加一個 “version” 字段來實現。讀取出數據時,將此版本號一同讀出,之后更新時,對此版本號加一。此時,將提交數據的版本數據與數據庫表對應記錄的當前版本信息進行比對,如果提交的數據版本號大于數據庫表當前版本號,則予以更新,否則認為是過期數據。

其實說白了,就是好比一個健身房里只有一臺跑步機,在健身房門口有個排號機,每個進健身房的人都得先領一個號碼才能進入,如果跑步機上有人,則在一邊做做熱身、喝喝水,如果跑步機上沒人,則確認跑步機上當前顯示的號碼(上一個用過跑步機的人的號碼)是否比自己手持的小,如果小,則可以使用;否則,就意味著過號,而過號在現實中我們的都知道要么走,要么重排,就是不能插隊,在系統中也是一樣的,通常是返回錯誤。

悲觀鎖

同樣,來看下百度百科的解釋:具有強烈的獨占和排他特性。它指的是對數據被外界(包括本系統當前的其他事務,以及來自外部系統的事務處理)修改持保守態度,因此,在整個數據處理過程中,將數據處于鎖定狀態。悲觀鎖的實現,往往依靠數據庫提供的鎖機制(也只有數據庫層提供的鎖機制才能真正保證數據訪問的排他性,否則,即使在本系統中實現了加鎖機制,也無法保證外部系統不會修改數據)。

然后,也同樣通俗的解釋下,還是那個健身房。這次在門口不需要排號機了,而是掛著把鑰匙(只有一把),想進去的人必須拿到這把鑰匙才行,拿到鑰匙的人可以進入,不管是熱身、喝水還是跑步都可以,直到他出來把鑰匙掛回墻上,下一個才能去爭取,拿到的才可以再進去。聽著好像有點不人性化,所以悲觀鎖比較適合強一致性的場景,但效率比較低,特別是讀的并發低。樂觀鎖則適用于讀多寫少,并發沖突少的場景。

背景

先說下,本文的開發背景,方便大家了解為什么要使用悲觀鎖以及文中鎖的詳細設計。

任務分發系統:任務池(mysql)中存在大量任務(文章),現在需要用戶協助編輯,系統基本需求如下(簡化版):

1、推送用戶感興趣的分類下的任務到用戶編輯器中;
2、用戶編輯提交一個任務后,自動推送下一個任務;
3、每次只分配一個任務給用戶;
4、如果一個用戶占有某任務超過一定時間,則自動釋放任務,任務進任務池,重新循環;
5、……

目標

目標有兩個:

1、一個任務在同一時間段內只能被一個用戶所持有;

2、避免出現死任務,即避免任務被用戶長時間占有,無法釋放。

思路

由于系統并發量較大,并且有頻繁的寫操作,所以選擇悲觀鎖來控制每個任務只能同時被一個用戶領取。主要思路如下:

1、從任務池中找出一部分可分配的任務;
2、根據一定順序,選擇一個任務,作為候選推送任務;
3、嘗試對候選推送任務加鎖;
4、如果加鎖成功,則推送任務給用戶,并修改對應的任務狀態和用戶狀態;
5、如果加鎖失敗,則任務已被領取,重復2-5,直到推送成功。

實現

這里只介紹下鎖的實現機制,其余業務邏輯略過。由于加鎖過程應該是不可拆解的,也就是常說的原子型操作,因此這里選擇redis中的setnx操作作為加鎖的方法。

簡化版的代碼如下:

function lock($strMutex, $intTimeout) {
  $objRedis = new Redis();
  //使用setnx原子型操作加鎖
  $intRet  = $objRedis->setnx($strMutex, 1);
  if ($intRet) {
    //設置過期時間,防止死任務的出現
    $objRedis->expire($strMutex, $intTimeout);
    return true;
  }
  return false;
}

這段代碼有個問題,就是setnx成功,但expire失敗,這就可能存在死任務的情況。解決這個問題的一種通用方法是通過使用incr方法代替setnx,具體如下:

function lock($strMutex, $intTimeout, $intMaxTimes = 0) {
  $objRedis = new Redis();
  //使用incr原子型操作加鎖
  $intRet  = $objRedis->incr($strMutex);
  if ($intRet === 1) {
    //設置過期時間,防止死任務的出現
    $objRedis->expire($strMutex, $intTimeout);
    return true;
  }
  if ($intMaxTimes > 0 && $intRet >= $intMaxTimes && $objRedis->ttl($strMutex) === -1) {
    //當設置了最大加鎖次數時,如果嘗試加鎖次數大于最大加鎖次數并且無過期時間則強制解鎖
    $objRedis->del($strMutex);
  }
  return false;
}

這段代碼通過$intMaxTimes來保證即使在expire未成功的時候也能強制解鎖,保證系統不會出現死任務。

還有沒有更好的方法呢?

其實redis中的set操作已兼容了setnx,并且支持設置過期時間。

function lock($strMutex, $intTimeout) {
  $objRedis = new Redis();
  //使用setnx操作加鎖,同時設置過期時間
  $strRet  = $objRedis->set($strMutex, 1, 'ex', $intTimeout, 'nx');
  if ($strRet === 'OK') {
    return true;
  }
  return false;
}

這個方法是我認為目前最好的,但是為什么沒有直接介紹這個方法,而是先介紹incr那個方法呢?其實細心的同學可以看到上面那個方面有兩個加粗的字”通用“。之所以這么說是因為set方法是從redis2.6.12版本才開始支持多參數的。

水平有限,歡迎指正~

參考資料:http://redisdoc.com/string/set.html

希望本文所述對大家PHP程序設計有所幫助。

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 久久视频精品3线视频在线观看 | 亚洲高清中文字幕 | 国产成人手机在线好好热 | blacked太粗太长| 久久久久影视 | 视频一区国产精戏刘婷 | 人体做爰aaaa免费 | 羞羞漫画视频 | 高清在线观看免费入口 | 手机在线观看精品国产片 | eee在线播放成人免费 | 视频二区 素人 欧美 日韩 | 四虎国产精品免费久久久 | 亚洲网站在线 | 国产suv精品 | 午夜在线播放免费人成无 | 亚洲午夜久久久久国产 | 暖暖免费高清完整版观看日本 | 蜜月aⅴ免费一区二区三区 蜜桃影像传媒推广 | 色噜噜视频影院 | 美女模特被c免费视频 | 丁香婷婷在线视频 | 九九精品视频在线观看 | 能看的毛片网站 | 小sao货水好多真紧h的视频 | 秋霞在线观看成人高清视频51 | 国产香蕉97碰碰久久人人 | 免费抽搐一进一出印度 | 99久久国产综合精麻豆 | 国产一卡二卡3卡4卡四卡在线 | 五月天色小说 | 69老司机亚洲精品一区 | 国产亚洲精品久久yy5099 | 含羞草国产亚洲精品岁国产精品 | japanesqirl日本护士 | 91麻豆精品激情在线观看最新 | 天天做天天爱天天操 | 欧美日韩在线观看精品 | 欧美 变态 另类 人妖班 | 天天爽天天操 | 亚洲精品成人在线 |