深入解析PHP中的(伪)多线程与多进程-6ren

深入解析PHP中的(伪)多线程与多进程

转载作者：qq735679552 更新时间：2022-09-29 22:32:09

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章深入解析PHP中的(伪)多线程与多进程由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

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

复制代码代码如下:

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

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

。

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

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

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

复制代码代码如下:

 
 declare(ticks=1); 
 
 $bWaitFlag = FALSE; /// 是否等待进程结束 
 
 $intNum = 10;           /// 进程总数 
 
 $pids = array();        ///  进程PID数组 
 
 echo ("Start\n"); 
 
 for($i = 0; $i < $intNum; $i++) { 
 
   $pids[$i] = pcntl_fork();/// 产生子进程，而且从当前行之下开试运行代码，而且不继承父进程的数据信息 
 
   if(!$pids[$i]) { 
 
     // 子进程进程代码段_Start 
 
     $str=""; 
 
     sleep(5+$i); 
 
     for ($j=0;$j<$i;$j++) {$str.="*";} 
 
     echo "$i -> " . time() . " $str \n"; 
 
     exit(); 
 
     // 子进程进程代码段_End 
 
   } 
 
 } 
 
 if ($bWaitFlag) 
 
 { 
 
   for($i = 0; $i < $intNum; $i++) { 
 
     pcntl_waitpid($pids[$i], $status, WUNTRACED); 
 
     echo "wait $i -> " . time() . "\n"; 
 
   } 
 
 } 
 
 echo ("End\n");

运行结果如下： CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest.php Start End [qiao@oicq qiao]$ ps -aux | grep "php" qiao 32275 0.0 0.5 49668 6148pts/1 S 14:03 0:00/usr/local/php4/b qiao 32276 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32277 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32278 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32279 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32280 0.0 0.5 49668 6152pts/1 S 14:03 0:00 /usr/local/php4/b qiao 32281 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32282 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32283 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32284 0.0 0.5 49668 6152pts/1 S 14:03 0:00/usr/local/php4/b qiao 32286 0.0 0.0 1620 600pts/1 S 14:03 0:00 grep php [qiao@oicq qiao]$ 0 -> 1133503401 1 -> 1133503402 * 2 -> 1133503403 ** 3 -> 1133503404 *** 4 -> 1133503405 **** 5 -> 1133503406 ***** 6 -> 1133503407 ****** 7 -> 1133503408 ******* 8 -> 1133503409 ******** 9 -> 1133503410 ********* [qiao@oicq qiao]$ 如果$bWaitFlag=TURE，则结果如下： CODE:[Copy toclipboard][qiao@oicq qiao]$ phptest.php Start 0 -> 1133503602 wait 0 -> 1133503602 1 -> 1133503603 * wait 1 -> 1133503603 2 -> 1133503604 ** wait 2 -> 1133503604 3 -> 1133503605 *** wait 3 -> 1133503605 4 -> 1133503606 **** wait 4 -> 1133503606 5 -> 1133503607 ***** wait 5 -> 1133503607 6 -> 1133503608 ****** wait 6 -> 1133503608 7 -> 1133503609 ******* wait 7 -> 1133503609 8 -> 1133503610 ******** wait 8 -> 1133503610 9 -> 1133503611 ********* wait 9 -> 1133503611 End [qiao@oicq qiao]$ 从多进程的例子可以看出，使用pcntl_fork()之后，将生成一个子进程，而且子进程运行的代码，从pcntl_fork()之后的代码开始，而子进程不继承父进程的数据信息(实际上是把父进程的数据做了一个全新的拷贝)，因而使用if(!$pids[$i]) 来控制子进程实际运行的代码段。更详细的研究出于时间关系，暂时没有进行，你可以参考我给出的手册的链接.

。

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

复制代码代码如下:

 
 <?php 
 
 if($argc==1){ 
 
 &nbsp;&nbsp;&nbsp; echo("argv\n"); 
 
 } 
 
 $arg = $argv[1]; 
 
 for($i=0; $i<10; $i++) 
 
 { 
 
 &nbsp;&nbsp;&nbsp; echo($i.".1.".time()." exec $arg \n"); 
 
 &nbsp;&nbsp;&nbsp; if($arg=='php2'){ 
 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sleep(1); 
 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; echo($i.".2.".time()." exec $arg \n"); 
 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sleep(1); 
 
 &nbsp;&nbsp;&nbsp; }else{ 
 
 &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; sleep(1); 
 
 &nbsp;&nbsp;&nbsp; } 
 
 } 
 
 ?>

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

复制代码代码如下:

 
 error_reporting(E_ALL); 
 
 $handle1 = popen('php sub.php php1', 'r'); 
 
 $handle2 = popen('php sub.php php2', 'r'); 
 
 $handle3 = popen('php sub.php php3', 'r'); 
 
 echo "'$handle1'; " . gettype($handle1) . "\n"; 
 
 echo "'$handle2'; " . gettype($handle2) . "\n"; 
 
 echo "'$handle3'; " . gettype($handle3) . "\n"; 
 
 //sleep(20); 
 
 while(!feof($handle1) || !feof($handle2) || !feof($handle3) ) 
 
 { 
 
 $read = fgets($handle1); 
 
 echo $read; 
 
 $read = fgets($handle2); 
 
 echo $read; 
 
 $read = fgets($handle3); 
 
 echo $read; 
 
 } 
 
 pclose($handle1); 
 
 pclose($handle2); 
 
 pclose($handle3);

下面是我机器上的输出： C:\my_hunter>php exec.php 'Resource id #4'; resource 'Resource id #5'; resource 'Resource id #6'; resource 0.1.1147935331 exec php1 0.1.1147935331 exec php2 0.1.1147935331 exec php3 1.1.1147935332 exec php1 0.2.1147935332 exec php2 1.1.1147935332 exec php3 2.1.1147935333 exec php1 1.1.1147935333 exec php2 2.1.1147935333 exec php3 3.1.1147935334 exec php1 1.2.1147935334 exec php2 3.1.1147935334 exec php3 4.1.1147935335 exec php1 2.1.1147935335 exec php2 4.1.1147935335 exec php3 5.1.1147935336 exec php1 2.2.1147935336 exec php2 5.1.1147935336 exec php3 6.1.1147935337 exec php1 3.1.1147935337 exec php2 6.1.1147935337 exec php3 7.1.1147935338 exec php1 3.2.1147935338 exec php2 7.1.1147935338 exec php3 8.1.1147935339 exec php1 4.1.1147935339 exec php2 8.1.1147935339 exec php3 9.1.1147935340 exec php1 4.2.1147935340 exec php2 9.1.1147935340 exec php3 5.1.1147935341 exec php2 5.2.1147935342 exec php2 6.1.1147935343 exec php2 6.2.1147935344 exec php2 7.1.1147935345 exec php2 7.2.1147935346 exec php2 8.1.1147935347 exec php2 8.2.1147935348 exec php2 9.1.1147935349 exec php2 9.2.1147935350 exec php2 **总结：** **主程序循环等待子进程，通过fgets或fread 把子进程的输出获取出来，从时间戳上看，的确实现了并发执行。** ----------------------------------------------- 以后的改进： * popen打开的句柄是单向的，如果需要向子进程交互，可以使用proc_open * 使用数组和子函数代替while(!feof($handle1)|| !feof($handle2) || !feof($handle3) )这种龌龊的写法 * 用fread一次把子进程已经产生的输出取完，而不是每次一行。一个并发执行shell任务的调度者,本程序读取一个任务文件,把里面的每行命令并发执行, 可以设置同时存在的子进程数目

复制代码代码如下:

 
 /* 
 
    主任务管理器 
 
    并发的执行子任务列表 
 
 */ 
 
 include("../common/conf.php"); 
 
 include("../common/function.php"); 
 
 //开启的进程数 
 
 $exec_number = 40 ; 
 
 /***** main ********/ 
 
 if($argc==1){ 
 
     echo("argv\n"); 
 
 } 
 
 $taskfile = $argv[1]; 
 
 //tasklist 
 
 $tasklist = file($taskfile); 
 
 $tasklist_len = count($tasklist); 
 
 $tasklist_pos = 0; 
 
 $handle_list = array(); 
 
 while(1) 
 
 { 
 
     //子进程列表有空闲,则填充补齐子进程列表 
 
     if($exec_number > count($handle_list) && 
 
             $tasklist_pos < $tasklist_len) 
 
     { 
 
         for($i=$tasklist_pos; $i<$tasklist_len; ) 
 
         { 
 
             $command = $tasklist[$i] ; 
 
             $handle_list[] = popen($command , "r" ); 
 
             tolog("begin task \t ".$tasklist[$i]); 
 
             $i++; 
 
             if($exec_number == count($handle_list)) break; 
 
         } 
 
         $tasklist_pos = $i; 
 
     } 
 
     //如果子进程列表空，退出 
 
     if(0 == count($handle_list)) 
 
     { 
 
         break; 
 
     } 
 
     //检查子进程列表的输出，把停掉的子进程关闭并记录下来 
 
     $end_handle_keys = array(); 
 
     foreach($handle_list as $key => $handle) 
 
     { 
 
         //$str = fgets($handle, 65536); 
 
         $str = fread($handle, 65536); 
 
         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("\n\n*******************end**********************\n\n", "" ,  true);

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

复制代码代码如下:

 
 do { 
 
  if (($msgsock = socket_accept($sock)) < 0) { 
 
   echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n"; 
 
   break; 
 
  } 
 
  $pid = pcntl_fork(); 
 
  if ($pid == -1) { 
 
   die('could not fork'); 
 
  } else if (!$pid) { 
 
   ..... 
 
   socket_write($msgsock, $msg, strlen($msg)); 
 
   do { 
 
    ...... 
 
   } while (true); 
 
    socket_close($msgsock); 
 
  } 
 
 } while (true);

。

最后此篇关于深入解析PHP中的(伪)多线程与多进程的文章就讲到这里了,如果你想了解更多关于深入解析PHP中的(伪)多线程与多进程的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！。

文章推荐： php 常用算法和时间复杂度

文章推荐：关于php循环跳出的问题

文章推荐：解析csv数据导入mysql的方法

文章推荐： SSH框架网上商城项目第8战之查询和删除商品类别功能实现

css - 如何在CSS中用一种颜色绘制一半对 Angular 线，用另一种颜色绘制另一半对 Angular 线
我将 Bootstrap 与 css 和 java 脚本结合使用。在不影响前端代码的情况下，我真的很难在css中绘制这个背景。在许多问题中，人们将宽度和高度设置为 0%。但是由于我的导航栏，我不能使用
c - scanf ("%79[^\n]",line); 之间的区别vs scanf ("%79[^\n]\n"，线) vs scanf ("%79[^\n]s"，线)
我正在用 c 编写一个程序来读取文件的内容。代码如下: #include void main() { char line[90]; while(scanf("%79[^\
Javascript获取矩阵数组的对 Angular 线
我想使用 javascript 获取矩阵数组的所有对 Angular 线。假设输入输出如下: input = [ [1,2,3], [4,5,6], [7,8,9], ] output =
pdfmake - 线，圆和其他形状？
可以用pdfmake绘制lines，circles和other shapes吗？如果是，是否有documentation或样本？我想用jsPDF替换pdfmake。最佳答案是的，有可能。 pdfm
svg - 如何制作带有边框的SVG“线”？
我有一个小svg小部件，其目的是显示角度列表（参见图片）。现在，角度是线元素，仅具有笔触，没有填充。但是现在我想使用一种“内部填充”颜色和一种“笔触/边框”颜色。我猜想line元素不能解决这个问题，
java - 线-三角形交点检查返回错误的交点
我正在为带有三角对象的 3D 场景编写一个非常基本的光线转换器，一切都工作正常，直到我决定尝试从场景原点 (0/0/0) 以外的点转换光线。但是，当我将光线原点更改为 (0/1/0) 时，相交测试突
Python Shebang 线
这个问题已经有答案了: Why do people write "#!/usr/bin/env python" on the first line of a Python script? (22 个回
java - 如何在屏幕上绘制星号(*)线？
如何使用大约 50 个星号 * 并使用 for 循环绘制一条水平线？当我尝试这样做时，结果是垂直(而不是水平)列出 50 个星号。 public void drawAstline() { f
java - 球不动；线？
这是一个让球以对角线方式下降的 UI，但球保持静止；线程似乎无法正常工作。你能告诉我如何让球移动吗？请下载一个球并更改目录，以便程序可以找到您的球的分配位置。没有必要下载足球场，但如果您愿意，也可以
ant - Jmeter和Ant报90%线
我在我的一个项目中使用 Jmeter 和 Ant，当我们生成报告时，它会在报告中显示 URL、#Samples、失败、成功率、平均时间、最短时间、最长时间。我也想在报告中包含 90% 的时间线。现
Java Swing 线
我有一个不寻常的问题，希望有人能帮助我。我想用 Canvas (android) 画一条 Swing 或波浪线，但我不知道该怎么做。它将成为蝌蚪的尾部，所以理想情况下我希望它的形状更像三角形，一端更大
javafx粗笔画路径(线)与圆之间的碰撞问题
这个问题已经有答案了: Checking Collision of Shapes with JavaFX (1 个回答) 已关闭 8 年前。我正在使用 JavaFx 8 库。我的任务很简单:我想检
bash - 如何按编号的百分比拆分文件。线？
如何按编号的百分比拆分文件。行数？假设我想将我的文件分成 3 个部分(60%/20%/20% 部分)，我可以手动执行此操作，-_-: $ wc -l brown.txt 57339 brown.tx
圆圈之间的 HTML 线
我正在努力实现这样的目标: 但这就是我设法做到的。你能帮我实现预期的结果吗？更新: 如果我删除 bootstrap.css 依赖项，问题就会消失。我怎样才能让它与 Bootstrap 一起工作？
css - 转换比例导致间隙/线
我目前正在构建一个网站，但遇到了 transform: scale 的问题。我有一个按钮，当用户将鼠标悬停在它上面时，会发生两件事: 背景以对 Angular 线“扫过” 按钮标签颜色改变按钮稍微变
macos - 非常快速地绘制图形(线)
我需要使用直线和仿射变换绘制大量数据点的图形(缩放图形以适合 View )。目前，我正在使用 NSBezierPath，但我认为它效率很低(因为点在绘制之前被复制到贝塞尔路径)。通过将我的数据切割成
image - 从车牌上删除多余的像素/线
我正在使用基于 SVM 分类的 HOG 特征检测器。我可以成功提取车牌，但提取的车牌除了车牌号外还有一些不必要的像素/线。我的图像处理流程如下: 在灰度图像上应用 HOG 检测器裁剪检测到的区域调
python - 间隙填充轮廓/线
我有以下图片: 我想填充它的轮廓(即我想在这张图片中填充线条)。我尝试了形态学闭合，但使用大小为 3x3 的矩形内核和 10 迭代并没有填满整个边界。我还尝试了一个 21x21 内核和 1 迭代，但
algorithm - 统计两组序列的交点(线)
我必须找到一种算法，可以找到两组数组之间的交集总数，而其中一个数组已排序。举个例子，我们有这两个数组，我们向相应的数字画直线。这两个数组为我们提供了总共 7 个交集。有什么样的算法可以帮助我解决
c++ - 如何从带有透视投影的近裁剪平面绘制射线/线？
简单地说 - 我想使用透视投影从近裁剪平面绘制一条射线/线到远裁剪平面。我有我认为是使用各种 OpenGL/图形编程指南中描述的方法通过单击鼠标生成的正确标准化的世界坐标。我遇到的问题是我的光线似乎

qq735679552

个人简介

我是一名优秀的程序员,十分优秀！

作者热门文章

滴滴打车优惠券免费领取

全站热门文章

首页

博学

6Ren·AI

商城

深入解析PHP中的(伪)多线程与多进程