Comment implémenter l'exécution asynchrone de scripts en PHP-tutoriel php-php.cn

Comment implémenter l'exécution asynchrone de scripts en PHP

墨辰丷

Libérer： 2023-03-26 17:14:02

original

1998 Les gens l'ont consulté

Cet article présente principalement la méthode d'exécution asynchrone de scripts via la programmation PHP, et analyse les compétences d'appel et d'exécution asynchrones de scripts implémentés par PHP à l'aide de fsockopen() sous forme d'exemples. Les amis dans le besoin peuvent s'y référer

Les détails sont les suivants :

Le langage PHP doit utiliser la fonction

pour implémenter l'exécution asynchrone du script. Le code est le suivant fsockopen()

Fonction de requête asynchrone (si le. Le paramètre debug est vrai, il est utilisé pour le débogage. Vous pouvez activer le débogage Voir l'exécution asynchrone, mais perdre l'effet asynchrone)

main.php

<?php
function request_by_fsockopen($url,$post_data=array(),$debug=false){
  $url_array = parse_url($url);
  $hostname = $url_array[&#39;host&#39;];
  $port = isset($url_array[&#39;port&#39;])? $url_array[&#39;port&#39;] : 80;
  @$requestPath = $url_array[&#39;path&#39;] ."?". $url_array[&#39;query&#39;];
  $fp = fsockopen($hostname, $port, $errno, $errstr, 10);
  if (!$fp) {
    echo "$errstr ($errno)";
    return false;
  }
  $method = "GET";
  if(!empty($post_data)){
    $method = "POST";
  }
  $header = "$method $requestPath HTTP/1.1\r\n";
  $header.="Host: $hostname\r\n";
  if(!empty($post_data)){
    $_post = strval(NULL);
    foreach($post_data as $k => $v){
    $_post[]= $k."=".urlencode($v);//必须做url转码以防模拟post提交的数据中有&符而导致post参数键值对紊乱
    }
    $_post = implode(&#39;&&#39;, $_post);
    $header .= "Content-Type: application/x-www-form-urlencoded\r\n";//POST数据
    $header .= "Content-Length: ". strlen($_post) ."\r\n";//POST数据的长度
    $header.="Connection: Close\r\n\r\n";//长连接关闭
    $header .= $_post; //传递POST数据
  }else{
    $header.="Connection: Close\r\n\r\n";//长连接关闭
  }
  fwrite($fp, $header);
  //-----------------调试代码区间-----------------
  //注如果开启下面的注释,异步将不生效可是方便调试
  if($debug){
  $html = &#39;&#39;;
  while (!feof($fp)) {
  $html.=fgets($fp);
  }
  echo $html;
  }
  //-----------------调试代码区间-----------------
  fclose($fp);
}
$data=array(&#39;name&#39;=>&#39;guoyu&#39;,&#39;pwd&#39;=>&#39;123456&#39;);
$url=&#39;http://localhost/test/other.php&#39;;
request_by_fsockopen($url,$data,true);//

Copier après la connexion

other.php

<?php
header("content-type:text/html;charset=utf-8");
//error_reporting(0);
//ini_set(&#39;html_errors&#39;,false);
//ini_set(&#39;display_errors&#39;,false);
$name = isset($_POST[&#39;name&#39;])?$_POST[&#39;name&#39;]:&#39;&#39;;
$pwd = isset($_POST[&#39;pwd&#39;])?$_POST[&#39;pwd&#39;]:&#39;&#39;;
echo $name.$pwd;
echo &#39;success ok&#39;;
die;
?>

Copier après la connexion

Exemple d'utilisation :

[fichier de script principal main.php en cours d'exécution]

$data=array(&#39;name&#39;=>&#39;guoyu&#39;,&#39;pwd&#39;=>&#39;123456&#39;);
$url=&#39;http://localhost/test/other.php&#39;;
request_by_fsockopen($url,$data,true);//把应用B的用户表异步-同步数据

Copier après la connexion

[Fichier d'exécution du guide other.php]

Dans other.php, vous pouvez utiliser $_POST pour recevoir les paramètres soumis par main .php, afin de passer à l'étape suivante

Recommandations associées :