這篇文章主要介紹了PHP 檔案鎖定與進程鎖的使用範例,小編覺得挺不錯的,現在分享給大家,也給大家做個參考。一起跟著小編過來看看吧
鑑於前面介紹了swoole,就藉用swoole的伺服器/客戶端與多進程機制對鎖進行說明.
這裡只針對PHP的鎖定機制進行說明,由於SQL的鎖定與其作用方式和應用場景不同,將作另行說明.
#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();
Client2(伺服器通訊過程已略):
$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
2.flock()的標準釋放方式為flock($file,LOCK_UN);, 但是個人喜歡fclose(),永絕後患;
2.進程鎖
實作想法有幾種:
1.利用flock()檔鎖,建立一個臨時lock檔,使用LOCK_NB模擬阻塞或非阻塞流,再在行程內部使用判定條件控制邏輯執行;非阻塞模型demo:
$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"); }
以上是簡單介紹PHP 檔案鎖與進程鎖的詳細內容。更多資訊請關注PHP中文網其他相關文章!