php异步学习(2)

 

PHP开启异步多线程执行脚本

 

场景要求

客户端调用服务器a.php接口,需要执行一个长达5s-20s不等的耗资源操作,但是客户端响应请求时间为5秒(微信公众账号服务器请求响应超时时间),5s以上无回复即断开连接。

解决设想

客户端调用a.php之后,a.php执行异步多线程操作调用b.php,a.php调用成功后即刻反馈给客户端回执,b.php自动执行耗资源操作。

难点

PHP没有真正实现多线程操作的方法。所以需要通过其它手段来进行模拟多线程。

方案一

利用CURL非阻塞调用b.php,实现过程可以参考
http://blog.csdn.net/linvo/article/details/5956629
但是有一个问题,就是a.php会继续等待b.php的响应。
于是临时想了一个解决方案:
在此处代码中,将$curlopt_timeout改为1
[php] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. /**  
  2.      * 单个CURL调用超时限制   
  3.      */    
  4.     public $curlopt_timeout = 1;    
  5.     private $param = array();    

但是这样做就违背了curl本身的逻辑限制。
 

方案二

利用socket
在a.php中加入以下代码
[php] view plaincopy在CODE上查看代码片派生到我的代码片
 
  1. $fp = fsockopen("test.com", 80, $errno, $errstr, 30);  
  2. if (!$fp){  
  3.     echo 'error fsockopen';  
  4. }  
  5. else{  
  6.     stream_set_blocking($fp,0);  
  7.     $http = "GET /test/b.php HTTP/1.1 ";      
  8.     $http .= "Host: test.com ";      
  9.     $http .= "Connection: Close ";  
  10.     fwrite($fp,$http);  
  11.     fclose($fp);  
  12. }  
即可实现a.php调用b.php无阻塞。
代码中stream_set_blocking函数用来设定socket链接为无阻塞方式(默认为阻塞)。
 

问题

在使用方案二以后,遇到了一个问题,即客户端短时间内多次调用a.php,出现部分请求 没有执行b.php 的情况。
解决方法:
在Nginx的nginx.conf文件中,查看worker_processes为1,判断服务端响应请求的线程启动限制太大,得知服务器本身配置为双核CPU,判断2-4线程比较合适,于是修改worker_processes为4.问题得到解决!
 
 
 
 
 
 
 
 
 
 

PHP利用fastcgi_finish_request()函数实现异步操作,提高响应速度

发布时间: 2014-01-22 浏览次数:3802 分类: PHP教程

某些操作,如用户注册后邮件发送,记录日志等一些耗时操作可以转化为异步操作!当PHP运行在FastCGI模式是提供了fastcgi_finish_request()函数,看下面例子:

  1. <?php
  2.  
  3. echo '输出给客户端的内容';
  4.  
  5. fastcgi_finish_request();
  6. sleep(3);
  7.  
  8. echo '放心吧,这里的内容并不会输出';
  9.  
  10. file_put_contents('log.txt', '这是客户端响应结束后,服务器段脚本继续执行后生成');

运行了次脚本,你会发现客户端输出上面一句话,fastcgi_finish_request()下面的内容并没有输出,但是却生成了文件,如此说明了调用了fastcgi_finish_request后,客户端响应就已经结束,但与此同时服务端脚本却继续运行。这在一定程度上提高了响应速度,当然更科学的做法是:使用fastcgi_finish_request()函数集成队列消息,可以把消息异步发 送到队列。
fastcgi_finish_reques()函数的缺点:
1.PHP FastCGI 进程数有限,正在处理异步操作的php-cgi进程,无法处理新请求;
2.如果并发访问量较大,php-cgi进程数用满,新访问请求,将没有php-cgi去处理。Nginx服务器会出现: 502 Bad Gateway。
 
 
 
 
*******************************

浏览器和服务器之间是通过 HTTP 协议进行连接通讯的。这是一种基于请求和响应模型的协议。浏览器通过 URL 向服务器发起请求,Web 服务器接收到请求,执行一段程序,然后做出响应,发送相应的html代码给客户端。

这就有了一个问题,Web 服务器执行一段程序,可能几毫秒就完成,也可能几分钟都完不成。如果程序执行缓慢,用户可能没有耐心等下去,就关闭浏览器了。

而有的时候,我们更本不关心这些耗时的脚本的返回结果,但却还要等他执行完返回,才能继续下一步。
那么有没有什么办法,只是简单的触发调用这些耗时的脚本然后就继续下一步,让这些耗时的脚本在服务端慢慢执行?

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

2. popen()

resource popen ( string command, string mode );
//打开一个指向进程的管道,该进程由派生给定的 command 命令执行而产生。打开一个指向进程的管道,该进程由派生给定的 command 命令执行而产生。

所以可以通过调用它,但忽略它的输出。

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

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

3. 使用CURL
这个方法,设置CUROPT_TIMEOUT为1(最小为1,郁闷)。也就是说,客户端至少必须等待1秒钟。

  1. $ch = curl_init();
  2.  
  3. $curl_opt = array(CURLOPT_URL, 'http://www.example.com/backend.php',
  4.                             CURLOPT_RETURNTRANSFER, 1,
  5.                             CURLOPT_TIMEOUT, 1,);
  6.  
  7. curl_setopt_array($ch, $curl_opt);
  8.  
  9. curl_exec($ch);
  10.  
  11. curl_close($ch);

4. 使用fsockopen
这个方法应该是最完美的,但是缺点是,你需要自己拼出HTTP的header部分。

  1. $fp = fsockopen("www.example.com", 80, $errno, $errstr, 30);
  2. if (!$fp) {
  3.     echo "$errstr ($errno)<br /> ";
  4. } else {
  5.     $out = "GET /backend.php / HTTP/1.1 ";
  6.     $out .= "Host: www.example.com ";
  7.     $out .= "Connection: Close ";
  8.  
  9.     fwrite($fp, $out);
  10.     /*忽略执行结果
  11. while (!feof($fp)) {
  12. echo fgets($fp, 128);
  13. }*/
  14.     fclose($fp);
  15. }

所以,总体来看,最好用,最简单的还是第一种方法。
最完美的应该是最后一种,但是比较复杂
如果有更好的办法,欢迎交流。

原文地址:https://www.cnblogs.com/clphp/p/4913214.html