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%