PHP asynchrone : utilisez fsockopen curl pour implémenter des méthodes fonctionnelles similaires au traitement asynchrone en PHP

D'un point de vue courant, PHP est un langage orienté processus. Son plus grand inconvénient est qu'il ne peut pas réaliser une gestion multithread. L'exécution de son programme se fait du début à la fin, et il est exécuté selon la logique jusqu'au bout. Les branches sont impossibles. C'est l'une des raisons qui empêche PHP de devenir un langage de niveau supérieur parmi les langages de programmation traditionnels.

En PHP, nous souhaitons parfois effectuer une autre opération tout en effectuant une certaine opération. Prenons un scénario : lorsque les utilisateurs récupèrent des tickets, vous ne voulez pas que les utilisateurs fassent la queue pour se connecter. jugement et insertion, puis renvoie les résultats de l'utilisateur une fois terminés. En fait, nous n'avons pas besoin que l'utilisateur attende aussi longtemps. Une fois que l'utilisateur a soumis, nous pouvons lui dire directement qu'il a réussi à récupérer le ticket. Quant aux différentes opérations, nous pouvons simplement les laisser en arrière-plan pour le traitement. . Bien sûr, nous utilisons désormais des listes de messages pour gérer cette situation. Nous stockons chaque demande soumise par l'utilisateur dans une file d'attente de messages pour indiquer à l'utilisateur qu'elle est terminée. Une fois que l'utilisateur ferme joyeusement la page, l'arrière-plan est toujours conservé. recevoir les messages un par un. Supprimer la demande de la file d'attente pour l'opération. Notre article utilise une approche hétérogène pour permettre aux opérations de s'exécuter en arrière-plan sans que l'utilisateur ait à attendre.

Tout d'abord, nous devons créer une entrée de requête :

Données soumises

Soumis en arrière-plan

Dire L'utilisateur l'a déjà fait

Deuxièmement, nous avons besoin d'un programme de traitement en arrière-plan, que l'utilisateur soit en ligne ou non n'affecte pas son fonctionnement :

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

Données entrantes

Traitement des données

La question est maintenant, dans le premier morceau de code, comment "soumettre en arrière-plan" ? Nous implémentons cette fonction via une requête non bloquante. Il s'agit de créer une URL accessible, d'exécuter le deuxième programme sur cette URL et de demander l'URL via une requête, activant ainsi l'exécution automatique du deuxième programme.

Regardons ensuite directement le code :

// 远程请求（不获取内容）函数
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);
 }
}

Nous avons créé une fonction basée sur fsockopen Dans cette fonction, fsockopen est utilisé pour accéder à l'url, mais lors de l'accès, ne nécessite pas d'obtenir le contenu affiché par l'URL, mais émet uniquement une demande d'accès, et l'accès est fermé immédiatement après l'arrivée de la demande. L'avantage est qu'il n'est pas nécessaire d'attendre que l'URL visitée renvoie des informations fiables, ce qui permet de gagner du temps. Le temps d'exécution de ce code est compris entre 0,1 et 0,2 seconde, ce qui est presque imperceptible pour les visiteurs ordinaires. Par conséquent, lors de son utilisation, il vous suffit d’appeler cette fonction et l’url correspondante. Cependant, aucune partie de transmission de données n'est fournie ici. Comment transmettre des données, en fait, il vous suffit d'ajouter le contenu de la publication à $header.

En plus de fsockopen, curl peut réellement obtenir cet effet. Certains hôtes ne prennent pas en charge fsockopen, nous pouvons donc utiliser curl pour y parvenir.

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;
}

La clé de ce code est de fournir un Timeout, seulement 1 seconde, ce qui signifie que curl fait une requête, peu importe si le contenu renvoyé est reçu ou non, après 1 seconde L'accès sera fermé, donc les données d'exécution de cette fonction sont comprises entre 1,0 et 1,1 secondes. Mais pour les utilisateurs, s'il s'agit d'une application qui nécessite un traitement de données, l'attente d'1 seconde est quasiment ignorée. Si vous souhaitez utiliser un code plus simple et plus facile à comprendre, vous pouvez choisir curl pour l'implémenter.