Der Unterschied zwischen Swoole-Coroutine und Asynchronität

Ab Version 4.0 bietet Swoole vollständige Coroutine- und Kanalfunktionen und bringt ein neues CSP-Programmiermodell mit.

Die Anwendungsschicht kann vollständig synchrone Programmierung verwenden, und die unterste Schicht implementiert automatisch asynchrone E/A. (Empfohlenes Lernen: Swoole-Video-Tutorial)

go(function () {
    $redis = new Swoole\Coroutine\Redis();
    $redis->connect('127.0.0.1', 6379);
    $val = $redis->get('key');
});

Version 4.0.0 oder höher unterstützt nur PHP7

Es wurde seit Version 4.0 entfernt. 1 Kompilierungsoption --enable-coroutine, geändert in dynamische Konfiguration

Coroutinen können als reine Benutzermodus-Threads verstanden werden, die durch Kooperation und nicht durch Vorkaufsrecht wechseln. Im Vergleich zu Prozessen oder Threads können alle Vorgänge von Coroutinen im Benutzermodus ausgeführt werden, und die Erstellungs- und Wechselkosten sind geringer.

Swoole kann für jede Anfrage eine entsprechende Coroutine erstellen und die Coroutine entsprechend dem IO-Status sinnvoll planen. Dies bringt die folgenden Vorteile:

Entwicklungsbenutzer können synchron verwenden Code schreiben, um die Wirkung und Leistung asynchroner E/A ohne jegliches Bewusstsein zu erzielen, die durch herkömmliche asynchrone Rückrufe verursachte diskrete Codelogik zu vermeiden und in mehrschichtigen Rückrufen gefangen zu sein, was zu nicht wartbarem Code führt

Gleichzeitig fällig zu Die unterste Ebene kapselt Coroutinen, sodass Entwickler im Vergleich zum herkömmlichen Coroutine-Framework der PHP-Ebene nicht das Schlüsselwort yield verwenden müssen, um eine Coroutine-E/A-Operation zu identifizieren, sodass kein tiefgreifendes Verständnis der Semantik von yield erforderlich ist und rufen Sie jede Ebene auf. Alle werden so modifiziert, dass sie die Entwicklungseffizienz erheblich verbessern

und den Anforderungen der meisten Entwickler gerecht werden können. Für private Protokolle können Entwickler zur bequemen Kapselung die TCP- oder UDP-Schnittstelle der Coroutine nutzen.

Wenn Sie zeitaufwändige Vorgänge im Serverprogramm ausführen müssen, z. B. das Senden von Broadcasts an einen Chat-Server oder das Senden von E-Mails an einen Webserver. Wenn Sie diese Funktionen direkt ausführen, wird der aktuelle Prozess blockiert, was dazu führt, dass der Server langsam reagiert.

Swoole bietet die Funktion der asynchronen Aufgabenverarbeitung, mit der eine asynchrone Aufgabe zur Ausführung an den TaskWorker-Prozesspool übergeben werden kann, ohne die Verarbeitungsgeschwindigkeit der aktuellen Anforderung zu beeinträchtigen.

Programmcode

Basierend auf dem ersten TCP-Server müssen nur zwei Ereignisrückruffunktionen, onTask und onFinish, hinzugefügt werden. Darüber hinaus muss die Anzahl der Aufgabenprozesse festgelegt werden. Die entsprechende Anzahl von Aufgabenprozessen kann entsprechend dem Zeitaufwand und dem Aufgabenvolumen der Aufgabe konfiguriert werden.

$serv = new swoole_server("127.0.0.1", 9501);

//设置异步任务的工作进程数量
$serv->set(array('task_worker_num' => 4));

$serv->on('receive', function($serv, $fd, $from_id, $data) {
    //投递异步任务
    $task_id = $serv->task($data);
    echo "Dispath AsyncTask: id=$task_id\n";
});

//处理异步任务
$serv->on('task', function ($serv, $task_id, $from_id, $data) {
    echo "New AsyncTask[id=$task_id]".PHP_EOL;
    //返回任务执行的结果
    $serv->finish("$data -> OK");
});

//处理异步任务的结果
$serv->on('finish', function ($serv, $task_id, $data) {
    echo "AsyncTask[$task_id] Finish: $data".PHP_EOL;
});

$serv->start();

Nach dem Aufruf von $serv->task() kehrt das Programm sofort zurück und führt den Code weiter aus. Die Rückruffunktion onTask wird asynchron im Task-Prozesspool ausgeführt. Rufen Sie nach Abschluss der Ausführung $serv->finish() auf, um das Ergebnis zurückzugeben.

Das obige ist der detaillierte Inhalt vonDer Unterschied zwischen Swoole-Coroutine und Asynchronität. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!