1.为啥PHP须要异步操做？javascript
通常来讲PHP适用的场合是web页面展现等耗时比较短的任务，若是对于比较花时间的操做如resize图片、大数据导入、批量发送EDM、SMS等，就很容易出现操做超时状况。你能够说我能够设置无限超时时间，等等你也要知道PHP有一个工做模式是fastcgi，PHP无限不超时，不表明fastcgi相应不超时……若是你还想说要fastcgi相应永不超时，我建议你应该跟大家的运维人员讨论去……php
这个时候异步的操做就发挥他的做用了，因为是非阻塞操做，操做会即时返回，而后在后台再慢慢干活。管你超时不超时的，我就没有在当前的进程/线程下干活。看吧是否是很美好，不过其实这也是个坑……html
2.PHP能够实现异步操做吗？java
答案是确定的，不过网上各类的纯PHP实现得就有点别扭了。socket模式、挂起进程模式、有的还直接fork进程。很好，各路神仙各显神通。若是运维人员看到的话，必定会×××××大家的，不把web server跑死才怪……node
那还有其余更好的方法去实现这个异步操做的可能么？有，如今咱们只有想怎么开外挂了。查一下PECL主流的外挂方案有一堆的××MQ（消息队列），其中有个用于任务分配的外挂进入了咱们的视线Gearman(其实这家伙才是角，我就不详细介绍了，点链接看介绍)。python
3.为啥选择Gearman?linux
别的不说，就说他的client多，支持不少语言的client，你可使用大部分你喜欢的语言去写worker。我我的是很烦语言之争，你喜欢用神码语言写worker都随你喜欢。有数据持久化支持（就是把队列保存到数据库介质中，那故障恢复也好作），有群集支持（其实不少××MQ都有这些功能）。PECL上有扩展，也有纯PHP实现扩展。反正这个Gearman也活了好久了，杂七杂八的问题都基本上解决了。web
4.基本思路数据库
有了Gearman这外挂就简单多了。就是向gearman发送一个任务，把执行的任务发出去，而后等待worker去调用PHP cli去运行咱们的php代码。编程
我就写了一下一个python的worker（别问我为啥用python，1.我会python，2.linux下不用装runtime），你能够本身根据思路写一个PHP的worker，不过嘛，本人是不太信得过PHP跑的worker。其余语言饭能够用java、node.js 或者其余语言实现一个worker试试。对用Golang写worker有兴趣的朋友能够找我。
phpasync_worker_py
很差意思，里面是没有注释的。一个配置文件，一个py脚本。基本的功能也就是分析一下调用的参数，而后调用PHP Cli，就是那样子而已。要让py脚本跑起来请自行安装python的gearman模块。
而后到PHP的部分先上测试代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
<?php
require_once
'PHPAsyncClient.php'
;
date_default_timezone_set(
'Asia/Shanghai'
);
class
AsyncTest {
const
LOG_FILE =
'/debug.log'
;
static
public
function
run() {
if
(PHPAsyncClient::in_callback(
__FILE__
)) {
self::log(
'php Async callback'
);
PHPAsyncClient::parse();
return
;
}
if
(PHPAsyncClient::is_main(
__FILE__
)) {
self::log(
'main run'
);
$async_call
= PHPAsyncClient::getInstance();
$async_call
->AsyncCall(
'AsyncTest'
,
'callback'
,
array
(
'content'
=>
'Hello World!!!'
,
),
array
(
'class'
=>
'AsyncTest'
,
'method'
=>
'callback'
,
'params'
=>
array
(
'content'
=>
'Hello Callback!'
,
),
),
__FILE__
);
return
;
}
}
static
public
function
callback(
$args
) {
self::log(
'AsyncTest callback run'
);
self::log(
'AsyncTest callback args:'
.print_r(
$args
, true));
}
static
public
function
log(
$content
) {
$fullname
= dirname(
__FILE__
).self::LOG_FILE;
$content
=
date
(
'[Y-m-d H:i:s]'
).
$content
.
"\n"
;
file_put_contents
(
$fullname
,
$content
, FILE_APPEND);
}
}
AsyncTest::run();
|
就3个静态方法，一个是用于调试的log方法，其余都是字面意思。这个例子是对这种调用方式有个初步印象。而后直接上PHP的全部源码：
php_async.zip
而后应该会有不少人会说，win下安装不了gearman……因此我把java版的gearman server也放上去吧。
java-gearman-service-0.6.6.zip
5.结论
通过以上配置犀牛同样大的家伙后（要装一个Gearman，还要跑个Py脚本），咱们基本上就使PHP拥有了异步调用功能，固然其中还有一个状态维护神马的要本身去实现。因此发现，其实这个方案不咋样，太复杂了。仍是使用一些web service的方式去作web callback会好点（问题是web callback同样会超时……），这个请留意后续。
*******************************************
PHP实现异步调用方法研究与分享
做者： 字体：[
增长
减少] 类型：转载 时间：2011-10-27
浏览器和服务器之间只一种面向无链接的HTTP协议进行通信的，面向无链接的程序的特色是客户端请求服务端，服务端根据请求输出相应的程序，不能保持持久链接
这样就出现了一个问题，一个客户端的相应服务端可能执行1秒也有可能执行1分钟，这样浏览器就会一直处于等待状态，若是程序执行缓慢，用户可能就没耐心关掉了浏览器。
而有的时候咱们不须要关心程序执行的结果，没有必要这样浪费时间和耐心等待，那咱们就要想出办法让程序不收等待在后台静默执行。
好比如今有一个场景，给1000个用户发送一封推荐邮件，用户输入或者导入邮件帐号了提交服务器执行发送。
<?php
$count=count($emailarr);
for($i=0;$i<$count;$i++)
{
sendmail(.....);//发送邮件
}
?>
这段代码用户体验极差，也没法实际运用，首先发送这么多邮件会产生服务器运行超时，其实漫长的用户等待时间会让用户对系统产品怀疑和失去信心。可是用户不须要等待到1000封邮件都发送完毕了才提交发送成功，咱们彻底能够提交后台后直接给用户提示发送成功，而后让后台程序静默依次发送。
这个时候咱们就须要“异步执行”技术来执行代码，异步执行的特色是后台静默执行，用户无需等待代码的执行结果，使用异步执行的好处：
1.摆脱了应用程序对单个任务的依赖性
2.提升了程序的执行效率
3.提升了程序的扩展性
4.在必定场景提升了用户体验
5.由于PHP不支持多线程，使用异步调用的请求多个HTTP的方式达到了程序并行执行效果，可是注意的是请求的HTTP过多的话，会大大加大了系统的开销
PHP异步执行的经常使用方式：
1.客户端页面采用AJAX技术请求服务器
1. 最简单的办法，就是在返回给客户端的HTML代码中，嵌入AJAX调用，或者，嵌入一个img标签，src指向要执行的耗时脚本。
这种方法最简单，也最快。服务器端不用作任何的调用。
可是缺点是，通常来讲Ajax都应该在onLoad之后触发，也就是说，用户点开页面后，就关闭，那就不会触发咱们的后台脚本了。
而使用img标签的话，这种方式不能称为严格意义上的异步执行。用户浏览器会长时间等待php脚本的执行完成，也就是用户浏览器的状态栏一直显示还在load。
固然，还可使用其余的相似原理的方法，好比script标签等等
2.popen()函数
resource popen ( string command, string mode );
//打开一个指向进程的管道，该进程由派生给定的 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.example.com", 80, $errno, $errstr, 30);
if (!$fp) {
echo "$errstr ($errno)<br />\n";
} else {
$out = "GET /backend.php / HTTP/1.1\r\n";
$out .= "Host: www.example.com\r\n";
$out .= "Connection: Close\r\n\r\n";
fwrite($fp, $out);
/*忽略执行结果
while (!feof($fp)) {
echo fgets($fp, 128);
}*/
fclose($fp);
}
因此，整体来看，最好用，最简单的仍是第一种方法。
最完美的应该是最后一种，可是比较复杂
若是有更好的办法，欢迎交流。
*******************************************************
1.使用Ajax 与 img 标记
原理，服务器返回的html中插入Ajax 代码或 img 标记，img的src为须要执行的程序。
优势：实现简单，服务端无需执行任何调用
缺点：在执行期间，浏览器会一直处于loading状态，所以这种方法并不算真正的异步调用。
$.get("doRequest.php", { name: "fdipzone"} );
<img src="doRequest.php?name=fdipzone">
2.使用popen
使用popen执行命令，语法：
// popen — 打开进程文件指针
resource popen ( string $command , string $mode )
pclose(popen('php /home/fdipzone/doRequest.php &', 'r'));
优势：执行速度快
缺点：1.只能在本机执行
2.不能传递大量参数
3.访问量高时会建立不少进程。
3.使用curl
设置curl的超时时间 CURLOPT_TIMEOUT 为1 （最小为1），所以客户端须要等待1秒
<?php
$ch = curl_init();
$curl_opt = array(
CURLOPT_URL, 'http://www.example.com/doRequest.php'
CURLOPT_RETURNTRANSFER,1,
CURLOPT_TIMEOUT,1
);
curl_setopt_array($ch, $curl_opt);
curl_exec($ch);
curl_close($ch);
?>
4.使用fsockopen
fsockopen是最好的，缺点是须要本身拼接header部分。
<?php
$url = 'http://www.example.com/doRequest.php';
$param = array(
'name'=>'fdipzone',
'gender'=>'male',
'age'=>30
);
doRequest($url, $param);
function doRequest($url, $param=array()){
$urlinfo = parse_url($url);
$host = $urlinfo['host'];
$path = $urlinfo['path'];
$query = isset($param)? http_build_query($param) : '';
$port = 80;
$errno = 0;
$errstr = '';
$timeout = 10;
$fp = fsockopen($host, $port, $errno, $errstr, $timeout);
$out = "POST ".$path." HTTP/1.1\r\n";
$out .= "host:".$host."\r\n";
$out .= "content-length:".strlen($query)."\r\n";
$out .= "content-type:application/x-www-form-urlencoded\r\n";
$out .= "connection:close\r\n\r\n";
$out .= $query;
fputs($fp, $out);
fclose($fp);
}
?>
注意：当执行过程当中，客户端链接断开或链接超时，都会有可能形成执行不完整，所以须要加上
ignore_user_abort(true); // 忽略客户端断开
set_time_limit(0); // 设置执行不超时
*************************
PHP异步调用socket
<?
$host = "www.aaa.com";
$path = "/Report.php?ReportID=1";
$cookie = Session_id();
$fp = fsockopen($host, 80, $errno, $errstr, 30);
if (!$fp) {
print "$errstr ($errno)<br />\n";
exit;
}
$out = "GET ".$path." HTTP/1.1\r\n";
$out .= "Host: ".$host."\r\n";
$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);
?>
**********************
php 异步调用方法
客户端与服务器端是经过HTTP协议进行链接通信，客户端发起请求，服务器端接收到请求后执行处理，并返回处理结果。
有时服务器须要执行很耗时的操做，这个操做的结果并不须要返回给客户端。但由于php是同步执行的，因此客户端须要等待服务处理完才能够进行下一步。
所以对于耗时的操做适合异步执行，服务器接收到请求后，处理完客户端须要的数据就返回，再异步在服务器执行耗时的操做。
1.使用Ajax 与 img 标记
原理，服务器返回的html中插入Ajax 代码或 img 标记，img的src为须要执行的程序。
优势：实现简单，服务端无需执行任何调用
缺点：在执行期间，浏览器会一直处于loading状态，所以这种方法并不算真正的异步调用。
- $.get("doRequest.php", { name: "fdipzone"} );
- <img src="doRequest.php?name=fdipzone">
2.使用popen
使用popen执行命令，语法：
- resource popen ( string $command , string $mode )
- pclose(popen('php /home/fdipzone/doRequest.php &', 'r'));
优势：执行速度快
缺点：1.只能在本机执行
2.不能传递大量参数
3.访问量高时会建立不少进程。
3.使用curl
设置curl的超时时间 CURLOPT_TIMEOUT 为1 （最小为1），所以客户端须要等待1秒
- <?php
- $ch = curl_init();
- $curl_opt = array(
- CURLOPT_URL, 'http://www.example.com/doRequest.php'
- CURLOPT_RETURNTRANSFER,1,
- CURLOPT_TIMEOUT,1
- );
- curl_setopt_array($ch, $curl_opt);
- curl_exec($ch);
- curl_close($ch);
- ?>
4.使用fsockopen
fsockopen是最好的，缺点是须要本身拼接header部分。
- <?php
-
- $url = 'http://www.example.com/doRequest.php';
- $param = array(
- 'name'=>'fdipzone',
- 'gender'=>'male',
- 'age'=>30
- );
-
- doRequest($url, $param);
-
- function doRequest($url, $param=array()){
-
- $urlinfo = parse_url($url);
-
- $host = $urlinfo['host'];
- $path = $urlinfo['path'];
- $query = isset($param)? http_build_query($param) : '';
-
- $port = 80;
- $errno = 0;
- $errstr = '';
- $timeout = 10;
-
- $fp = fsockopen($host, $port, $errno, $errstr, $timeout);
-
- $out = "POST ".$path." HTTP/1.1\r\n";
- $out .= "host:".$host."\r\n";
- $out .= "content-length:".strlen($query)."\r\n";
- $out .= "content-type:application/x-www-form-urlencoded\r\n";
- $out .= "connection:close\r\n\r\n";
- $out .= $query;
-
- fputs($fp, $out);
- fclose($fp);
- }
-
- ?>
注意：当执行过程当中，客户端链接断开或链接超时，都会有可能形成执行不完整，所以须要加上
- ignore_user_abort(true);
- set_time_limit(0);
Tips：关于fsockopen的介绍与用法能够参考我以前写的《php 利用fsockopen GET/POST 提交表单及上传文件》与《PHP HTTP请求类，支持GET,POST,Multipart/form-data》
**************************************
深刻PHP异步执行的详解
做者： 字体：[
增长
减少] 类型：转载 时间：2013-06-03
本篇文章是对PHP的异步执行进行了详细的分析介绍，须要的朋友参考下
Web服务器执行一个PHP脚本，有时耗时很长才能返回执行结果，后面的脚本须要等待很长一段时间才能继续执行。若是想实现只简单触发耗时脚本的执行而不等待执行结果就直接执行下一步操做，能够经过fscokopen函数来实现。
PHP支持socket编程，fscokopen函数返回一个到远程主机链接的句柄，能够像使用fopen返回的句柄同样，对它进行fwrite、fgets、fread等操做。使用fsockopen链接到本地服务器，触发脚本执行，而后当即返回，不等待脚本执行完成，便可实现异步执行PHP的效果。
示例代码以下：
<?
function triggerRequest($url, $post_data = array(), $cookie = array()){
$method = "GET"; //经过POST或者GET传递一些参数给要触发的脚本
$url_array = parse_url($url); //获取URL信息
$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_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;
}
这样就能够经过fsockopen()函数来触发一个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]);//注册脚本退出时执行的函数
