js接收php回调,PHP实现类似javascript的setTimeout异步回调

在php中&＃xff0c;我们偶尔会希望这样的场景&＃xff1a;当执行某段程序的时候&＃xff0c;需要执行某个任务&＃xff0c;但是该任务并不需要立即执行&＃xff0c;而是需要延迟几秒再执行。这个功能正如Javascript的setTimeout&＃xff0c;但是php中并没有现成的异步功能&＃xff0c;php的单线程的&＃xff0c;所以要实现这个效果&＃xff0c;我们还需要想想其他的办法。

不过幸运的是&＃xff0c;php中提供了一种非阻塞的通信方式。因此&＃xff0c;我们创建下面这个类&＃xff1a;

class AsyncCallback {

private $auth;

public function __construct() {

$this->auth &＃61; substr(md5(&＃39;iosnae23a9a~40^33fsdf.adsfie*&＃39;),8,16); // 修改内容&＃xff0c;作为密钥

$headers &＃61; array();

foreach ($_SERVER as $key &＃61;> $value) {

if(&＃39;HTTP_&＃39; &＃61;&＃61; substr($key,0,5)) {

$key &＃61; substr($key,5);

$key &＃61; strtolower($key);

$headers[$key] &＃61; $value;

}

}

$this->headers &＃61; $headers;

if(isset($this->headers[&＃39;auth&＃39;]) && $this->headers[&＃39;auth&＃39;] &＃61;&＃61; $this->auth) {

ignore_user_abort();

set_time_limit(0);

$event &＃61; $this->headers[&＃39;event&＃39;];

$data &＃61; $this->headers[&＃39;data&＃39;];

parse_str($data,$data);

call_user_func(array($this,$event.&＃39;Callback&＃39;),$data);

exit;

}

}

public function setTimeout($function,$timeout) {

$this->sock(&＃39;setTimeout&＃39;,array(&＃39;function&＃39; &＃61;> $function,&＃39;timeout&＃39; &＃61;> $timeout));

}

private function setTimeoutCallback($data) {

$function &＃61; $data[&＃39;function&＃39;];

$timeout &＃61; $data[&＃39;timeout&＃39;];

sleep($timeout);

call_user_func($function);

}

private function sock($event,$data) {

$url &＃61; $this->current_url();

$host &＃61; parse_url($url,PHP_URL_HOST);

$path &＃61; parse_url($url,PHP_URL_PATH);

$query &＃61; parse_url($url,PHP_URL_QUERY);

if($query)

$path .&＃61; &＃39;?&＃39;.$query;

$port &＃61; parse_url($url,PHP_URL_PORT);

$port &＃61; $port ? $port : 80;

$scheme &＃61; parse_url($url,PHP_URL_SCHEME);

if($scheme &＃61;&＃61; &＃39;https&＃39;)

$host &＃61; &＃39;ssl://&＃39;.$host;

$data &＃61; http_build_query($data);

$fp &＃61; fsockopen($host,$port,$errno,$errstr,1);

if(!$fp) {

return false;

}

stream_set_blocking($fp,0);

stream_set_timeout($fp,1);

$header &＃61; "GET $path  / HTTP/1.1\r";

$header .&＃61; "Host: $host\r";

$header .&＃61; "Event: $event\r";

$header .&＃61; "Data: $data\r";

$header .&＃61; "Auth: {$this->auth}\r";

$header .&＃61; "Connection: Close\r\r";

fwrite($fp,$header);

fclose($fp);

return true;

}

private function current_url() {

$url &＃61; $_SERVER[&＃39;HTTP_HOST&＃39;].$_SERVER[&＃39;REQUEST_URI&＃39;];

if(!isset($_SERVER[&＃39;HTTPS&＃39;]))

$url &＃61; &＃39;http://&＃39;.$url;

elseif($_SERVER[&＃39;HTTPS&＃39;] &＃61;&＃61;&＃61; 1 || $_SERVER[&＃39;HTTPS&＃39;] &＃61;&＃61;&＃61; &＃39;on&＃39; || $_SERVER[&＃39;SERVER_PORT&＃39;] &＃61;&＃61; 443)

$url &＃61; &＃39;https://&＃39;.$url;

else

$url &＃61; &＃39;http://&＃39;.$url;

return $url;

}

}

我们来看下具体的用法&＃xff1a;

require &＃39;AsyncCallback.class.php&＃39;;

$AsyncCallback &＃61; new AsyncCallback();

file_put_contents(&＃39;./runtime/setTimeout.txt&＃39;,&＃39;[&＃39;.date(&＃39;Y-m-d H:i:s&＃39;).&＃39;][&＃39;.microtime().&＃39;] 我先处理一点事情&＃39;,LOCK_EX);

$AsyncCallback->setTimeout(&＃39;setTimeout&＃39;,10);

function setTimeout() {

file_put_contents(&＃39;./runtime/setTimeout.txt&＃39;,"".&＃39;[&＃39;.date(&＃39;Y-m-d H:i:s&＃39;).&＃39;][&＃39;.microtime().&＃39;] 我是延时执行的结果&＃39;,FILE_APPEND);

}

file_put_contents(&＃39;./runtime/setTimeout.txt&＃39;,"".&＃39;[&＃39;.date(&＃39;Y-m-d H:i:s&＃39;).&＃39;][&＃39;.microtime().&＃39;] 我再处理一点事情&＃xff0c;看看是否有时间差距&＃39;,FILE_APPEND);

接下来我们来解释一下这里面都做了什么。

首先&＃xff0c;sock()方法

我们来具体分析一下sock方法中fsockopen的用法。fsockopen开启了一个fsock通信&＃xff0c;stream_set_blocking()函数的第二个参数设置为0&＃xff0c;声明这个fsock为非阻塞模式&＃xff0c;也就是说&＃xff0c;下次在调用$this->sock()的时候&＃xff0c;程序是流畅执行的&＃xff0c;fsock发出请求时&＃xff0c;不会阻塞进程&＃xff0c;fsock发出请求后就继续往下执行&＃xff0c;而无需得到结果。

fsock使用fwrite或fput发出请求&＃xff0c;其中第二个参数需要我们自己构造http header信息&＃xff0c;你需要了解http协议的东西&＃xff0c;构造header可以帮我们实现get、post、head、put、delete等多种请求方式。

总之&＃xff0c;sock()方法&＃xff0c;帮我们实现非阻塞的发出请求。

其次&＃xff0c;异步执行

我们来看下__construct()方法中的 if(isset($this->headers[&＃39;auth&＃39;]) && $this->headers[&＃39;auth&＃39;] &＃61;&＃61; $this->auth) 的内容。

ignore_user_abort();

set_time_limit(0);

这两句可以帮助程序在后台继续执行&＃xff0c;即使访问被客户端关闭&＃xff0c;也就是说fsock发出的非阻塞请求虽然并没有等结果返回&＃xff0c;但是我们如此声明以后&＃xff0c;程序仍然会继续执行&＃xff0c;不会被中断。

call_user_func(array($this,$event.&＃39;Callback&＃39;),$data);

这句则是调用当前事件的回调函数(方法)&＃xff0c;这里就是$this->setTimeoutCallback()&＃xff0c;而在setTimeoutCallback()中&＃xff0c;使用了

call_user_func($function);

也就是调用我们第二段代码中规定的那个setTimeout()函数。

最后&＃xff0c;回调函数

而这个setTimeout()函数就是回调函数&＃xff0c;它会在fsock请求的终端进行执行&＃xff0c;而它的执行将会开启一个新的php进程&＃xff0c;不会影响当前的这个页面的程序的执行(虽然它是被写在当前页面内的)。

关于php的进程&＃xff0c;请阅读《PHP进程分支设计》&＃xff0c;了解php单线程的局限。

总之&＃xff0c;你只需要在你的程序中引入AsyncCallback类&＃xff0c;并且实例化后如下操作即可&＃xff1a;

$AsyncCallback &＃61; new AsyncCallback();

$AsyncCallback->setTimeout(&＃39;setTimeout&＃39;,10);

function setTimeout() {    // 延时执行的代码

}

不过&＃xff0c;本类的使用&＃xff0c;也有一些缺陷&＃xff1a;

和Javascript不同&＃xff0c;该类不能在界面展示上实现异步展示&＃xff0c;而只能实现任务上的异步

必须在页面开头的地方实例化类&＃xff0c;因为回调是在类的构造方法中实现的

不能和主进程通信&＃xff0c;这一点是最大的缺陷

2016-02-18

8242