[原创]简单的PHP的任务队列

jackxiang 2009-7-20 12:08 | |
写了一个简单的队列任务处理。多进程任务,异步任务可能会用到这个(主要是命令行应用)
比如,任务的某个一个环节速度十分不稳定,可能执行几秒,也可能执行几分钟,
我就可以把那个环节包括前面的部分扔进队列,多跑几个进程,同时往队列里面写。
然后后面比较快的环节只跑一个处理任务就OK了。让整体速度达到更好的效果。

write.php: 将任务写入队列

<?php
/*
产生队列
*/
//用微秒生成队列文件名。因为会有多个队列,所以加了一个identifier来区分各个队列
function mt($identifier='default')
{
        return sprintf("%.6f.%s",strtok(microtime(),' ')+strtok(''),$identifier);
}

while(1) //实际中尽量不要while(1) 非要while(1)记得任务完成要break
{
        if(count(glob('./queue/*.identifier'))>=10) //队列最大长度,不限制的话硬盘可能会受不了哦。
        {
                sleep(1);//记住这里要sleep,否则队列满了cpu占用很高
                continue;
        }
        $url = 'www.'.time().'.com'; //随便举个例子,我用时间戳生成了一个网址
        echo "$url\r\n";
        $fp = fopen('./queue/'.mt('identifier'),'w');
        fwrite($fp,$url);
        fclose($fp);
        sleep(1);//这里不需要sleep,我sleep是因为我的任务太简单。
}
?>


read.php:

<?php
/*
处理队列
*/

while(1) //实际程序最好不要while(1)如果while(1),记得处理完任务要break
{
        if($queue = glob('./queue/*.identifier'))
        {
                $q = array_shift($queue);
                $url = file_get_contents($q);
                echo $url."\r\n";
                unlink($q);
        }
        sleep(1);//这里要不要sleep或sleep多久自己凭感觉来。
}
?>

作者:jackxiang@向东博客 专注WEB应用 构架之美 --- 构架之美,在于尽态极妍 | 应用之美,在于药到病除
地址:https://jackxiang.com/post/1847/
版权所有。转载时必须以链接形式注明作者和原始出处及本声明!

评论列表
发表评论

昵称

网址

电邮

打开HTML 打开UBB 打开表情 隐藏 记住我 [登入] [注册]