PHP asynchron: Verwenden Sie fsockopen curl, um funktionale Methoden zu implementieren, die der asynchronen Verarbeitung in PHP ähneln

Aus Mainstream-Sicht ist PHP eine prozessorientierte Sprache. Ihr größter Nachteil besteht darin, dass sie kein Multi-Thread-Management erreichen kann. Die Ausführung ihres Programms erfolgt von Anfang bis Ende nach Logik . Verzweigungen sind unmöglich. Dies ist einer der Gründe, die die Entwicklung von PHP zu einer höheren Programmiersprache verhindern.

In PHP möchten wir manchmal tatsächlich einen anderen Vorgang ausführen, während wir einen bestimmten Vorgang ausführen. Nehmen Sie ein Szenario: Wenn Benutzer Tickets abrufen, möchten Sie nicht, dass Benutzer in der Warteschlange stehen, um eine Verbindung herzustellen. Beurteilung und Einfügung und gibt nach Abschluss die Benutzerergebnisse zurück. Tatsächlich müssen wir nicht so lange warten, bis der Benutzer das Ticket abgeschickt hat. Was die verschiedenen Vorgänge betrifft, können wir es einfach im Hintergrund verarbeiten . Natürlich verwenden wir jetzt Nachrichtenlisten, um diese Situation zu bewältigen. Wir speichern jede vom Benutzer gesendete Anfrage in einer Nachrichtenwarteschlange, um dem Benutzer mitzuteilen, dass sie abgeschlossen ist. Nachdem der Benutzer die Seite glücklich geschlossen hat, bleibt der Hintergrund bestehen Empfangen von Nachrichten nacheinander. Entfernen Sie die Anforderung aus der Warteschlange, um sie auszuführen. Unser Artikel verwendet einen heterogenen Ansatz, um die Ausführung von Vorgängen im Hintergrund zu ermöglichen, ohne dass der Benutzer warten muss.

Zuerst müssen wir einen Anfrageeintrag erstellen:

Übermittelte Daten

An den Hintergrund übermittelt

Sagen Sie, dass der Benutzer es bereits getan hat

Zweitens benötigen wir ein Hintergrundverarbeitungsprogramm. Ob der Benutzer online ist oder nicht, hat keinen Einfluss auf seinen Betrieb:

<?php 
ignore_user_abort(true);
set_time_limit(0);

Eingehende Daten

Datenverarbeitung

Die Frage ist nun, wie man im ersten Teil des Codes „im Hintergrund bleibt“? Wir implementieren diese Funktion durch eine nicht blockierende Anfrage. Das heißt, eine URL zu erstellen, auf die zugegriffen werden kann, das zweite Programm unter dieser URL auszuführen und die URL über eine Anfrage anzufordern, wodurch die automatische Ausführung des zweiten Programms aktiviert wird.

Als nächstes schauen wir uns den Code direkt an:

// 远程请求（不获取内容）函数
function _sock($url) {
 $host = parse_url($url,PHP_URL_HOST);
 $port = parse_url($url,PHP_URL_PORT);
 $port = $port ? $port : 80;
 $scheme = parse_url($url,PHP_URL_SCHEME);
 $path = parse_url($url,PHP_URL_PATH);
 $query = parse_url($url,PHP_URL_QUERY);
 if($query) $path .= '?'.$query;
 if($scheme == 'https') {
  $host = 'ssl://'.$host;
 }
 
 $fp = fsockopen($host,$port,$error_code,$error_msg,1);
 if(!$fp) {
  return array('error_code' => $error_code,'error_msg' => $error_msg);
 }
 else {
  stream_set_blocking($fp,true);//开启了手册上说的非阻塞模式
  stream_set_timeout($fp,1);//设置超时
  $header = "GET $path HTTP/1.1\r\n";
  $header.="Host: $host\r\n";
  $header.="Connection: close\r\n\r\n";//长连接关闭
  fwrite($fp, $header);
  usleep(1000); // 这一句也是关键，如果没有这延时，可能在nginx服务器上就无法执行成功
  fclose($fp);
  return array('error_code' => 0);
 }
}

Wir haben eine Funktion basierend auf fsockopen erstellt. In dieser Funktion wird fsockopen verwendet, um auf die URL zuzugreifen Beim Zugriff ist es nicht erforderlich, den über die URL angezeigten Inhalt abzurufen, sondern es wird lediglich eine Zugriffsanforderung ausgegeben, und der Zugriff wird sofort nach Eintreffen der Anforderung geschlossen. Dies hat den Vorteil, dass nicht darauf gewartet werden muss, dass die besuchte URL zuverlässige Informationen zurückgibt, was Zeit spart. Die Ausführungszeit dieses Codes liegt zwischen 0,1 und 0,2 Sekunden, was für normale Besucher kaum wahrnehmbar ist. Wenn Sie es verwenden, müssen Sie daher nur diese Funktion und die entsprechende URL aufrufen. Hier wird jedoch kein Teil zur Datenübertragung bereitgestellt. Tatsächlich müssen Sie nur den Beitragsinhalt zum $header hinzufügen.

Zusätzlich zu fsockopen kann Curl diesen Effekt tatsächlich erzielen. Einige Hosts unterstützen fsockopen nicht, daher können wir Curl verwenden, um ihn zu erreichen.

function _curl($url) {
 $ch = curl_init();
 curl_setopt($ch,CURLOPT_URL,$url);
 curl_setopt($ch,CURLOPT_RETURNTRANSFER,1);
 curl_setopt($ch,CURLOPT_TIMEOUT,1);
 $result = curl_exec($ch);
 curl_close($ch);
 return $result;
}

Der Schlüssel zu diesem Code besteht darin, ein Timeout von nur 1 Sekunde bereitzustellen, was bedeutet, dass Curl danach eine Anfrage stellt, unabhängig davon, ob der zurückgegebene Inhalt empfangen wird oder nicht 1 Sekunde Der Zugriff wird geschlossen, sodass die Ausführungsdaten dieser Funktion zwischen 1,0 und 1,1 Sekunden liegen. Wenn es sich jedoch um eine Anwendung handelt, die eine Datenverarbeitung erfordert, wird die Wartezeit von 1 Sekunde für Benutzer fast ignoriert. Wenn Sie einen einfacheren und leichter verständlichen Code verwenden möchten, können Sie Curl wählen, um ihn zu implementieren.