脚本宝典收集整理的这篇文章主要介绍了如何构建PHP队列系统,脚本宝典觉得挺不错的,现在分享给大家,也给大家做个参考。
下面是queue.PHP的代码,从shell运行(puTTy或somesuch).
<?PHP //. set this constant to false if we ever need to debug //. the application in a terminal. define('QUEUESERVER_FORK',true); //////// fork into a background PRocess //////// if(QUEUESERVER_FORK){ $pid = pcntl_fork(); if($pid === -1) die('error: unable to fork.'); else if($pid) exIT(0); posix_setsid(); sleep(1); ob_start(); } $queue = array(); //////// SETUP our named piPE //////// $pipefile = '/tmp/queueserver-input'; if(file_exists($pipefile)) if(!unlink($pipefile)) die('unable to remove stale file'); umask(0); if(!posix_mkfifo($pipefile,0666)) die('unable to create named pipe'); $pipe = fopen($pipefile,'r+'); if(!$pipe) die('unable to open the named pipe'); stream_set_blocking($pipe,false); //////// process the queue //////// while(1){ while($input = trim(fgets($pipe))){ stream_set_blocking($pipe,false); $queue[] = $input; } $job = current($queue); $jobkey = key($queue); if($job){ echo 'processing job ',$job,PHP_EOL; process($job); next($queue); unset($job,$queue[$jobkey]); }else{ echo 'no jobs to do - waiting...',PHP_EOL; stream_set_blocking($pipe,true); } if(QUEUESERVER_FORK) ob_clean(); } ?>
我的问题是“如果服务器必须重新启动,我如何才能自动启动作业?”
通过将其添加到服务器启动时启动的事物列表中.不幸的是,这样做的说明因操作系统和操作系统版本而异.您可能希望使用更多跨平台的东西.我有很多运气与supervisor,你可以在你选择的操作系统的包回购中找到.
那就是说,你正走在疯狂的路上.你正在做的事情之前已经完成了,更好的是,由令人敬畏的人.查看Gearman工作队列系统和随附的PECL extension.发生这样的情况,主管也非常方便让您的Gearman工作人员保持活力.
以上是脚本宝典为你收集整理的如何构建PHP队列系统全部内容,希望文章能够帮你解决如何构建PHP队列系统所遇到的问题。
本图文内容来源于网友网络收集整理提供,作为学习参考使用,版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ:384754419,请注明来意。