Asynchrone, nicht blockierende PHP-Implementierungsmethode

Um zu verhindern, dass PHP bei der Verarbeitung langfristiger Aufgaben im Backend blockiert und schnell auf Seitenanfragen reagiert, können folgende Maßnahmen ergriffen werden:

1. Verwenden Sie fastcgi_finish_request()

Wenn PHP und der Webserver PHP-FPM (FastCGI Process Manager) verwenden, kann die Sitzung über die Funktion fastcgi_finish_request() sofort beendet werden und der PHP-Thread kann im Hintergrund weiterlaufen.

echo "program start...";
file_put_contents('log.txt','start-time:'.date('Y-m-d H:i:s'), FILE_APPEND);
fastcgi_finish_request();
sleep(1);
echo 'debug...';
file_put_contents('log.txt', 'start-proceed:'.date('Y-m-d H:i:s'), FILE_APPEND);
sleep(10);
file_put_contents('log.txt', 'end-time:'.date('Y-m-d H:i:s'), FILE_APPEND);

Wie Sie den Ausgabeergebnissen entnehmen können, kehrt die Sitzung nach dem Drucken der Seite, dem Programmstart ... nach der Ausgabe der ersten Zeile in log.txt zurück, sodass das nachfolgende Debuggen ... nicht erfolgt im Browser ausgeführt werden, und die Datei log.txt kann vollständig drei Abschlusszeiten erhalten.

2. Verwenden Sie fsockopen()

Verwenden Sie fsockopen(), um eine Netzwerkverbindung oder eine Unix-Socket-Verbindung zu öffnen, und verwenden Sie dann stream_set_blocking(), um eine nicht- Blockierungsmodus:

$fp = fsockopen("www.example.com", 80, $errno, $errstr, 30);
if (!$fp) {
    die('error fsockopen');
}
// 转换到非阻塞模式
stream_set_blocking($fp, 0);
$http = "GET /save.php  / HTTP/1.1\r\n";
$http .= "Host: www.example.com\r\n";
$http .= "Connection: Close\r\n\r\n";
fwrite($fp, $http);
fclose($fp);

3. Verwenden Sie cURL

Verwenden Sie die Funktionen „curl_multi_*“ in cURL, um asynchrone Anfragen zu senden

$mh = curl_multi_init();
$ch = curl_init();
curl_setopt($ch, CURLOPT_URL, "http://localhost/");
curl_multi_add_handle($mh, $ch);
curl_multi_exec($mh, $active);
curl_close($ch);
curl_multi_remove_handle($mh, $ch);
curl_multi_close($mh);
echo "End\n";

4 /Swoole-Erweiterung

Gearman ist ein verteiltes asynchrones Verarbeitungsframework mit PHP-Erweiterung, das große Mengen asynchroner Aufgaben verarbeiten kann.

Swoole erfreut sich in letzter Zeit großer Beliebtheit. Es verfügt über viele asynchrone Methoden und ist einfach zu verwenden.

5. Verwenden Sie Caches und Warteschlangen

Verwenden Sie Redis und andere Caches und Warteschlangen, um Daten in den Cache zu schreiben, und verwenden Sie geplante Hintergrundaufgaben, um eine asynchrone Datenverarbeitung zu erreichen.

Diese Methode sollte in gängigen Architekturen mit hohem Datenverkehr sehr verbreitet sein

6. Rufen Sie Systembefehle auf

In extremen Fällen können Sie das System aufrufen Command kann Daten zur Ausführung an Hintergrundaufgaben übergeben, ich persönlich halte dies jedoch für nicht sehr effizient.

$cmd = 'nohup php ./processd.php $someVar >/dev/null  &';
`$cmd`

7. Verwenden Sie pcntl_fork()

, um die pcntl-Erweiterung zu installieren und verwenden Sie pcntl_fork(), um einen untergeordneten Prozess zu generieren, um Aufgaben asynchron auszuführen ist der bequemste, aber auch einfachste. Ein Zombie-Prozess erscheint.

$pid = pcntl_fork()
if ($pid == 0) {
    child_func();    //子进程函数，主进程运行
} else {
    father_func();   //主进程函数
}
echo "Process " . getmypid() . " get to the end.\n";
 
function father_func() {
    echo "Father pid is " . getmypid() . "\n";
}
function child_func() {
    sleep(6);
    echo "Child process exit pid is " . getmypid() . "\n";
    exit(0);
}

Das obige ist der detaillierte Inhalt vonAsynchrone, nicht blockierende PHP-Implementierungsmethode. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!