关于PHP实现异步操做的研究

1.为啥PHP须要异步操做?
通常来讲PHP适用的场合是web页面展现等耗时比较短的任务,若是对于比较花时间的操做如resize图片、大数据导入、批量发送EDM、SMS等,就很容易出现操做超时状况。你能够说我能够设置无限超时时间,等等你也要知道PHP有一个工做模式是fastcgi,PHP无限不超时,不表明 fastcgi相应不超时……若是你还想说要fastcgi相应永不超时,我建议你应该跟大家的运维人员讨论去……
这个时候异步的操做就发挥他的做用了,因为是非阻塞操做,操做会即时返回,而后在后台再慢慢干活。管你超时不超时的,我就没有在当前的进程/线程下干活。看吧是否是很美好,不过其实这也是个坑……php


2.PHP能够实现异步操做吗?
答案是确定的,不过网上各类的纯PHP实现得就有点别扭了。socket模式、挂起进程模式、有的还直接fork进程。很好,各路神仙各显神通。若是运维人员看到的话,必定会×××××大家的,不把web server跑死才怪……
那还有其余更好的方法去实现这个异步操做的可能么?有,如今咱们只有想怎么开外挂了。查一下PECL主流的外挂方案有一堆的××MQ(消息队列),其中有个用于任务分配的外挂进入了咱们的视线Gearman(其实这家伙才是角,我就不详细介绍了,点链接看介绍)。java


3.为啥选择Gearman?
别的不说,就说他的client多,支持不少语言的client,你能够使用大部分你喜欢的语言去写worker。我我的是很烦语言之争,你喜欢用神码语言写worker都随你喜欢。有数据持久化支持(就是把队列保存到数据库介质中,那故障恢复也好作),有群集支持(其实不少××MQ都有这些功能)。 PECL上有扩展,也有纯PHP实现扩展。反正这个Gearman也活了好久了,杂七杂八的问题都基本上解决了。node


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的部分先上测试代码:python

 

  1. <?php 
  2. require_once'PHPAsyncClient.php'
  3. date_default_timezone_set('Asia/Shanghai'); 
  4. class AsyncTest { 
  5.     const
  6.         LOG_FILE = '/debug.log'
  7.     staticpublicfunction run() { 
  8.         if (PHPAsyncClient::in_callback(__FILE__)) { 
  9.             self::log('php Async callback'); 
  10.             PHPAsyncClient::parse(); 
  11.             return
  12.         } 
  13.         if (PHPAsyncClient::is_main(__FILE__)) { 
  14.             self::log('main run'); 
  15.             $async_call = PHPAsyncClient::getInstance(); 
  16.             $async_call->AsyncCall('AsyncTest', 'callback', array
  17.                 'content' => 'Hello World!!!'
  18.             ), array
  19.                 'class' => 'AsyncTest'
  20.                 'method' => 'callback'
  21.                 'params' => array
  22.                     'content' => 'Hello Callback!'
  23.                 ), 
  24.             ), __FILE__); 
  25.             return
  26.         } 
  27.     } 
  28.     staticpublicfunction callback($args) { 
  29.         self::log('AsyncTest callback run'); 
  30.         self::log('AsyncTest callback args:'.print_r($args, true)); 
  31.     } 
  32.     staticpublicfunction log($content) { 
  33.         $fullname = dirname(__FILE__).self::LOG_FILE; 
  34.         $content = date('[Y-m-d H:i:s]').$content."\n"
  35.         file_put_contents($fullname, $content, FILE_APPEND); 
  36.     } 
  37. AsyncTest::run();

就3个静态方法,一个是用于调试的log方法,其余都是字面意思。这个例子是对这种调用方式有个初步印象。而后直接上PHP的全部源码:
php_async.zip
而后应该会有不少人会说,win下安装不了gearman……因此我把java版的gearman server也放上去吧。
java-gearman-service-0.6.6.zip
linux


5.结论
通过以上配置犀牛同样大的家伙后(要装一个Gearman,还要跑个Py脚本),咱们基本上就使PHP拥有了异步调用功能,固然其中还有一个状态维护神马的要本身去实现。因此发现,其实这个方案不咋样,太复杂了。仍是使用一些web service的方式去作web callback会好点(问题是web callback同样会超时……),这个请留意后续。
web

相关文章
相关标签/搜索