So lösen Sie das Problem des gleichzeitigen Lesens und Schreibens von Dateien in PHP

Im Falle einer hohen Parallelität führt das Betreiben derselben Datei zu Datenverwirrung, sodass beim Betreiben der Datei einige spezielle Verarbeitungen durchgeführt werden müssen. Nachfolgend sind mehrere Lösungen zusammengefasst. Ich hoffe, es hilft allen.

Option 1: Verwenden Sie die Flock-Funktion, um die Datei zu sperren

<span style="font-size: 14px;">/*  <br/>* flock(file,lock,block)  <br/>* file 必需，规定要锁定或释放的已打开的文件  <br/>* lock 必需。规定要使用哪种锁定类型。  <br/>* block 可选。若设置为 1 或 true，则当进行锁定时阻挡其他进程。  <br/>* lock  <br/>* LOCK_SH 要取得共享锁定（读取的程序）  <br/>* LOCK_EX 要取得独占锁定（写入的程序）  <br/>* LOCK_UN 要释放锁定（无论共享或独占）  <br/>* LOCK_NB 如果不希望 flock() 在锁定时堵塞  <br/>/*  <br/><br/>// 获取锁if (flock($file,LOCK_EX)) {    // 操作文件<br/>    fwrite($file,&#39;write more words&#39;);  <br/>    // 操作完毕后释放锁<br/>    flock($file,LOCK_UN);  <br/>} else {  <br/>    //处理错误逻辑  <br/>}  <br/>fclose($file);  <br/></span>

Die Flock-Funktion scheint häufig vorhanden zu sein monopolisiert und nicht sofort oder überhaupt nicht freigegeben, was zu Deadlocks, einer sehr hohen CPU-Auslastung des Servers und manchmal sogar zum vollständigen Abstürzen des Servers führt. Daher kann die einfache Verwendung von Flock zum Sperren das Problem nicht vollständig lösen.

Option 2: Sperrzeit begrenzen und bei Zeitüberschreitung beenden

<span style="font-size: 14px;">if($fp = fopen($fileName,&#39;a&#39;)) {    $startTime = microtime();    do{        $canWrite = flock($fp, LOCK_EX);        if(!$canWrite) {<br/>            usleep(round(rand(0, 100) * 1000));   // 释放cpu，将cpu资源先让给其他进程<br/>        }        // 如果未获取到锁，且未超时，则继续获取锁<br/>    } while((!$canWrite) && ((microtime() - $startTime) < 1000));    if($canWrite) {        fwrite($fp, $dataToSave);<br/>        flock($file,LOCK_UN);  <br/>    }    fclose($fp);<br/>}<br/></span>

Option 3: Temporäre Dateien verwenden

<span style="font-size: 14px;">$dir_fileopen=&#39;tmp&#39;;function cfopen($filename,$mode){<br/>    global $dir_fileopen;<br/>    clearstatcache();    // 创建一个临时文件<br/>    do{        $id=uniqid();        $tempfilename=$dir_fileopen.&#39;/&#39;.$id.md5($filename);<br/>    } while(file_exists($tempfilename));    // 将要操作的文件内容拷贝到临时文件中<br/>    copy($filename,$tempfilename);    $fp = fopen($tempfilename, $mode);    return $fp ? [$fp, $filename, $id, @filemtime($filename)] : false;<br/>}function cfwrite($fp,$string){<br/>    // 将新增内容写入到临时文件中<br/>    return fwrite($fp[0], $string);<br/>}function cfclose($fp){<br/>    global $dir_fileopen;    $success = fclose($fp[0]);<br/>    clearstatcache();    $tempfilename = $dir_fileopen.&#39;/&#39;.$fp[2].md5($fp[1]);    // 如果要操作的文件在操作期间没有被修改过，则说明没有人操作过该文件，那么将临时文件改名为真正的文件<br/>    if((@filemtime($fp[1]) == $fp[3])){<br/>        rename($tempfilename,$fp[1]);<br/>    }else{        //说明有其它进程在操作目标文件，当前进程被拒绝，删除临时文件<br/>        unlink($tempfilename);        $success = false;<br/>    }    return $success;<br/>}$startTime = microtime();do{    $fp=cfopen(&#39;lock.txt&#39;,&#39;a+&#39;);<br/>    cfwrite($fp,"welcome to beijing.\n");    $success = cfclose($fp, &#39;on&#39;);    if(!$success) {<br/>        usleep(round(rand(0, 100) * 1000));   // 释放cpu，将cpu资源先让给其他进程<br/>    }<br/>}while(!$success && ((microtime() - $startTime) < 1000));    // 如果为false，说明操作失败，则重新进行一次操作<br/></span>

Option 4: Verwenden Sie die Warteschlange

, um eine Dateioperationswarteschlange zu erstellen, und schreiben Sie dann ein Skript, um die Dateioperationsinformationen nacheinander aus der Warteschlange zu lesen Verarbeiten Sie dann die Datei. Führen Sie entsprechende Vorgänge aus, sodass jeweils nur ein Prozess die Datei bearbeitet, wodurch das Parallelitätsproblem gelöst wird.

Auf den obigen Inhalt wird verwiesen von: http://blog.csdn.net/daiyan_csdn/article/details/51524781

In high Parallelitätssituationen In diesem Fall führt das Betreiben derselben Datei zu Datenverwirrung, sodass beim Betreiben der Datei eine spezielle Verarbeitung durchgeführt werden muss. Hier sind mehrere Lösungen.

Option 1: Verwenden Sie die Flock-Funktion, um die Datei zu sperren

<span style="font-size: 14px;">/*  <br/>* flock(file,lock,block)  <br/>* file 必需，规定要锁定或释放的已打开的文件  <br/>* lock 必需。规定要使用哪种锁定类型。  <br/>* block 可选。若设置为 1 或 true，则当进行锁定时阻挡其他进程。  <br/>* lock  <br/>* LOCK_SH 要取得共享锁定（读取的程序）  <br/>* LOCK_EX 要取得独占锁定（写入的程序）  <br/>* LOCK_UN 要释放锁定（无论共享或独占）  <br/>* LOCK_NB 如果不希望 flock() 在锁定时堵塞  <br/>/*  <br/><br/>// 获取锁if (flock($file,LOCK_EX)) {    // 操作文件<br/>    fwrite($file,&#39;write more words&#39;);  <br/>    // 操作完毕后释放锁<br/>    flock($file,LOCK_UN);  <br/>} else {  <br/>    //处理错误逻辑  <br/>}  <br/>fclose($file);  <br/></span>

Die Flock-Funktion scheint oft Ressourcen in mehreren gleichzeitigen Situationen zu monopolisieren . , nicht sofort oder überhaupt nicht freigegeben, was zu einem Deadlock führt, der zu einer sehr hohen CPU-Auslastung des Servers und manchmal sogar zum vollständigen Absturz des Servers führt. Daher kann die einfache Verwendung von Flock zum Sperren das Problem nicht vollständig lösen.

Option 2: Sperrzeit begrenzen und bei Zeitüberschreitung beenden

<span style="font-size: 14px;">if($fp = fopen($fileName,&#39;a&#39;)) {    $startTime = microtime();    do{        $canWrite = flock($fp, LOCK_EX);        if(!$canWrite) {<br/>            usleep(round(rand(0, 100) * 1000));   // 释放cpu，将cpu资源先让给其他进程<br/>        }        // 如果未获取到锁，且未超时，则继续获取锁<br/>    } while((!$canWrite) && ((microtime() - $startTime) < 1000));    if($canWrite) {        fwrite($fp, $dataToSave);<br/>        flock($file,LOCK_UN);  <br/>    }    fclose($fp);<br/>}<br/></span>

Option 3: Temporäre Dateien verwenden

<span style="font-size: 14px;">$dir_fileopen=&#39;tmp&#39;;function cfopen($filename,$mode){<br/>    global $dir_fileopen;<br/>    clearstatcache();    // 创建一个临时文件<br/>    do{        $id=uniqid();        $tempfilename=$dir_fileopen.&#39;/&#39;.$id.md5($filename);<br/>    } while(file_exists($tempfilename));    // 将要操作的文件内容拷贝到临时文件中<br/>    copy($filename,$tempfilename);    $fp = fopen($tempfilename, $mode);    return $fp ? [$fp, $filename, $id, @filemtime($filename)] : false;<br/>}function cfwrite($fp,$string){<br/>    // 将新增内容写入到临时文件中<br/>    return fwrite($fp[0], $string);<br/>}function cfclose($fp){<br/>    global $dir_fileopen;    $success = fclose($fp[0]);<br/>    clearstatcache();    $tempfilename = $dir_fileopen.&#39;/&#39;.$fp[2].md5($fp[1]);    // 如果要操作的文件在操作期间没有被修改过，则说明没有人操作过该文件，那么将临时文件改名为真正的文件<br/>    if((@filemtime($fp[1]) == $fp[3])){<br/>        rename($tempfilename,$fp[1]);<br/>    }else{        //说明有其它进程在操作目标文件，当前进程被拒绝，删除临时文件<br/>        unlink($tempfilename);        $success = false;<br/>    }    return $success;<br/>}$startTime = microtime();do{    $fp=cfopen(&#39;lock.txt&#39;,&#39;a+&#39;);<br/>    cfwrite($fp,"welcome to beijing.\n");    $success = cfclose($fp, &#39;on&#39;);    if(!$success) {<br/>        usleep(round(rand(0, 100) * 1000));   // 释放cpu，将cpu资源先让给其他进程<br/>    }<br/>}while(!$success && ((microtime() - $startTime) < 1000));    // 如果为false，说明操作失败，则重新进行一次操作<br/></span>

Option 4: Verwenden Sie die Warteschlange

, um eine Dateioperationswarteschlange zu erstellen, und schreiben Sie dann ein Skript, um die Dateioperationsinformationen nacheinander aus der Warteschlange zu lesen Verarbeiten Sie dann die Datei. Führen Sie entsprechende Vorgänge aus, sodass jeweils nur ein Prozess die Datei bearbeitet, wodurch das Parallelitätsproblem gelöst wird.

Verwandte Empfehlungen:

Lösung des Problems gleichzeitiger PHP-Lese- und Schreibdateikonflikte

Das obige ist der detaillierte Inhalt vonSo lösen Sie das Problem des gleichzeitigen Lesens und Schreibens von Dateien in PHP. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!