swoole如何创建多进程协同处理数据?比如一个很大的日志文件,需要多进程分段统计,类似于hadoop的map reduce方法。
网友回复
这是一个创建多进程来协同并发同时抓取数据汇总的示例代码:
<?php
$url_arr = array();
for ($i=0;$i<10;$i++){
$url_arr[] = "www.baidu.com?wd=".$i;
}
echo "开始执行:".date("Y-m-d H:i:s").PHP_EOL;
$_begintime=time();
$workers = array();
for ($i=0;$i<5;$i++){
$process = new swoole_process('getContents',true);
$process->start();
$process->write($i);
$workers[] = $process;
}
//主...点击查看剩余70%


