php解決多進(jìn)程同時(shí)寫(xiě)一個(gè)文件的方法:首先復(fù)制需要更新的文件,并更改文件名;然后檢查最后更新時(shí)間和先前所保存的時(shí)間是否一致;最后將所修改的臨時(shí)文件重命名到原文件。
php解決多進(jìn)程同時(shí)寫(xiě)一個(gè)文件的方法:
首先PHP是支持進(jìn)程的而不支持多線程(這個(gè)先搞清楚了),如果是對(duì)于文件操作,其實(shí)你只需要給文件加鎖就能解決,不需要其它操作,PHP的flock已經(jīng)幫你搞定了。
用flock在寫(xiě)文件前先鎖上,等寫(xiě)完后解鎖,這樣就實(shí)現(xiàn)了多線程同時(shí)讀寫(xiě)一個(gè)文件避免沖突。大概就是下面這個(gè)流程
/* *flock(file,lock,block) *file 必需,規(guī)定要鎖定或釋放的已打開(kāi)的文件 *lock 必需。規(guī)定要使用哪種鎖定類(lèi)型。 *block 可選。若設(shè)置為 1 或 true,則當(dāng)進(jìn)行鎖定時(shí)阻擋其他進(jìn)程。 *lock *LOCK_SH 要取得共享鎖定(讀取的程序) *LOCK_EX 要取得獨(dú)占鎖定(寫(xiě)入的程序) *LOCK_UN 要釋放鎖定(無(wú)論共享或獨(dú)占) *LOCK_NB 如果不希望 flock() 在鎖定時(shí)堵塞 /* if (flock($file,LOCK_EX)) { fwrite($file,'write more words'); flock($file,LOCK_UN); } else { //處理錯(cuò)誤邏輯 } fclose($file); )
相關(guān)學(xué)習(xí)推薦:PHP編程從入門(mén)到精通
方案:不使用flock函數(shù),借用臨時(shí)文件來(lái)解決讀寫(xiě)沖突的問(wèn)題。
大致原理如下:
(1)將需要更新的文件考慮一份到我們的臨時(shí)文件目錄,將文件最后修改時(shí)間保存到一個(gè)變量,并為這個(gè)臨時(shí)文件取一個(gè)隨機(jī)的,不容易重復(fù)的文件名。
(2)當(dāng)對(duì)這個(gè)臨時(shí)文件進(jìn)行更新后,再檢測(cè)原文件的最后更新時(shí)間和先前所保存的時(shí)間是否一致。
(3)如果最后一次修改時(shí)間一致,就將所修改的臨時(shí)文件重命名到原文件,為了確保文件狀態(tài)同步更新,所以需要清除一下文件狀態(tài)。
(4)但是,如果最后一次修改時(shí)間和先前所保存的一致,這說(shuō)明在這期間,原文件已經(jīng)被修改過(guò),這時(shí),需要把臨時(shí)文件刪除,然后返回false,說(shuō)明文件這時(shí)有其它進(jìn)程在進(jìn)行操作。
實(shí)現(xiàn)代碼如下:
代碼如下:
$dir_fileopen='tmp'; function randomid(){ return time().substr(md5(microtime()),0,rand(5,12)); } function cfopen($filename,$mode){ global $dir_fileopen; clearstatcache(); do{ $id=md5(randomid(rand(),TRUE)); $tempfilename=$dir_fileopen.'/'.$id.md5($filename); } while(file_exists($tempfilename)); if(file_exists($filename)){ $newfile=false; copy($filename,$tempfilename); }else{ $newfile=true; } $fp=fopen($tempfilename,$mode); return $fp?array($fp,$filename,$id,@filemtime($filename)):false; } function cfwrite($fp,$string){ return fwrite($fp[0],$string); } function cfclose($fp,$debug='off'){ global $dir_fileopen; $success=fclose($fp[0]); clearstatcache(); $tempfilename=$dir_fileopen.'/'.$fp[2].md5($fp[1]); if((@filemtime($fp[1])==$fp[3])||($fp[4]==true&&!file_exists($fp[1]))||$fp[5]==true){ rename($tempfilename,$fp[1]); }else{ unlink($tempfilename); //說(shuō)明有其它進(jìn)程 在操作目標(biāo)文件,當(dāng)前進(jìn)程被拒絕 $success=false; } return $success; } $fp=cfopen('lock.txt','a+'); cfwrite($fp,"welcome to beijing.n"); fclose($fp,'on');
對(duì)于上面的代碼所使用的函數(shù),需要說(shuō)明一下:
(1)rename();
重命名一個(gè)文件或一個(gè)目錄,該函數(shù)其實(shí)更像linux里的mv。更新文件或者目錄的路徑或名字很方便。但當(dāng)我在window測(cè)試上面代碼時(shí),如果新文件名已經(jīng)存在,會(huì)給出一個(gè)notice,說(shuō)當(dāng)前文件已經(jīng)存在。但在linux下工作的很好。
(2)clearstatcache();
清除文件的狀態(tài).php將緩存所有文件屬性信息,以提供更高的性能,但有時(shí),多進(jìn)程在對(duì)文件進(jìn)行刪除或者更新操作時(shí),php沒(méi)來(lái)得及更新緩存里的文件屬性,容易導(dǎo)致訪問(wèn)到最后更新時(shí)間不是真實(shí)的數(shù)據(jù)。所以這里需要使用該函數(shù)對(duì)已保存的緩存進(jìn)行清除。