這篇文章主要介紹了PHP 檔案鎖定與進程鎖的使用範例，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟著小編過來看看吧
1.檔案鎖定
flock()
fclose()
swoole_lock()
檔案鎖定的可能應用場景為:
1.限制並發多進程或多台伺服器需要對相同檔案進行存取和修改;
2.對參與檔案I/O的進程隊列化和人為阻塞;
3.在業務邏輯中對文件內容進行守護;
下面是文件鎖定C/S通訊機制下的使用,已經省略了具體的通訊過程
Server(伺服器通訊過程已略):
//监听数据发送事件
$serv->on('receive', function ($serv, $fd, $from_id, $data) {
$serv->send($fd, "ServerEnd");
$p_file = "locktest.txt";
var_dump(file_get_contents($p_file));
});#Client1(伺服器通訊程序已略為):
#
$s_recv = "ww"; $p_file = "locktest.txt"; $o_file = fopen($p_file,'w+'); // flock()加锁方式: flock($o_file,LOCK_EX); // // swoole加锁方式: // $lock = new swoole_lock(SWOOLE_FILELOCK, $p_file); // $lock->lock(); fwrite($o_file, 'ss' . $s_recv); sleep(30); // 两种解锁方式 // flock($o_file, LOCK_UN); // $lock->unlock();
$s_recv = "xx"; $p_file = "locktest.txt"; $o_file = fopen($p_file,'w+'); // flock()加锁方式: flock($o_file,LOCK_EX); // // swoole加锁方式: // $lock = new swoole_lock(SWOOLE_FILELOCK, $p_file); // $lock->lock(); fwrite($o_file, 'ss' . $s_recv); // 两种解锁方式 // flock($o_file, LOCK_UN); // $lock->unlock();
結果:
Client2被阻塞了30s,直到Client1執行結束才對檔案進行了一次寫入;#[l0.16@4 m29.5% c30s04] $ php swoole_client2.php
需要注意的是:
1.無論是flock()還是swoole提供的swoole_lock(),都有在進程結束時自動解鎖的機制,所以在demo中即使不進行手動解鎖也能正常運行,因此這裡在第一個Client中執行了sleep( )暫停函數來觀察檔案鎖的效果;
2.flock()的標準釋放方式為flock($file,LOCK_UN);, 但是個人喜歡fclose(),永絕後患;2.進程鎖
與檔案鎖不同的是,進程鎖並不用來阻止對檔案的I/O,而是用來防止多進程並發造成的預期之外的後果.所以需要在多進程並發時將其隊列化,即在某進程的關鍵邏輯執行結束前阻塞其他並發進程的邏輯執行.
實作想法有幾種:
$p_file = "locktest.txt";
$o_file = fopen($p_file, 'w+');
// 如果临时文件被锁定,这里的flock()将返回false
if (!flock($o_file, LOCK_EX + LOCK_NB)) {
var_dump('Process Locked');
}
else {
// 非阻塞模型必须在flock()中增加LOCK_NB参数
// 当然,这里取消LOCK_NB参数就是阻塞模型了
flock($o_file, LOCK_EX + LOCK_NB);
var_dump('Process Locking');
// 模拟长时间的执行操作
sleep(10);
}傳遞變數的方法很多,這裡只提供一個思路,就以memcached為例;
阻塞模型demo:
// 初始化memcached
$memcached = new Memcache;
$memcached->connect("localhost", 11211);
// 获取用来做状态判定的全局变量
$s_flag = $memcached->get("flag");
if (!$s_flag) {
// 这里利用了memcached的过期时间作为演示,实际上业务处理完成后销毁该变量即可
$memcached->set("flag", "locked", 0, 10);
main();
}
else {
// 阻塞模型
while ($s_flag == 'locked') {
var_dump('Process locked, retrying...');
// 设置重试时间, 避免过于频繁的操作尝试
sleep(1);
// 更新状态变量
$s_flag = $memcached->get("flag");
}
// // 非阻塞模型
// if ($s_flag == 'locked') {
// var_dump('Process locked, suspended');
// die();
// }
main();
}
// 模拟业务主函数
function main() {
var_dump('Process Running');
// 业务执行结束后回收memcached
// $memcached->delete("flag");
}
#這裡要注意的是:
1.memcached的過期時間不可少於程式運行的實際時間,因此建議稍微長一點,邏輯執行結束後進行回收;2.在非阻塞模型中,若狀態被判定為false,應該將進程中止或block,避免業務邏輯的繼續執行;
檔案鎖定解決高並發
####### ##PHP使用###檔案鎖定###解決高並發步驟詳解###########################以上是PHP 實作檔案鎖與進程鎖的詳細內容。更多資訊請關注PHP中文網其他相關文章！
