PHP之pcntl_fork多进程并发编程示例
admin
2023-06-23 11:41:56
0

    待下载的网页地址放在$urls数组中,按指定的并发数多进程下载网页,下载的网页保存在本地硬盘,下载的网页大小通过linux消息队列发送给父进程累加,全部网页下载完成后,父进程显示下载的网页数、字节数。代码如下。

0) {//父进程
}
elseif ($pids[$ct]==0) {//子进程
download($urls[$ct], $msg_queue);
exit(0);
}
$cttask++;
$ct++;
}
$tmppid = pcntl_waitpid(0, $status);//等待子进程结束
foreach($pids as $key => $pid) {
    if($tmppid == $pid){
    unset($pids[$key]);
    $cttask--;//子进程结束后,并发进程计数器减1
    }
}
do {//从消息队列出取出每个网页的大小,计算下载的字节数。如果要下载的网页很多,需要把此段代码放到下载网页的循环中,否则可能会出现队列满的情况。
msg_receive($msg_queue, 0, $message_type, 16, $message, true, MSG_IPC_NOWAIT); 
//echo "[".$message."]\n";
$total_bytes += $message;
$a = msg_stat_queue($msg_queue);
if($a['msg_qnum'] == 0){//这种方式退出比$ct==$urls_num好,因为如果fork==-1,就不会有$urls_num个消息,程序会永远等待消息。
    break;
}
} while(true);
}
while ($cttask > 0) {//等待最后$cttask个子进程结束
$tmppid = pcntl_waitpid(0,$status);
foreach($pids as $key => $pid) {
    if($tmppid == $pid){
    unset($pids[$key]);
    $cttask--;
    }
}
}
do {//取得最后$cttask个子进程的消息
msg_receive($msg_queue, 0, $message_type, 16, $message, true, MSG_IPC_NOWAIT); 
//echo "[".$message."]\n";
$total_bytes += $message;
$a = msg_stat_queue($msg_queue);
if($a['msg_qnum'] == 0){
    break;
}
} while(true);
msg_remove_queue($msg_queue);//删除消息队列
echo "\nDone. download: ".$urls_num." pages,total: ".round($total_bytes/1024,3)." KB \n";
exit(0);
function download($url, $msg_queue) {//下载指定网页,把内容保存在本地硬盘,并下载内容的长度放入消息队列中
$dirname = "/tmp/donwload/";//保存下载网页的目录,要事先创建好
$content = file_get_contents($url);
if ($content === false) {
$content = 0;
}
$url_parts = parse_url($url);
$fname = $dirname.$url_parts['host'];
$ret = file_put_contents($fname, $content);
msg_send($msg_queue, 1, strlen($content));
} 
?>

参考资料:

PHP实现进程间通信:消息队列 https://www.douban.com/note/245520545/


相关内容

热门资讯

海军黄石舰最新演练画面 近日,北部战区海军某支队黄石舰开展海上多课目实战化训练。训练全程不设脚本、临机设置险情,突出专攻精练...
美财长:特朗普不会接受“糟糕的... △美国财政部长贝森特(资料图)当地时间5月28日,美国财政部长贝森特在简报会上表示,美国与伊朗谈判团...
知情人士:伊朗方面尚未同意任何... 当地时间5月28日,伊朗谈判代表团媒体团队成员赛义德·阿加卢表示,截至目前,伊朗方面尚未同意任何谅解...
古巴外长:古美双边谈判没有取得... △古巴外交部长罗德里格斯(资料图)当地时间5月28日,古巴外交部长布鲁诺·罗德里格斯表示,古巴与美国...
伊朗最高领袖强调维护民族团结 伊朗最高领袖穆杰塔巴28日发表书面讲话,强调维护民族团结与社会凝聚力,并呼吁伊朗各界共同维护国家统一...
消息称字节跳动正开发自有CPU... IT之家 5 月 28 日消息,据路透社援引三名知情人士消息称,由于芯片价格持续上涨、供应短缺时间拉...
李咏瑾: “科技的省心”,会不... “科技的省心”会不会日益造就人们“判断的懒惰”? 近日,两条有关“AI成为投诉对象甚至被告”的新闻,...
一卷胶带如何“撕”出诺贝尔奖?... 一层原子厚的材料,能有多神奇?日前,“追星就追科学家”校园公益科普活动邀请上海交通大学物理与天文学院...
广发银行多项成果入选“十四五”... 近日,第八届金融科技创新大会暨CITE2026人工智能与金融数智化创新发展论坛正式发布了“十四五”金...
人工智能如何构建伦理治理体系?... 5月28日,“智能时代的自主知识体系构建暨人工智能伦理与社会实验室建设学术研讨会”在华南师范大学举行...