- php 不等待返回的实现方法（异步调用）

您的位置：首页 >> 程序员学前班[不再更新，只读] >> 主题: php 不等待返回的实现方法（异步调用） [回主站] [分站链接]

您的位置：首页 >> 程序员学前班[不再更新，只读] >> 主题: php 不等待返回的实现方法（异步调用） [最新] [回主站]

标题

php 不等待返回的实现方法（异步调用）

clq

浏览(5) + 2017-10-31 09:54:35 发表编辑

关键字:

[2019-06-21 09:01:11 最后更新]
php 不等待返回的实现方法（异步调用）
转载 2015年07月08日 17:52:35

PHP异步执行的常用方式常见的有以下几种，可以根据各自优缺点进行选择：

1.客户端页面采用AJAX技术请求服务器
优点：最简单，也最快，就是在返回给客户端的HTML代码中，嵌入AJAX调用，或者，嵌入一个img标签，src指向要执行的耗时脚本。
缺点：一般来说Ajax都应该在onLoad以后触发，也就是说，用户点开页面后，就关闭，那就不会触发我们的后台脚本了。
而使用img标签的话，这种方式不能称为严格意义上的异步执行。用户浏览器会长时间等待php脚本的执行完成，也就是用户浏览器的状态栏一直显示还在load。
当然，还可以使用其他的类似原理的方法，比如script标签等等。

2.popen()函数
该函数打开一个指向进程的管道，该进程由派生给定的 command 命令执行而产生。打开一个指向进程的管道，该进程由派生给定的 command 命令执行而产生。
所以可以通过调用它，但忽略它的输出。使用代码如下：

 pclose(popen("/home/xinchen/backend.php &", 'r'));

优点：避免了第一个方法的缺点，并且也很快。
缺点：这种方法不能通过HTTP协议请求另外的一个WebService，只能执行本地的脚本文件。并且只能单向打开，无法穿大量参数给被调用脚本。并且如果，访问量很高的时候，会产生大量的进程。如果使用到了外部资源，还要自己考虑竞争。

3.CURL扩展
CURL是一个强大的HTTP命令行工具，可以模拟POST/GET等HTTP请求，然后得到和提取数据，显示在"标准输出"（stdout）上面。代码如下：

 $ch = curl_init();

 $curl_opt = array(CURLOPT_URL, 'http://www.example.com/backend.php',
 CURLOPT_RETURNTRANSFER, 1,
 CURLOPT_TIMEOUT, 1,);

 curl_setopt_array($ch, $curl_opt);

 curl_exec($ch);

 curl_close($ch);

缺点：如你问题中描述的一样，由于使用CURL需要设置CUROPT_TIMEOUT为1（最小为1，郁闷）。也就是说，客户端至少必须等待1秒钟。

4.fscokopen()函数
fsockopen支持socket编程，可以使用fsockopen实现邮件发送等socket程序等等,使用fcockopen需要自己手动拼接出header部分
可以参考: http://cn.php.net/fsockopen/
使用示例如下：

 $fp = fsockopen("www.34ways.com", 80, $errno, $errstr, 30);
 if (!$fp) {
 echo "$errstr ($errno) \n";
 } else {
 $out = "GET /index.php / HTTP/1.1\r\n";
 $out .= "Host: www.34ways.com\r\n";
 $out .= "Connection: Close\r\n\r\n";

 fwrite($fp, $out);
 /*忽略执行结果
 while (!feof($fp)) {
 echo fgets($fp, 128);
 }*/
 fclose($fp);
 }

所以总结来说，fscokopen()函数应该可以满足您的要求。可以尝试一下。

 fscokopen的问题和popen 一样，并发非常多时会产生很多子进程，当达到apache的连接限制数时，就会挂掉，我问题已经说了这种情况。

PHP 本身没有多线程的东西，但可以曲线的办法来造就出同样的效果，比如多进程的方式来达到异步调用，只限于命令模式。还有一种更简单的方式，可用于 Web 程序中，那就是用fsockopen()、fputs() 来请求一个 URL 而无需等待返回，如果你在那个被请求的页面中做些事情就相当于异步了。

关键代码如下：

 $fp=fsockopen('localhost',80,&$errno,&$errstr,5);
 if(!$fp){
 echo "$errstr ($errno) \n";
 }
 fputs($fp,"GET another_page.php?flag=1\r\n");
 fclose($fp);

上面的代码向页面 another_page.php 发送完请求就不管了，用不着等待请求页面的响应数据，利用这一点就可以在被请求的页面 another_page.php 中异步的做些事情了。

比如，一个很切实的应用，某个 Blog 在每 Post 了一篇新日志后需要给所有它的订阅者发个邮件通知。如果按照通常的方式就是：

 日志写完 -> 点提交按钮 -> 日志插入到数据库 -> 发送邮件通知 ->
 告知撰写者发布成功

那么作者在点提交按钮到看到成功提示之间可能会等待很常时间，基本是在等邮件发送的过程，比如连接邮件服务异常、或器缓慢或是订阅者太多。而实际上是不管邮件发送成功与否，保证日志保存成功基本可接受的，所以等待邮件发送的过程是很不经济的，这个过程可异步来执行，并且邮件发送的结果不太关心或以日志形式记录备查。

改进后的流程就是：

 日志写完 -> 点提交按钮 -> 日志插入到数据库 --->
 告知撰写者发布成功
 └ 发送邮件通知 -> [记下日志]

用个实际的程序来测试一下，有两个 php，分别是 write.php 和 sendmail.php，在 sendmail.php 用 sleep(seconds) 来模拟程序执行使用时间。

write.php，执行耗时 1 秒

 <?php

 function asyn_sendmail() {
 $fp=fsockopen('localhost',80,&$errno,&$errstr,5);
 if(!$fp){
 echo "$errstr ($errno) \n";
 }
 sleep(1);
 fputs($fp,"GET /sendmail.php?param=1\r\n"); #请求的资源 URL 一定要写对
 fclose($fp);
 }

 echo time().' ';
 echo 'call asyn_sendmail ';
 asyn_sendmail();
 echo time().' ';
 ?>

sendmail.php，执行耗时 10 秒

 <?php
 //sendmail();
 //sleep 10 seconds
 sleep(10);
 fopen('C:\'.time(),'w');
 ?>

通过页面访问 write.php，页面输出：

 1272472697 call asyn_sendmail
 1272472698

并且在 C:\ 生成文件：

 1272472708

从上面的结果可知 sendmail.php 花费至少 10 秒，但不会阻塞到 write.php 的继续往下执行，表明这一过程是异步的。

转自：http://www.dewen.io/q/3970/

clq

2017-10-31 09:56:59 发表编辑

clq

2017-10-31 09:57:32 发表编辑

使用PHP进行异步HTTP请求
转载 2013年11月17日 15:04:59

使用JavaScript/Ajax可轻松实现异步HTTP请求，本文介绍使用PHP进行异步HTTP请求。所谓异步HTTP请求是指：HTTP协议基于TCP且是基于状态的，client和server建立连接后发送请求需要等到server处理结束并返回后才可以断开连接。某些情况下，client端只需要发出自己的请求即可，不需要知道 server端的响应，这个时候即需要实现client端发出异步HTTP请求。另外，在长耗时应用中(请求的server端任务比较耗时，超过HTTP timeout时间甚至更长)，也可以考虑使用异步HTTP请求出发该任务。关于长耗时应用也可以参考该文。
方法1：使用curl的CURLOPT_TIMEOUT或CURLOPT_TIMEOUT_MS

设置CURLOPT_TIMEOUT为最小值1，client端在等待1秒之后即返回。

 $url = "http://www.yoursite.com/background-script.php";
 $ref_url = "http://www.yoursite.com";
 $data = array(
 "key1" => "value1",
 "key2" => "value2",
 );

 $ch = curl_init();
 curl_setopt($ch, CURLOPT_URL, $url);
 curl_setopt($ch, CURLOPT_USERAGENT, $agent);
 curl_setopt($ch, CURLOPT_REFERER, $ref_url);

 curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
 curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);

 curl_setopt($ch, CURLOPT_POST, TRUE);
 curl_setopt($ch, CURLOPT_POSTFIELDS, $data);

 curl_setopt($ch, CURLOPT_TIMEOUT, 1);

 curl_exec($ch);
 curl_close($ch);

如果是cURL 7.16.2 or higher and PHP 5.2.3 or above，可以设置Timeout时间为1 ms，实现立即返回，修改如上的curl_setopt($ch, CURLOPT_TIMEOUT, 1);为curl_setopt($ch, CURLOPT_TIMEOUT_MS, 1);。
方法2：使用socket修改HTTP header

使用socket连接到server上，发送raw HTTP header(注意设置Connection: Close)，完成之后立即关闭socket不等待server做出响应再返回。
GET例子

需要请求的server url为http://example.com/Default.aspx，接受的参数为action=start，method 为GET，需要携带的cookies为ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah。(这些信息都可以使用HttpWatch分析得到)。

例如HttpWatch的分析的client端的HTTP请求为：

 GET /Default.aspx?action=start HTTP/1.1
 Accept-Language: zh-cn
 User-Agent: Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.1; Trident/4.0; .NET CLR 2.0.50727)
 Accept-Encoding: gzip, deflate
 Host: example.com
 Connection: Keep-Alive
 Cookie: ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah

修改为异步HTTP请求：

 <?php

 $host = "example.com";
 $path = "/Default.aspx?action=start";
 $cookie = "ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah";

 $start = microtime(true);

 $fp = fsockopen($host, 80, $errno, $errstr, 30);
 if (!$fp) {
 print "$errstr ($errno) \n";
 exit;
 }
 $out = "GET ".$path." HTTP/1.1\r\n";
 $out .= "Host: ".$host."\r\n"; //需要注意Host不能包括`http://`，仅可以使用`example.com`
 $out .= "Connection: Close\r\n";
 $out .= "Cookie: ".$cookie."\r\n\r\n";

 fwrite($fp, $out); //将请求写入socket

 /*
 //也可以选择获取server端的响应
 while (!feof($fp)) {
 echo fgets($fp, 128);
 }
 */

 //如果不等待server端响应直接关闭socket即可
 fclose($fp);

 $cost = microtime(true) - $start;
 print "\n".$cost."\n";
 exit;

POST例子

需要请求的server url为http://example.com/Login.aspx，接受的参数为username=my-username&password=my-password，method 为POST，需要携带的cookies为ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah。(这些信息都可以使用HttpWatch分析得到)。

例如HttpWatch的分析的client端的HTTP请求为：

 POST /Login.aspx HTTP/1.1
 Accept-Language: zh-cn
 User-Agent: Mozilla/4.0 (compatible; MSIE 8.0; Windows NT 5.1; Trident/4.0; .NET CLR 2.0.50727)
 Content-Type: application/x-www-form-urlencoded
 Accept-Encoding: gzip, deflate
 Host: example.com
 Connection: Keep-Alive
 Cache-Control: no-cache
 Cookie: ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah

 username=my-username&password=my-password

修改为异步HTTP请求：

 <?php

 $host = "example.com";
 $path = "/Login.aspx";
 $cookie = "ASP.NET_SessionId=zfyaimqgtt1bfiewq0najgah";
 $params = "username=my-username&password=my-password";

 $start = microtime(true);

 $fp = fsockopen($host, 80, $errno, $errstr, 30);
 if (!$fp) {
 print "$errstr ($errno) \n";
 exit;
 }
 $out = "POST ".$path." HTTP/1.1\r\n";
 $out .= "Host: ".$host."\r\n";
 $out .= "Connection: Close\r\n";
 $out .= "Cookie: ".$cookie."\r\n\r\n";
 $out .= $params;

 fwrite($fp, $out);

 /*
 //也可以选择获取server端的响应
 while (!feof($fp)) {
 echo fgets($fp, 128);
 }
 */

 //如果不等待server端响应直接关闭socket即可
 fclose($fp);

 $cost = microtime(true) - $start;
 print "\n".$cost."\n";
 exit;

clq

2017-10-31 09:59:17 发表编辑

使用fscok实现异步调用PHP

    作者: Laruence( )
    本文地址: http://www.laruence.com/2008/04/16/98.html
    转载请注明出处

     Web 服务器执行一个脚本，可能几毫秒就完成，也可能几分钟都完不成。如果程序执行缓慢，用户可能没有耐心等下去，就关闭浏览器了。
    而有的时候，我们更本不关心这些耗时的脚本的执行结果，但却还要等他执行完返回，才能继续下一步。
    那么有没有什么办法，只是简单的触发调用这些耗时的脚本然后就继续下一步，让这些耗时的脚本在服务端慢慢执行？

    接下来，我将使用fscokopen来实现这一功能。

    PHP是支持socket编程的，就是fsockopen，在以前做CMS的时候，我也曾经用过它做过smtp发信。
    fscokopen返回一个到远程主机连接的句柄。你可以像使用fopen返回的句柄一样，对她进行写fwrite，读取fgets, fread等操作。

    我们的异步PHP，主要想要的效果就是，触发一个PHP脚本，然后立即返回，留它在服务器端慢慢执行。前面我也写过一篇文章讨论过这个问题。

    那么，我们就可以使用fsockopen连接到本地服务器，触发脚本执行，然后立即返回，不等待脚本执行完成。

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

    现在，就可以通过这个函数来触发一个PHP脚本的执行，然后函数就会返回。我们就可以接着执行下一步操作了。

   还有一个问题就是，当客户端断开连接以后。也就是triggerRequest发送请求后，立即关闭了连接，那么可能会引起服务器端正在执行的脚本退出。

   在 PHP 内部，系统维护着连接状态，其状态有三种可能的情况：

    * 0 – NORMAL（正常）

    * 1 – ABORTED（异常退出）

    * 2 – TIMEOUT（超时）

     当 PHP 脚本正常地运行 NORMAL 状态时，连接为有效。当客户端中断连接时，ABORTED 状态的标记将会被打开。远程客户端连接的中断通常是由用户点击 STOP 按钮导致的。当连接时间超过 PHP 的时限（请参阅 set_time_limit() 函数）时，TIMEOUT 状态的标记将被打开。

     可以决定脚本是否需要在客户端中断连接时退出。有时候让脚本完整地运行会带来很多方便，即使没有远程浏览器接受脚本的输出。默认的情况是当远程客户端连接中断时脚本将会退出。该处理过程可由 php.ini 的 ignore_user_abort 或由 Apache .conf 设置中对应的“php_value ignore_user_abort”以及 ignore_user_abort() 函数来控制。如果没有告诉 PHP 忽略用户的中断，脚本将会被中断，除非通过 register_shutdown_function() 设置了关闭触发函数。通过该关闭触发函数，当远程用户点击 STOP 按钮后，脚本再次尝试输出数据时，PHP 将会检测到连接已被中断，并调用关闭触发函数。

     脚本也有可能被内置的脚本计时器中断。默认的超时限制为 30 秒。这个值可以通过设置 php.ini 的 max_execution_time 或 Apache .conf 设置中对应的“php_value max_execution_time”参数或者 set_time_limit() 函数来更改。当计数器超时的时候，脚本将会类似于以上连接中断的情况退出，先前被注册过的关闭触发函数也将在这时被执行。在该关闭触发函数中，可以通过调用 connection_status() 函数来检查超时是否导致关闭触发函数被调用。如果超时导致了关闭触发函数的调用，该函数将返回 2。

     需要注意的一点是 ABORTED 和 TIMEOUT 状态可以同时有效。这在告诉 PHP 忽略用户的退出操作时是可能的。PHP 将仍然注意用户已经中断了连接但脚本仍然在运行的情况。如果到了运行的时间限制，脚本将被退出，设置过的关闭触发函数也将被执行。在这时会发现函数 connection_status() 返回 3。

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

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

     或者，也可以使用:
register_shutdown_function(callback fuction[, parameters]);//注册脚本退出时执行的函数

clq

2017-10-31 10:04:41 发表编辑

??

clq

2017-10-31 10:05:17 发表编辑

??

NEWBT官方QQ群1: 276678893
可求档连环画,漫画;询问文本处理大师等软件使用技巧;求档softhub软件下载及使用技巧.
但不可"开车",严禁国家敏感话题,不可求档涉及版权的文档软件.
验证问题说明申请入群原因即可.