Prinzip und Implementierung des asynchronen PHP-Betriebs

1. Warum benötigt PHP asynchrone Operationen?

Im Allgemeinen eignet sich PHP für kurzfristige Aufgaben wie die Anzeige von Webseiten, wenn es sich um zeitaufwändige Vorgänge wie die Größenänderung von Bildern, den Import großer Datenmengen, das Senden von EDM, SMS usw. in Stapeln handelt ist sehr einfach. Es ist eine Zeitüberschreitung beim Vorgang aufgetreten. Sie können sagen, dass ich eine unendliche Zeitüberschreitung usw. festlegen kann. Sie müssen auch wissen, dass PHP einen Arbeitsmodus hat, der Fastcgi ist. PHP führt keine Zeitüberschreitung auf unbestimmte Zeit durch, was nicht bedeutet, dass Fastcgi keine Zeitüberschreitung hat ... Wenn Sie immer noch möchten fastcgi soll niemals eine Zeitüberschreitung verursachen. Es wird empfohlen, dass Sie dies mit Ihrem Betriebs- und Wartungspersonal besprechen ...

Zu diesem Zeitpunkt kommen asynchrone Vorgänge ins Spiel, da es sich um nicht blockierende Vorgänge handelt sofort und arbeiten Sie dann langsam im Hintergrund. Es spielt keine Rolle, ob es zu einer Zeitüberschreitung kommt oder nicht, ich arbeite nicht unter dem aktuellen Prozess/Thread. Schauen Sie, ist das nicht wunderbar, aber eigentlich ist es auch eine Falle...

2. Kann PHP asynchrone Operationen implementieren?

Die Antwort ist ja, aber verschiedene reine PHP-Implementierungen im Internet sind etwas umständlich. Socket-Modus, angehaltener Prozessmodus und einige verzweigen den Prozess sogar direkt. Sehr gut, alle möglichen Götter zeigen ihre magischen Kräfte. Wenn das Betriebs- und Wartungspersonal es sieht, werden sie es auf jeden Fall tun. Es wäre seltsam, wenn der Webserver nicht getötet würde ...

Gibt es einen anderen besseren Weg, diesen asynchronen Betrieb zu erreichen? ? Ja, jetzt müssen wir nur noch darüber nachdenken, wie wir Plug-Ins aktivieren. Schauen Sie sich die Mainstream-Plug-In-Lösungen von PECL an. Es gibt eine Reihe von ××MQ (Nachrichtenwarteschlange), darunter ein Plug-In für die Aufgabenverteilung, das uns ins Auge fällt. Ich werde es nicht im Detail vorstellen. Klicken Sie zum Verbinden (siehe Einführung).

3. Warum Gearman wählen?

Wenn nichts anderes, sagen Sie einfach, dass es viele Kunden hat und Kunden in vielen Sprachen unterstützt . Persönlich ärgere ich mich sehr über die Sprachdebatte. Sie können Shenma verwenden, um Arbeiter zu schreiben, wie Sie möchten. Es gibt Datenpersistenzunterstützung (das heißt, die Warteschlange wird auf dem Datenbankmedium gespeichert, sodass die Wiederherstellung nach Fehlern einfach ist) und es gibt Clusterunterstützung (tatsächlich verfügen viele ××MQ über diese Funktionen). Es gibt Erweiterungen für PECL und es gibt auch Erweiterungen, die in reinem PHP implementiert sind. Wie auch immer, dieser Gearman lebt schon lange und alle verschiedenen Probleme wurden im Grunde genommen gelöst.

4. Grundidee

Mit dem Gearman-Plugin ist es viel einfacher. Das bedeutet, eine Aufgabe an Gearman zu senden, die ausgeführte Aufgabe zu senden und dann darauf zu warten, dass der Worker die PHP-CLI aufruft, um unseren PHP-Code auszuführen.

Ich habe gerade einen Python-Worker geschrieben (fragen Sie mich nicht, warum ich Python verwende, 1. Ich kenne Python, 2. Ich muss unter Linux keine Laufzeit installieren. Sie können einen PHP-Worker schreiben). Ich vertraue jedoch nicht wirklich den Mitarbeitern, die PHP ausführen. Für andere Sprachen können Sie versuchen, einen Worker mithilfe von Java, node.js oder anderen Sprachen zu implementieren. Freunde, die daran interessiert sind, Arbeiter in Golang zu schreiben, können mich kontaktieren.

phpasync_worker_py

Leider sind keine Kommentare darin enthalten. Eine Konfigurationsdatei und ein Py-Skript. Die Grundfunktion besteht darin, die Aufrufparameter zu analysieren und dann die PHP-CLI aufzurufen, das war's. Um das Py-Skript auszuführen, installieren Sie bitte selbst das Python-Gearman-Modul.

Gehen Sie dann zum PHP-Teil und beginnen Sie mit dem Testcode:

<?php 
require_once &#39;PHPAsyncClient.php&#39;; 
date_default_timezone_set(&#39;Asia/Shanghai&#39;); 
 
class AsyncTest { 
 
    const
        LOG_FILE = &#39;/debug.log&#39;; 
 
    static public function run() { 
        if (PHPAsyncClient::in_callback(__FILE__)) { 
            self::log(&#39;php Async callback&#39;); 
            PHPAsyncClient::parse(); 
            return; 
        } 
        if (PHPAsyncClient::is_main(__FILE__)) { 
            self::log(&#39;main run&#39;); 
            $async_call = PHPAsyncClient::getInstance(); 
            $async_call->AsyncCall(&#39;AsyncTest&#39;, &#39;callback&#39;, array( 
                &#39;content&#39; => &#39;Hello World!!!&#39;, 
            ), array( 
                &#39;class&#39; => &#39;AsyncTest&#39;, 
                &#39;method&#39; => &#39;callback&#39;, 
                &#39;params&#39; => array( 
                    &#39;content&#39; => &#39;Hello Callback!&#39;, 
                ), 
            ), __FILE__); 
            return; 
        } 
    } 
 
    static public function callback($args) { 
        self::log(&#39;AsyncTest callback run&#39;); 
        self::log(&#39;AsyncTest callback args:&#39;.print_r($args, true)); 
    } 
 
    static public function log($content) { 
        $fullname = dirname(__FILE__).self::LOG_FILE; 
        $content = date(&#39;[Y-m-d H:i:s]&#39;).$content."\n"; 
        file_put_contents($fullname, $content, FILE_APPEND); 
    } 
} 
 
AsyncTest::run();

Es gibt nur drei statische Methoden, eine ist die Protokollmethode zum Debuggen und die anderen sind literal. Dieses Beispiel ist ein erster Eindruck dieser Aufrufmethode. Laden Sie dann direkt den gesamten Quellcode von PHP hoch:

php_async.zip

Dann dürften viele Leute sagen, dass Gearman nicht unter Win installiert werden kann ... also habe ich auch die Java-Version von installiert Gearman-Server.

java-gearman-service-0.6.6.zip

5. Fazit

Nachdem wir etwas so Großes wie ein Nashorn konfiguriert haben (ein Gearman muss installiert und ein Py-Skript ausgeführt werden), haben wir PHP grundsätzlich für eine asynchrone Aufruffunktion aktiviert. Natürlich gibt es auch eine Statuswartungsfunktion Das muss von uns selbst aufrechterhalten werden. Daher fand ich, dass diese Lösung eigentlich nicht gut und zu kompliziert ist. Es wäre besser, einige Web-Service-Methoden zu verwenden, um Web-Rückrufe durchzuführen (das Problem besteht darin, dass auch Web-Rückrufe eine Zeitüberschreitung aufweisen ...), bitte beachten Sie die Folgemaßnahmen.