Maison  >  Article  >  développement back-end  >  Exemple de code montrant comment utiliser fscok pour implémenter l'appel asynchrone de PHP

Exemple de code montrant comment utiliser fscok pour implémenter l'appel asynchrone de PHP

黄舟
黄舟original
2017-03-30 10:03:321511parcourir

Le serveur Web exécute un script, qui peut être terminé en quelques millisecondes ou ne pas être terminé en plusieurs minutes. Si le programme s'exécute lentement, l'utilisateur n'aura peut-être plus la patience d'attendre plus longtemps et de fermer le navigateur.

Parfois, nous ne nous soucions même pas des résultats d'exécution de ces scripts chronophages, mais nous devons attendre qu'ils terminent leur exécution et reviennent avant de pouvoir passer à l'étape suivante.
Alors, existe-t-il un moyen de simplement déclencher l'appel de ces scripts chronophages puis de passer à l'étape suivante, afin que ces scripts chronophages puissent être exécutés lentement côté serveur ?

Ensuite, j'utiliserai fscokopen pour implémenter cette fonction.

  en utilisant fsockopen. fscokopen renvoie un handle vers la connexion à l'hôte distant. Vous pouvez effectuer fwrite, read
fgets, fread et d'autres opérations sur elle, tout comme en utilisant le handle renvoyé par fopen.
Le principal effet recherché de notre PHP asynchrone est de déclencher un script PHP puis de revenir immédiatement, le laissant s'exécuter lentement côté serveur. J'ai également écrit un article plus tôt pour discuter de cette question.

Ensuite, nous pouvons utiliser fsockopen pour nous connecter au serveur local, déclencher l'exécution du script, puis revenir immédiatement sans attendre la fin de l'exécution du script.


function triggerRequest($url, $post_data = array(), $cookie = array())…{
        $method = "GET";  //可以通过POST或者GET传递一些参数给要触发的脚本
        $url_array = parse_url($url); //获取URL信息,以便平凑HTTP HEADER
        $port = isset($url_array['port'])? $url_array['port'] : 80; 
      
        $fp = fsockopen($url_array['host'], $port, $errno, $errstr, 30); 
        if (!$fp) …{
                return FALSE;
        }
        $getPath = $url_array['path'] ."?". $url_array['query'];
        if(!empty($post_data))…{
                $method = "POST";
        }
        $header = $method . " " . $getPath;
        $header .= " HTTP/1.1\r\n";
        $header .= "Host: ". $url_array['host'] . "\r\n "; //HTTP 1.1 Host域不能省略
        /**//*以下头信息域可以省略
        $header .= "User-Agent: Mozilla/5.0 (Windows; U; Windows NT 5.1; en-US; rv:1.8.1.13) Gecko/20080311 Firefox/2.0.0.13 \r\n";
        $header .= "Accept: text/xml,application/xml,application/xhtml+xml,text/html;q=0.9,text/plain;q=0.8,image/png,q=0.5 \r\n";
        $header .= "Accept-Language: en-us,en;q=0.5 ";
        $header .= "Accept-Encoding: gzip,deflate\r\n";
         */

        $header .= "Connection:Close\r\n";
        if(!empty($cookie))…{
                $_cookie = strval(NULL);
                foreach($cookie as $k => $v)…{
                        $_cookie .= $k."=".$v."; ";
                }
                $cookie_str =  "Cookie: " . base64_encode($_cookie) ." \r\n";//传递Cookie
                $header .= $cookie_str;
        }
        if(!empty($post_data))…{
                $_post = strval(NULL);
                foreach($post_data as $k => $v)…{
                        $_post .= $k."=".$v."&";
                }
                $post_str  = "Content-Type: application/x-www-form-urlencoded\r\n";//POST数据
                $post_str .= "Content-Length: ". strlen($_post) ." \r\n";//POST数据的长度
                $post_str .= $_post."\r\n\r\n "; //传递POST数据
                $header .= $post_str;
        }
        fwrite($fp, $header);
        //echo fread($fp, 1024); //我们不关心服务器返回
        fclose($fp);
        return true;
}
Désormais, vous pouvez déclencher l'exécution d'un script PHP via cette

fonction , puis la fonction reviendra. Nous pouvons alors passer à l'étape suivante.

Un autre problème est lorsque le client se déconnecte. Autrement dit, une fois que triggerRequest a envoyé la requête, la connexion est immédiatement fermée, ce qui peut entraîner la fermeture du script en cours d'exécution sur le serveur.

Au sein de PHP, le système maintient le

statut de connexion , qui a trois états possibles :

* 0 – NORMAL (normal)

* 1 - ABORTED (sortie anormale)

* 2 - TIMEOUT (timeout)

Lorsque le script PHP s'exécute normalement à l'état NORMAL, la connexion est valide. Lorsque le client se déconnecte, l'indicateur d'état ABORTED sera activé. L'interruption de la connexion du client distant est généralement provoquée par le fait que l'utilisateur clique sur le bouton S

TOP . Lorsque le temps de connexion dépasse la limite de temps de PHP (voir la fonction set_time_limit()), l'indicateur de l'état TIMEOUT sera activé.

Vous pouvez décider si le script doit se terminer lorsque le client se déconnecte. Parfois, il est pratique d'exécuter un script dans son intégralité, même si aucun navigateur distant n'accepte la sortie du script. Par défaut, le script se ferme lorsque la connexion du client distant est perdue. Ce traitement peut être contrôlé par ignore_user_abort dans php.ini ou par les fonctions correspondantes "php_value ignore_user_abort" et ignore_user_abort() dans les paramètres Apache .conf. Si PHP n'est pas invité à ignorer les interruptions de l'utilisateur, le script sera interrompu sauf via register_shutdown_function() La fonction de déclenchement d'arrêt est définie. Grâce à cette fonction de déclenchement de fermeture, lorsque l'utilisateur distant clique sur le bouton STOP et que le script tente à nouveau de générer des données, PHP détectera que la connexion a été interrompue et appellera la fonction de déclenchement de fermeture.

Les scripts peuvent également être interrompus par le minuteur de script intégré. Le délai d'expiration par défaut est de 30 secondes. Cette valeur peut être modifiée en définissant max_execution_time dans php.ini ou le paramètre "php_value max_execution_time" correspondant dans les paramètres Apache .conf ou la fonction set_time_limit(). Lorsque le compteur expire, le script se terminera de la même manière que dans la situation d'interruption de connexion ci-dessus, et la fonction de déclenchement d'arrêt précédemment enregistrée sera également exécutée à ce moment-là. Dans la fonction de déclenchement d'arrêt, vous pouvez vérifier si le délai d'attente a provoqué l'appel de la fonction de déclenchement d'arrêt en appelant la fonction connection_status(). Si un délai d'attente entraîne un appel à la fonction déclenchant l'arrêt, la fonction retournera 2.

Une chose à noter est que les états ABORTED et TIMEOUT peuvent être valides en même temps. Ceci est possible en demandant à PHP d'ignorer les actions de sortie de l'utilisateur. PHP remarquera toujours que l'utilisateur s'est déconnecté mais le script est toujours en cours d'exécution. Si la limite de temps d'exécution est atteinte, le script sera quitté et la fonction de déclenchement d'arrêt définie sera également exécutée. À ce stade, vous constaterez que la fonction connection_status() renvoie 3.

      所以还在要触发的脚本中指明:

ignore_user_abort(TRUE); //如果客户端断开连接,不会引起脚本
abort.set_time_limit(0);//取消脚本执行延时上限

     或者,也可以使用:

register_shutdown_function(callback fuction[, parameters]);//注册脚本退出时执行的函数

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn