知识大全深入解析PHP中的(伪)多线程与多进程

Posted 2022-07-21 知

篇首语：青春不以山海为远，志愿只向家国未来。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全深入解析PHP中的(伪)多线程与多进程相关的知识，希望对你有一定的参考价值。

深入解析PHP中的(伪)多线程与多进程 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

本篇文章是对PHP中的(伪)多线程与多进程进行了详细的分析介绍需要的朋友参考下

　　(伪)多线程借助外力 利用WEB服务器本身的多线程来处理从WEB服务器多次调用我们需要实现多线程的程序 QUOTE: 我们知道PHP本身是不支持多线程的但是我们的WEB服务器是支持多线程的也就是说可以同时让多人一起访问这也是我在PHP中实现多线程的基础假设我们现在运行的是a php这个文件但是我在程序中又请求WEB服务器运行另一个b php 那么这两个文件将是同时执行的 (PS: 一个链接请求发送之后 WEB服务器就会执行它而不管客户端是否已经退出) 有些时候我们想运行的不是另一个文件而是本文件中的一部分代码该怎么办呢? 其实可是通过参数来控制a php来运行哪一段程序 下面看一个例子:

复制代码代码如下: <?php function runThread() $fp = fsockopen( localhost $errno $errmsg); fputs($fp "GET /a php?act=brnrn");//这里的第二个参数是HTTP协议中规定的请求头不明白的请看RFC中的定义 fclose($fp); function a() $fp = fopen( result_a log w ); fputs($fp Set in Date( h:i:s time()) (double)microtime() "rn"); fclose($fp); function b() $fp = fopen( result_b log w ); fputs($fp Set in Date( h:i:s time()) (double)microtime() "rn"); fclose($fp); if(!isset($_GET[ act ])) $_GET[ act ] = a ;; if($_GET[ act ] == a ) runThread(); a(); else if($_GET[ act ] == b ) b(); ; ?>

　　打开result_a log 和 result_b log 比较一下两个文件的中访问的时间大家会发现这两个的确是在不同线程中运行的有些时间完全一样上面只是一个简单的例子大家可以改进成其它形式既然PHP中也能多线程了那么问题也来了那就是同步的问题我们知道 PHP本身是不支持多线程的所以更不会有什么像Java 中synchronize的方法了那我们该如何做呢

　　 尽量不访问同一个资源以避免冲突但是可以同时像数据库操作因为数据库是支持并发操作的所以在多线程的PHP中 不要向同一个文件中写入数据如果必须要写的话用别的方法进行同步如调用 flock对文件进行加锁等或建立临时文件并在另外的线程中等待这个文件的消失 while(file_exits( xxx )); 这样就等于这个临时文件存在时表示其实线程正在操作如果没有了这个文件说明其它线程已经释放了这个

　　 尽量不要从runThread在执行fputs后取这个socket中读取数据因为要实现多线程需要的用非阻塞模式 即在像fgets这样的函数时立即返回所以读写数据就会出问题如果使用阻塞模式的话程序就不算是多线程了他要等上面的返回才执行下面的程序所以如果需要交换数据最后利用外面文件或数据中完成实在想要的话就用socket_set_nonblock($fp) 来实现说了这么多倒底这个有没有实际的意义呢? 在什么时候需要这种用这种方法呢 ? 答案是肯定的大家知道在一个不断读取网络资源的应用中网络的速度是瓶颈如果采多这种形式就可以同时以多个线程对不同的页面进行读取本人做的一个能从 soaso这些商城网站搜索信息的程序还有一个从阿里巴巴网站上读取商业信息和公司目录的程序也用到了此技术因为这两个程序都是要不断的链接它们的服务器读取信息并保存到数据库利用此技术正好消除了在等待响应时的瓶颈

　　多进程使用PHP的Process Control Functions(PCNTL/线程控制函数) 只能用在Unix Like OS Windows不可用编译php的时候需要加上 enable pcntl 且推荐仅仅在CLI模式运行不要在WEB服务器环境运行 以下为简短的测试代码

复制代码代码如下: declare(ticks= ); $bWaitFlag = FALSE; /// 是否等待进程结束 $intNum = ; /// 进程总数 $pids = array(); /// 进程PID数组 echo ("Startn"); for($i = ; $i < $intNum; $i++) $pids[$i] = pcntl_fork();/// 产生子进程而且从当前行之下开试运行代码而且不继承父进程的数据信息 if(!$pids[$i]) // 子进程进程代码段_Start $str=""; sleep( +$i); for ($j= ;$j<$i;$j++) $str ="*"; echo "$i > " time() " $str n"; exit(); // 子进程进程代码段_End if ($bWaitFlag) for($i = ; $i < $intNum; $i++) pcntl_waitpid($pids[$i] $status WUNTRACED); echo "wait $i > " time() "n"; echo ("Endn");

　　 运行结果如下 CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest php Start End [qiao@oicq qiao]$ ps aux | grep "php" qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : /usr/local/php /b qiao pts/ S : : grep php [qiao@oicq qiao]$ > > * > ** > *** > **** > ***** > ****** > ******* > ******** > ********* [qiao@oicq qiao]$ 如果$bWaitFlag=TURE 则结果如下 CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest php Start > wait > > * wait > > ** wait > > *** wait > > **** wait > > ***** wait > > ****** wait > > ******* wait > > ******** wait > > ********* wait > End [qiao@oicq qiao]$ 从多进程的例子可以看出使用pcntl_fork()之后将生成一个子进程而且子进程运行的代码从pcntl_fork()之后的代码开始而子进程不继承父进程的数据信息(实际上是把父进程的数据做了一个全新的拷贝) 因而使用if(!$pids[$i]) 来控制子进程实际运行的代码段更详细的研究出于时间关系暂时没有进行你可以参考我给出的手册的链接

　　[文章二] 尝试php命令行脚本多进程并发执行 除了fork cli下的并发方式还有一种看我的例子: php不支持多线程但是我们可以把问题转换成“多进程”来解决由于php中的pcntl_fork只有unix平台才可以使用所以本文尝试使用popen来替代 下面是一个例子 被并行调用的子程序代码

复制代码代码如下: <?php if($argc== ) echo("argvn"); $arg = $argv[ ]; for($i= ; $i< ; $i++) echo($i " " time() " exec $arg n"); if($arg== php ) sleep( ); echo($i " " time() " exec $arg n"); sleep( ); else sleep( ); ?>

　　主调用者程序由他调用子进程同时并发的收集子程序的输出

复制代码代码如下: error_reporting(E_ALL); $handle = popen( php sub php php r ); $handle = popen( php sub php php r ); $handle = popen( php sub php php r ); echo " $handle ; " gettype($handle ) "n"; echo " $handle ; " gettype($handle ) "n"; echo " $handle ; " gettype($handle ) "n"; //sleep( ); while(!feof($handle ) || !feof($handle ) || !feof($handle ) ) $read = fgets($handle ); echo $read; $read = fgets($handle ); echo $read; $read = fgets($handle ); echo $read; pclose($handle ); pclose($handle ); pclose($handle );

　　下面是我机器上的输出 C:my_hunter>php exec php Resource id # ; resource Resource id # ; resource Resource id # ; resource exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php exec php **总结 ** **主程序循环等待子进程通过fgets或fread 把子进程的输出获取出来从时间戳上看的确实现了并发执行 ** 以后的改进 * popen打开的句柄是单向的如果需要向子进程交互可以使用proc_open * 使用数组和子函数代替while(!feof($handle )|| !feof($handle ) || !feof($handle ) )这种龌龊的写法 * 用fread一次把子进程已经产生的输出取完而不是每次一行一个并发执行shell任务的调度者本程序读取一个任务文件把里面的每行命令并发执行可以设置同时存在的子进程数目:

复制代码代码如下: /* 主任务管理器并发的执行子任务列表 */ include(" /mon/conf php"); include(" /mon/function php"); //开启的进程数 $exec_number = ; /***** main ********/ if($argc== ) echo("argvn"); $taskfile = $argv[ ]; //tasklist $tasklist = file($taskfile); $tasklist_len = count($tasklist); $tasklist_pos = ; $handle_list = array(); while( ) //子进程列表有空闲则填充补齐子进程列表 if($exec_number > count($handle_list) && $tasklist_pos < $tasklist_len) for($i=$tasklist_pos; $i<$tasklist_len; ) $mand = $tasklist[$i] ; $handle_list[] = popen($mand "r" ); tolog("begin task t " $tasklist[$i]); $i++; if($exec_number == count($handle_list)) break; $tasklist_pos = $i; //如果子进程列表空退出 if( == count($handle_list)) break; //检查子进程列表的输出把停掉的子进程关闭并记录下来 $end_handle_keys = array(); foreach($handle_list as $key => $handle) //$str = fgets($handle ); $str = fread($handle ); echo($str); if(feof($handle)) $end_handle_keys[] = $key; pclose($handle); //踢出停掉的子进程 foreach($end_handle_keys as $key) unset($handle_list[$key]); //var_dump($handle_list); //exit; tolog("nn*******************end**********************nn" "" true);

　　 附加一段Socket多进程接收的代码

复制代码代码如下: cha138/Article/program/PHP/201311/21087

知识大全 深入解析PHP中的(伪)多线程与多进程

知识大全深入解析PHP中的(伪)多线程与多进程