php中多進程函數的使用案例

這篇文章主要介紹php中多進程函數的使用案例，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

在服務器跑腳本時，避免不了一些耗時任務，使用多進程是必不可少的。而在 PHP5.5 之后，PHP 開始加入了多進程元素，以滿足開發需求。

php多進程一般應用在php_cli命令行中執行php腳本,實現多進程需要開啟的擴展：pcntl、 posix（pcntl是process control進程管理的縮寫）。Windows 環境下不支持 PHP 的多進程編程，本文主要在 Linux 環境下開發測試

pcntl_fork — 在當前進程當前位置產生分支（子進程）。
一個fork子進程的基礎示例：

$pid = pcntl_fork();
//父進程和子進程都會執行下面代碼
if ($pid == -1) {
        //錯誤處理：創建子進程失敗時返回-1.
         die('could not fork');
} else if ($pid) {
         //父進程會得到子進程號，所以這里是父進程執行的邏輯
         pcntl_wait($status); //等待子進程中斷，防止子進程成為僵尸進程。
} else {
         //子進程得到的$pid為0, 所以這里是子進程執行的邏輯。
}

如果一個任務被分解成多個進程執行，就會減少整體的耗時。
比如有一個比較大的數據文件要處理，這個文件由很多行組成。如果單進程執行要處理的任務，量很大時要耗時比較久。這時可以考慮多進程。

來看一道面試題，有一個1000萬個元素的int數組，需要求和，平均分到4個進程處理，每個進程處理一部分，再將結果統計出來，代碼如下

  <?php

  $arrint = [0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15];//假設很多
  $arrint = array_chunk($arrint,4,TRUE);
  for ($i = 0; $i < 4; $i++){
      	$pid = pcntl_fork();
  if ($pid == -1) {
     	die("could not fork");
  } elseif ($pid) {
      	echo $pid;
      	echo "I'm the Parent $i\n";
  } else {
       	// 子進程處理
      	// $content = file_get_contents("prefix_name0".$i);
     	$psum = array_sum($arrint[$i]);
      	echo $psum . "\n";分別輸出子進程的部分求和數字，但是無法進行想加，因為進程互相獨立
     	exit;// 一定要注意退出子進程,否則pcntl_fork() 會被子進程再fork,帶來處理上的影響。
       	}
  }
          
  // 等待子進程執行結
  while (pcntl_waitpid(0, $status) != -1) {
      	$status = pcntl_wexitstatus($status);
      	echo "Child $status completed\n";
  }

上訴答案中，是把數組分為4個子數組分別用4個子進程去處理了，但是沒有辦法把所計算的結果相加，因為進程都是獨立完成任務的，沒有辦法共享同一個（內存）變量，下面將引進消息隊列來解決進程通信的問題

  <?php
  $arrint = [0,1,2,3,4,5,6,7,8,9,10,11,12,13,14,15];//假設很多
  $arrint = array_chunk($arrint,4,TRUE);//把數組分為4個

  // 創建消息隊列,以及定義消息類型(類似于數據庫中的庫)
  $id = ftok(__FILE__,'m');//生成文件key，唯一
  $msgQueue = msg_get_queue($id);
  const MSG_TYPE = 1;
  msg_send($msgQueue,MSG_TYPE,'0');//給消息隊列一個默認值0，必須是字符串類型
  
  //fork出四個子進程
  for ($i = 0; $i < 4; $i++){
   		$pid = pcntl_fork();
      	if ($pid == -1) {
          	die("could not fork");
      	} elseif ($pid) {
         	echo $pid;
          	echo "I'm the Parent $i\n";
      	} else {
      		// 子進程處理邏輯，相互獨立，解決辦法，放到內存消息隊列中
          	$part = array_sum($arrint[$i]);
          	implode_sum($part);//合成計算出的sum
          	exit;// 一定要注意退出子進程,否則pcntl_fork() 會被子進程再fork,帶來處理上的影響。
    	}
  }
          
  function implode_sum($part){
     	global $msgQueue;
      	msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$sum);//獲取消息隊列中的值，最后一個參數為隊列中的值
      	$sum = intval($sum) + $part;
      	msg_send($msgQueue,MSG_TYPE,$sum);//發送每次計算的結果給消息隊列
  }
      
  // 等待子進程執行結束
  while (pcntl_waitpid(0, $status) != -1) {
      	$status = pcntl_wexitstatus($status);
      	$pid = posix_getpid();
      	echo "Child $status completed\n";
  }
      
  //所有子進程結束后，再取出最后在隊列中的值，就是int數組的和
  msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$sum);
  echo $sum;//輸出120

以上是php中多進程函數的使用案例的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！