《PHP應用:Redis構建分布式鎖》要點:
本文介紹了PHP應用:Redis構建分布式鎖,希望對您有用。如果有疑問,可以聯系我們。
PHP學習1、前言
PHP學習為什么要構建鎖呢?因為構建合適的鎖可以在高并發下能夠保持數據的一致性,即客戶端在執行連貫的命令時上鎖的數據不會被別的客戶端的更改而發生錯誤.同時還能夠保證命令執行的成功率.
PHP學習看到這里你不禁要問redis中不是有事務操作么?事務操作不能夠實現上面的功能么?
PHP學習的確,redis中的事務可以watch可以監控數據,從而能夠保證連貫執行的時數據的一致性,但是我們必須清楚的認識到,在多個客戶端同時處理相同的數據的時候,很容易導致事務的執行失敗,甚至會導致數據的出錯.
PHP學習在關系型數據庫中,用戶首先向數據庫服務器發送BEGIN,然后執行各個相互一致的寫操作和讀操作,最后用戶可以選擇發送COMMIT來確認之前的修改,或者發送ROLLBACK進行回滾.
PHP學習在redis中,通過特殊的命令MULTI為開始,之后用戶傳入一連貫的命令,最后EXEC為結束(在這一過程中可以使用watch進行監控一些key).進一步分析,redis事務中的命令會先推入隊列,等到EXEC命令出現的時候才會將一條條命令執行.假若watch監控的key發生改變,這個事務將會失敗.這也就說明Redis事務中不存在鎖,其他客戶端可以修改正在執行事務中的有關數據,這也就為什么在多個客戶端同時處理相同的數據時事務往往會發生錯誤.
PHP學習2、簡單理解redis的單線程IO多路復用
PHP學習Redis采用單線程IO多路復用模型來實現高內存數據服務.何為單線程IO多路復用呢?從字面的意思可以知道redis采用的是單線程、使用的是多個IO.整個過程簡單的來講就是,哪個命令的數據流先到達就先執行.
PHP學習請看下面的形象理解圖:圖中是一座窄橋,只能允許一輛車通過,左邊是車輛進入的通道,哪一輛車先到達就先進入.即哪個IO流先到達就先處理哪個.
PHP學習Linux下網絡IO使用socket套接字來通訊,普通IO模型只能監聽一個socket,而IO多路復用可同時監控多個socket.IO多路復用避免阻塞在IO上,單線程保存多個socket的狀態后輪循處理.
PHP學習
PHP學習3、并發測試
PHP學習我們就模擬一個簡單典型的并發測試,然后從這個測試中得出問題,再進一步研究.
PHP學習并發測試思路:
PHP學習1、在redis中設置一個字符串count,運用程序將其取出來加+1,再存儲回去,一直循環十萬次
PHP學習2、在兩個瀏覽器上同時執行這個代碼
PHP學習3、將count取出來,查看結果
PHP學習測試步驟:
PHP學習1、建立test.php文件
PHP學習
<?php
$redis=new Redis();
$redis->connect('192.168.95.11','6379');
for ($i=0; $i < 100000; $i++)
{
$count=$redis->get('count');
$count=$count+1;
$redis->set('count',$count);
}
echo "this OK";
?>
PHP學習2、分別在兩個瀏覽器中訪問test.php文件
PHP學習
PHP學習結果由上圖可知,總共執行兩次,count原本應該是二十萬才對的,但實際上count等于十三萬多,遠遠小于二十萬,這是為什么呢?
PHP學習由前面的內容可知,redis是采用單線程IO多路復用模型的.因此我們使用兩個瀏覽器即為兩個會話(A、B),取出、加1、存入這三個命令并不是原子操作,并且在執行取出、存入這兩個redis命令時是哪個客戶端先到就先執行.
PHP學習例如:
PHP學習1、此時count=120
PHP學習2、A取出count=120,緊接著B的取出命令流到了,也將count=120取出
PHP學習3、A取出后立即加1,并將count=121存回去
PHP學習4、此時B也緊跟著,也將count=121存進去了
PHP學習注意:
PHP學習1、設置循環次數盡量大一點,太小的話,當在第一個瀏覽器執行完畢,第二個瀏覽器還沒開始進行呢
PHP學習2、必須要兩個瀏覽器同時執行.假若在一個瀏覽器中同時執行兩次test.php文件,不管是否同時執行,最終結果就是count=200000.因為在同一個瀏覽器中執行,都是屬于同一個會話(所有命令都在同一個通道通過),所以redis會讓先執行的十萬次執行完,再接著執行其他的十萬次.
PHP學習4、事務解決與原子性操作解決
PHP學習4.1、事務解決
PHP學習更改后的test.php文件
PHP學習
<?php
header("content-type: text/html;charset=utf8;");
$start=time();
$redis=new Redis();
$redis->connect('192.168.95.11','6379');
for ($i=0; $i < 100000; $i++)
{
$redis->multi();
$count=$redis->get('count');
$count=$count+1;
$redis->set('count',$count);
$redis->exec();
}
$end=time();
echo "this OK<br/>";
echo "執行時間為:".($end-$start);
?>
PHP學習執行結果失敗,表名使用事務不能夠解決此問題.
PHP學習
PHP學習分析原因:
PHP學習我們都知道當redis開啟時,事務中的命令是不執行的,而是先將命令壓入隊列,然后當出現exec命令的時候,才會阻塞式的將所有的命令一個接一個的執行.
PHP學習所以當使用PHP中的Redis類進行redis事務的時候,所有有關redis的命令都不會真正的執行,而僅僅是將命令發送到redis中進行存儲起來.
PHP學習因此下圖中所圈到的$count實際上不是我們想要的數據,而是一個對象,因此test.php中11行出錯.
PHP學習
PHP學習查看對象count:
PHP學習
PHP學習
PHP學習4.2、原子性操作incr解決
PHP學習#更新test.php文件
PHP學習
<?php
header("content-type: text/html;charset=utf8;");
$start=time();
$redis=new Redis();
$redis->connect('192.168.95.11','6379');
for ($i=0; $i < 100000; $i++)
{
$count=$redis->incr('count');
}
$end=time();
echo "this OK<br/>";
echo "執行時間為:".($end-$start);
?>
PHP學習兩個瀏覽器同時執行,耗時14、15秒,count=200000,可以解決此問題.
PHP學習缺點:
PHP學習僅僅只是解決這里的取出加1的問題,本質上還是沒能解決問題的,在實際環境中,我們需要做的是一系列操作,不僅僅只是取出加1,因此就很有必要構建一個萬能鎖了.
PHP學習5、構建分布式鎖
PHP學習我們構造鎖的目的就是在高并發下消除選擇競爭、保持數據一致性
PHP學習構造鎖的時候,我們需要注意幾個問題:
PHP學習1、預防處理持有鎖在執行操作的時候進程奔潰,導致死鎖,其他進程一直得不到此鎖
PHP學習2、持有鎖進程因為操作時間長而導致鎖自動釋放,但本身進程并不知道,最后錯誤的釋放其他進程的鎖
PHP學習3、一個進程鎖過期后,其他多個進程同時嘗試獲取鎖,并且都成功獲得鎖
PHP學習我們將不對test.php文件修改了,而是直接建立一個相對比較規范的面向對象Lock.class.php類文件
PHP學習#建立Lock.class,php文件
PHP學習
<?php
#分布式鎖
class Lock
{
private $redis=''; #存儲redis對象
/**
* @desc 構造函數
*
* @param $host string | redis主機
* @param $port int | 端口
*/
public function __construct($host,$port=6379)
{
$this->redis=new Redis();
$this->redis->connect($host,$port);
}
/**
* @desc 加鎖方法
*
* @param $lockName string | 鎖的名字
* @param $timeout int | 鎖的過期時間
*
* @return 成功返回identifier/失敗返回false
*/
public function getLock($lockName, $timeout=2)
{
$identifier=uniqid(); #獲取唯一標識符
$timeout=ceil($timeout); #確保是整數
$end=time()+$timeout;
while(time()<$end) #循環獲取鎖
{
if($this->redis->setnx($lockName, $identifier)) #查看$lockName是否被上鎖
{
$this->redis->expire($lockName, $timeout); #為$lockName設置過期時間,防止死鎖
return $identifier; #返回一維標識符
}
elseif ($this->redis->ttl($lockName)===-1)
{
$this->redis->expire($lockName, $timeout); #檢測是否有設置過期時間,沒有則加上(假設,客戶端A上一步沒能設置時間就進程奔潰了,客戶端B就可檢測出來,并設置時間)
}
usleep(0.001); #停止0.001ms
}
return false;
}
/**
* @desc 釋放鎖
*
* @param $lockName string | 鎖名
* @param $identifier string | 鎖的唯一值
*
* @param bool
*/
public function releaseLock($lockName,$identifier)
{
if($this->redis->get($lockName)==$identifier) #判斷是鎖有沒有被其他客戶端修改
{
$this->redis->multi();
$this->redis->del($lockName); #釋放鎖
$this->redis->exec();
return true;
}
else
{
return false; #其他客戶端修改了鎖,不能刪除別人的鎖
}
}
/**
* @desc 測試
*
* @param $lockName string | 鎖名
*/
public function test($lockName)
{
$start=time();
for ($i=0; $i < 10000; $i++)
{
$identifier=$this->getLock($lockName);
if($identifier)
{
$count=$this->redis->get('count');
$count=$count+1;
$this->redis->set('count',$count);
$this->releaseLock($lockName,$identifier);
}
}
$end=time();
echo "this OK<br/>";
echo "執行時間為:".($end-$start);
}
}
header("content-type: text/html;charset=utf8;");
$obj=new Lock('192.168.95.11');
$obj->test('lock_count');
?>
PHP學習測試結果:
PHP學習在兩個不同的瀏覽器中執行,最終結果count=200000,但是耗時相對較多,需要近八十多秒左右.但是在高并發下,對同一個數據,二十萬次上鎖執行釋放鎖的操作還是可以接受的,甚至已經很不錯了.
PHP學習以上的簡單例子僅僅只是為了模擬并發測試并檢驗而已,實際上我們可以使用Lock.class.php中的鎖結合自己的項目加以修改就可以很好地使用這個鎖了.例如商城中的瘋狂搶購、游戲中虛擬商城玩家買賣東西等等.
PHP學習以上就是本文的全部內容,希望本文的內容對大家的學習或者工作能帶來一定的幫助,同時也希望多多支持維易PHP!