PHP使用redis實現(xiàn)分布式鎖的示例詳解
目錄
- 什么是分布式鎖
- 實現(xiàn)原理
- php實現(xiàn)代碼
最近在做一個領(lǐng)券功能的時候，發(fā)現(xiàn)在一定并發(fā)下會出現(xiàn)重復(fù)領(lǐng)券的問題。使用度娘一頓搜索操作之后，發(fā)現(xiàn)可以使用分布式鎖來解決這個問題。
什么是分布式鎖
分布式鎖是控制分布式系統(tǒng)之間同步訪問共享資源的一種方式。在分布式系統(tǒng)中，常常需要協(xié)調(diào)他們的動作。如果不同的系統(tǒng)或是同一個系統(tǒng)的不同主機之間共享了一個或一組資源，那么訪問這些資源的時候，往往需要互斥來防止彼此干擾來保證一致性，這個時候，便需要使用到分布式鎖。
實現(xiàn)原理
實現(xiàn)分布式鎖的原理很簡單，就是需要有一把鎖，多個服務(wù)同時去獲取鎖，但是只有一個服務(wù)能獲取到鎖。獲取到鎖的服務(wù)就可以執(zhí)行自己的業(yè)務(wù)，沒有獲取到鎖的其他服務(wù)需要等待獲取到鎖的服務(wù)業(yè)務(wù)執(zhí)行完成后釋放鎖，然后再次嘗試獲取鎖。
實現(xiàn)分布式的方案有很多種。如下
- 基于數(shù)據(jù)庫實現(xiàn)分布式鎖,比如mysql
- 基于緩存實現(xiàn)分布式鎖，比如redis
- 基于Zookeeper實現(xiàn)分布式鎖
這里我們使用redis來實現(xiàn)分布式鎖,在執(zhí)行業(yè)務(wù)之前先獲取一個key，如果key存在就說明已經(jīng)有其他服務(wù)獲得鎖，這個時候需要等待或者返回系統(tǒng)繁忙。如果key不存在，說明沒有其他服務(wù)獲取鎖，把這個key保存到redis，然后執(zhí)行業(yè)務(wù)，等待業(yè)務(wù)執(zhí)行完就從redis中刪除這個key。
php實現(xiàn)代碼
<?php
class RedisLock
{
protected $redis;
public function __construct(){
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$this->redis = $redis;
}
public function getLock($key){
$value = $this->redis->get($key);
return $value;
}
public function setLock($key,$value){
$this->redis->set($key,$value);
}
public function delLock($key){
$lineNumber = $thid->redis->del($key);
return $lineNumber;
}
}
$key = "your_lock_key";
$value = time();
$redisLock = new RedisLock();
$isLock = $redisLock->get($key);
if($isLock) {
//已有鎖，直接返回,不往下執(zhí)行了
return false;
}
//沒有鎖，加鎖
$redisLock->setLock($key,$value);
//todo 執(zhí)行業(yè)務(wù)邏輯
sleep(5);
// 解鎖
$redisLock->delLock($key);
使用ab進行測試
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖
執(zhí)行業(yè)務(wù)
解鎖
解鎖
執(zhí)行業(yè)務(wù)
解鎖
執(zhí)行業(yè)務(wù)
解鎖
執(zhí)行業(yè)務(wù)
解鎖
解鎖
執(zhí)行業(yè)務(wù)
解鎖
加鎖
執(zhí)行業(yè)務(wù)
解鎖
加鎖
執(zhí)行業(yè)務(wù)
解鎖
從測試結(jié)果來看，發(fā)現(xiàn)有多個執(zhí)行業(yè)務(wù)，并沒有完全鎖住。這個是因為我們用的是redis的set命令。set 命令用于設(shè)置給定 key 的值。如果 key 已經(jīng)存儲其他值， SET 就覆寫舊值，且無視類型。這樣會導(dǎo)致很多服務(wù)都能加鎖成功，而我們想要的是只有一個服務(wù)能加鎖成功。
要解決這個問題，需要了解redis的另一個命令setnx。setnx 命令在指定的 key 不存在時，為 key 設(shè)置指定的值。
<?php
class RedisLock
{
protected $redis;
public function __construct(){
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$this->redis = $redis;
}
public function getLock($key){
$value = $this->redis->get($key);
return $value;
}
public function setLock($key,$value){
return $this->redis->setnx($key,$value);
}
public function delLock($key){
$lineNumber = $thid->redis->del($key);
return $lineNumber;
}
}
$key = "your_lock_key";
$value = time();
$redisLock = new RedisLock();
$isLock = $redisLock->get($key);
if($isLock) {
//已有鎖，直接返回,不往下執(zhí)行了
return false;
}
//沒有鎖，加鎖
$setLock = $redisLock->setLock($key,$value);
if(!$setLock) {
//加鎖失敗
return false;
}
//todo 執(zhí)行業(yè)務(wù)邏輯
sleep(5);
// 解鎖
$redisLock->delLock($key);
再次使用ab進行測試
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖
加鎖失敗
加鎖失敗
加鎖失敗
加鎖失敗
加鎖失敗
已鎖
已鎖
已鎖
執(zhí)行業(yè)務(wù)
解鎖
從測試結(jié)果來看，在未加鎖的狀態(tài)下，有多個服務(wù)同時獲取加鎖，但是只有一個加鎖成功， 其他的都是返回加鎖失敗，再后面的服務(wù)更是直接返回已鎖。由此可見，加鎖成功。
那么到此就結(jié)束了嗎？其實并不是的。假如在已加鎖的情況執(zhí)行業(yè)務(wù)，在業(yè)務(wù)過程中因為一些原因出現(xiàn)異常導(dǎo)致退出而沒有進行解鎖，那么將造成死鎖，后面的所有服務(wù)都無法再次獲取鎖。為了解決這個問題，我們需要對鎖設(shè)置一個過期的時間，防止死鎖的發(fā)生。
<?php
class RedisLock
{
protected $redis;
public function __construct(){
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
$this->redis = $redis;
}
public function getLock($key){
$value = $this->redis->get($key);
return $value;
}
public function setLock($key,$value,$second){
$setnx = $this->redis->setnx($key,$value);
if(!$setnx) {
return $setnx;
}
$expire = $this->redis->expire($key,$second);
if(!$expire) {
$this->redis->del($key);
}
return $expire;
}
public function delLock($key){
$lineNumber = $thid->redis->del($key);
return $lineNumber;
}
}
$key = "your_lock_key";
$value = time();
$redisLock = new RedisLock();
$isLock = $redisLock->get($key);
if($isLock) {
//已有鎖，直接返回,不往下執(zhí)行了
return false;
}
//沒有鎖，加鎖
$second = 5;
$setLock = $redisLock->setLock($key,$value,$second);
if(!$setLock) {
//加鎖失敗
return false;
}
//todo 執(zhí)行業(yè)務(wù)邏輯
sleep(5);
// 解鎖
$redisLock->delLock($key);
以上就是PHP使用redis實現(xiàn)分布式鎖的示例詳解的詳細(xì)內(nèi)容，更多關(guān)于PHP redis分布式鎖的資料請關(guān)注其它相關(guān)文章！
網(wǎng)公網(wǎng)安備