本篇文章帶大家了解一下PHP中的進程和進程間通信。有一定的參考價值，有需要的朋友可以參考一下，希望對大家有所幫助。

環(huán)境

php中的進程是以擴展的形式來完成。通過這些擴展，我們能夠很輕松的完成進程的一系列動作。

pcntl擴展：主要的進程擴展，完成進程創(chuàng)建于等待操作。 posix擴展：完成posix兼容機通用api,如獲取進程id,殺死進程等。 sysvmsg擴展：實現(xiàn)system v方式的進程間通信之消息隊列。 sysvsem擴展：實現(xiàn)system v方式的信號量。 sysvshm擴展：實現(xiàn)system v方式的共享內(nèi)存。 sockets擴展：實現(xiàn)socket通信。 這些擴展只能在linux/mac中使用，window下是不支持。最后建議php版本為5.5+。

簡單的例子

一個簡單的PHP多進程例子，該例子中，一個子進程，一個父進程。子進程輸出5次，退出程序。

echo "parent progress pid:{$parentPid}n";  $childList = array();  $pid = pcntl_fork();  if ( $pid == -1) {      // 創(chuàng)建失敗      exit("fork progress error!n");  } else if ($pid == 0) {      // 子進程執(zhí)行程序      $pid = posix_getpid();      $repeatNum = 5;      for ( $i = 1; $i <= $repeatNum; $i++) {          echo "({$pid})child progress is running! {$i} n";          $rand = rand(1,3);          sleep($rand);      }      exit("({$pid})child progress end!n");  } else {      // 父進程執(zhí)行程序      $childList[$pid] = 1;  }  // 等待子進程結(jié)束  pcntl_wait($status); echo "({$parentPid})main progress end!";

完美，終于創(chuàng)建了一個子進程，一個父進程。完了么？沒有，各個進程之間相互獨立的，沒有任何交集，使用范圍嚴重受到現(xiàn)在。怎么辦，哪就進程間通信(interprogress communication)唄。

進程間通信（IPC）

通常linux中的進程通信方式有：消息隊列、信號量、共享內(nèi)存、信號、管道、socket。

1.消息隊列

消息隊列是存放在內(nèi)存中的一個隊列。如下代碼將創(chuàng)建3個生產(chǎn)者子進程，2個消費者子進程。這5個進程將通過消息隊列通信。

echo "parent progress pid:{$parentPid}n";$childList = array(); // 創(chuàng)建消息隊列,以及定義消息類型(類似于數(shù)據(jù)庫中的庫) $id = ftok(__FILE__,'m'); $msgQueue = msg_get_queue($id); const MSG_TYPE = 1; // 生產(chǎn)者 function producer(){     global $msgQueue;     $pid = posix_getpid();     $repeatNum = 5;     for ( $i = 1; $i <= $repeatNum; $i++) {         $str = "({$pid})progress create! {$i}";         msg_send($msgQueue,MSG_TYPE,$str);         $rand = rand(1,3);         sleep($rand);     } } // 消費者 function consumer(){     global $msgQueue;     $pid = posix_getpid();     $repeatNum = 6;     for ( $i = 1; $i <= $repeatNum; $i++) {         $rel = msg_receive($msgQueue,MSG_TYPE,$msgType,1024,$message);         echo "{$message} | consumer({$pid}) destroy n";         $rand = rand(1,3);         sleep($rand);     } } function createProgress($callback){     $pid = pcntl_fork();     if ( $pid == -1) {         // 創(chuàng)建失敗         exit("fork progress error!n");     } else if ($pid == 0) {         // 子進程執(zhí)行程序         $pid = posix_getpid();         $callback();         exit("({$pid})child progress end!n");     }else{         // 父進程執(zhí)行程序         return $pid;     } } // 3個寫進程 for ($i = 0; $i < 3; $i ++ ) {     $pid = createProgress('producer');     $childList[$pid] = 1;     echo "create producer child progress: {$pid} n"; } // 2個寫進程 for ($i = 0; $i < 2; $i ++ ) {     $pid = createProgress('consumer');     $childList[$pid] = 1;     echo "create consumer child progress: {$pid} n"; } // 等待所有子進程結(jié)束 while(!empty($childList)){     $childPid = pcntl_wait($status);     if ($childPid > 0){         unset($childList[$childPid]);     } } echo "({$parentPid})main progress end!n";

由于消息隊列去數(shù)據(jù)是，只有一個進程能去到，所以不需要額外的鎖或信號量。

2. 信號量與共享內(nèi)存

信號量：是系統(tǒng)提供的一種原子操作，一個信號量，同時只有你個進程能操作。一個進程獲得了某個信號量，就必須被該進程釋放掉。

共享內(nèi)存：是系統(tǒng)在內(nèi)存中開辟的一塊公共的內(nèi)存區(qū)域，任何一個進程都可以訪問，在同一時刻，可以有多個進程訪問該區(qū)域，為了保證數(shù)據(jù)的一致性，需要對該內(nèi)存區(qū)域加鎖或信號量。

以下，創(chuàng)建多個進程修改內(nèi)存中的同一個值。

echo "parent progress pid:{$parentPid}n"; $childList = array();  // 創(chuàng)建共享內(nèi)存,創(chuàng)建信號量,定義共享key $shm_id = ftok(__FILE__,'m'); $sem_id = ftok(__FILE__,'s'); $shareMemory = shm_attach($shm_id); $signal = sem_get($sem_id); const SHARE_KEY = 1; // 生產(chǎn)者 function producer(){     global $shareMemory;     global $signal;     $pid = posix_getpid();     $repeatNum = 5;     for ( $i = 1; $i <= $repeatNum; $i++) {         // 獲得信號量         sem_acquire($signal);                  if (shm_has_var($shareMemory,SHARE_KEY)){             // 有值,加一             $count = shm_get_var($shareMemory,SHARE_KEY);             $count ++;             shm_put_var($shareMemory,SHARE_KEY,$count);             echo "({$pid}) count: {$count}n";         }else{             // 無值,初始化             shm_put_var($shareMemory,SHARE_KEY,0);             echo "({$pid}) count: 0n";         }         // 用完釋放         sem_release($signal);                  $rand = rand(1,3);         sleep($rand);     } } function createProgress($callback){     $pid = pcntl_fork();     if ( $pid == -1) {         // 創(chuàng)建失敗         exit("fork progress error!n");     } else if ($pid == 0) {         // 子進程執(zhí)行程序         $pid = posix_getpid();         $callback();         exit("({$pid})child progress end!n");     }else{         // 父進程執(zhí)行程序         return $pid;     } } // 3個寫進程 for ($i = 0; $i < 3; $i ++ ) {     $pid = createProgress('producer');     $childList[$pid] = 1;     echo "create producer child progress: {$pid} n"; } // 等待所有子進程結(jié)束 while(!empty($childList)){     $childPid = pcntl_wait($status);     if ($childPid > 0){         unset($childList[$childPid]);     } } // 釋放共享內(nèi)存與信號量 shm_remove($shareMemory); sem_remove($signal); echo "({$parentPid})main progress end!n";

3.信號

信號是一種系統(tǒng)調(diào)用。通常我們用的kill命令就是發(fā)送某個信號給某個進程的。具體有哪些信號可以在liunx/mac中運行kill -l查看。下面這個例子中，父進程等待5秒鐘，向子進程發(fā)送sigint信號。子進程捕獲信號，掉信號處理函數(shù)處理。

echo "parent progress pid:{$parentPid}n";  // 定義一個信號處理函數(shù) function sighandler($signo) {     $pid = posix_getpid();     echo "{$pid} progress,oh no ,I'm killed!n";     exit(1); }  $pid = pcntl_fork(); if ( $pid == -1) {     // 創(chuàng)建失敗     exit("fork progress error!n"); } else if ($pid == 0) {     // 子進程執(zhí)行程序     // 注冊信號處理函數(shù)     declare(ticks=10);     pcntl_signal(SIGINT, "sighandler");     $pid = posix_getpid();     while(true){         echo "{$pid} child progress is running!n";         sleep(1);     }     exit("({$pid})child progress end!n"); }else{     // 父進程執(zhí)行程序     $childList[$pid] = 1;     // 5秒后,父進程向子進程發(fā)送sigint信號.     sleep(5);     posix_kill($pid,SIGINT);     sleep(5); } echo "({$parentPid})main progress end!n";

4.管道（有名管道）

管道是比較常用的多進程通信手段，管道分為無名管道與有名管道，無名管道只能用于具有親緣關(guān)系的進程間通信，而有名管道可以用于同一主機上任意進程。這里只介紹有名管道。下面的例子，子進程寫入數(shù)據(jù)，父進程讀取數(shù)據(jù)。

$pipe_path = '/data/test.pipe'; if(!file_exists($pipe_path)){     if(!posix_mkfifo($pipe_path,0664)){         exit("create pipe error!");     } } $pid = pcntl_fork(); if($pid == 0){     // 子進程,向管道寫數(shù)據(jù)     $file = fopen($pipe_path,'w');     while (true){         fwrite($file,'hello world');         $rand = rand(1,3);         sleep($rand);     }     exit('child end!'); }else{     // 父進程,從管道讀數(shù)據(jù)     $file = fopen($pipe_path,'r');     while (true){         $rel = fread($file,20);         echo "{$rel}n";         $rand = rand(1,2);         sleep($rand);     } }

推薦學習：《PHP視頻教程》