本來(lái)使用 stream_socket_pair
是用來(lái)父子進(jìn)程間通信的,實(shí)現(xiàn)多進(jìn)程下,某個(gè)子進(jìn)程消息通過(guò)父進(jìn)程轉(zhuǎn)發(fā)給其他子進(jìn)程(類似于 qq
),但是這碰到了一個(gè)問(wèn)題:
$count = 4;
$childConn = [];
$parent = null;
for ($i = 0; $i < $count; ++$i)
{
$pair = stream_socket_pair(STREAM_PF_UNIX , STREAM_SOCK_STREAM , STREAM_IPRROTO_IP);
$pid = pcntl_fork();
if ($pid < 0) {
throw new Exception("創(chuàng)建子進(jìn)程失敗");
} else if ($pid > 0) {
fclose($pair[1]);
$child = $pair[0];
$childConn[$pid] = $child;
// 監(jiān)聽(tīng)子進(jìn)程消息
listenChild($child);
} else {
fclose($pair[0]);
$parent = $pair[1];
// 監(jiān)聽(tīng)父進(jìn)程消息
listenParent($parent);
}
}
以上目的就是為每個(gè)子進(jìn)程創(chuàng)建與父進(jìn)程的通信通道,然結(jié)果卻發(fā)生了令人意外的效果!
比如下面一個(gè)通信過(guò)程:
父進(jìn)程pid: 30246
子進(jìn)程pid: 30247 30248 30249 30250,每個(gè)子進(jìn)程中都監(jiān)聽(tīng)客戶端連接。
1. 客戶端A 進(jìn)入子進(jìn)程 30247
2. 客戶端B 進(jìn)入子進(jìn)程 30248
3. A 客戶端發(fā)送消息,子進(jìn)程 30247 接受到消息,要求轉(zhuǎn)發(fā)給 30248 中的客戶端 B
4. 子進(jìn)程 30247 調(diào)用事先保存的 $parent(與父進(jìn)程的通信連接),發(fā)送消息
... 意外產(chǎn)生了!!
你可能想當(dāng)然的以為,他絕對(duì)是發(fā)送給父進(jìn)程(30246)!
而實(shí)際上不是!結(jié)果可能是其他子進(jìn)程!
到這兒,我就很郁悶了,stream_socket_pair 創(chuàng)建的成對(duì)套接字,怎么會(huì)發(fā)生這種現(xiàn)象??
我表示特別無(wú)語(yǔ)了 ....跪求大神解救
use Event\Event;
use Event\Select;
$pid_list = [];
$parent_pid = posix_getpid();
for ($i = 0; $i < 4; ++$i)
{
$pair = stream_socket_pair(STREAM_PF_UNIX , STREAM_SOCK_STREAM , STREAM_IPPROTO_IP);
$pid = pcntl_fork();
if ($pid < 0) {
throw new Exception("創(chuàng)建子進(jìn)程失敗");
} else if ($pid > 0) {
// 父進(jìn)程
fclose($pair[0]);
$child = $pair[1];
fwrite($child , "父進(jìn)程問(wèn)候 " . posix_getpid());
Select::addIo($child , Event::READ , function($ctrl , $socket , $child) use($parent_pid){
$msg = fread($socket , 65535);
echo "父進(jìn)程領(lǐng)域!父進(jìn)程 {$parent_pid} 當(dāng)前執(zhí)行進(jìn)程 " . posix_getpid() . " 消息:{$msg}" . PHP_EOL;
} , $child);
} else {
// 子進(jìn)程
fclose($pair[1]);
$parent = $pair[0];
fwrite($parent , "子進(jìn)程問(wèn)候 " . posix_getpid());
Select::addIo($parent , Event::READ , function($ctrl , $socket , $parent) use($parent_pid){
$msg = fread($socket , 65535);
echo "子進(jìn)程領(lǐng)域!子進(jìn)程 " . posix_getpid() . " 當(dāng)前執(zhí)行進(jìn)程 " . posix_getpid() . " 消息:{$msg}\n";
} , $parent);
}
}
產(chǎn)生的進(jìn)程信息:
父進(jìn)程:32140
子進(jìn)程:32141 32142 32143 32144
坑人的結(jié)果:
父進(jìn)程領(lǐng)域!父進(jìn)程 32140 當(dāng)前執(zhí)行進(jìn)程 32142 消息 子進(jìn)程問(wèn)候 32141
父進(jìn)程領(lǐng)域!父進(jìn)程 32140 當(dāng)前執(zhí)行進(jìn)程 32143 消息 子進(jìn)程問(wèn)候 32142
父進(jìn)程領(lǐng)域!父進(jìn)程 32140 當(dāng)前執(zhí)行進(jìn)程 32144 消息 子進(jìn)程問(wèn)候 32143
父進(jìn)程領(lǐng)域!父進(jìn)程 32140 當(dāng)前執(zhí)行進(jìn)程 32140 消息 子進(jìn)程問(wèn)候 32144
子進(jìn)程領(lǐng)域!子進(jìn)程 32141 當(dāng)前執(zhí)行進(jìn)程 32141 消息 父進(jìn)程問(wèn)候 32140
子進(jìn)程領(lǐng)域!子進(jìn)程 32142 當(dāng)前執(zhí)行進(jìn)程 32142 消息 父進(jìn)程問(wèn)候 32140
子進(jìn)程領(lǐng)域!子進(jìn)程 32143 當(dāng)前執(zhí)行進(jìn)程 32143 消息 父進(jìn)程問(wèn)候 32140
子進(jìn)程領(lǐng)域!子進(jìn)程 32144 當(dāng)前執(zhí)行進(jìn)程 32144 消息 父進(jìn)程問(wèn)候 32140
這得仔細(xì)分析 for
循環(huán)!
Event::$events
添加子進(jìn)程監(jiān)聽(tīng)事件,子進(jìn)程平行執(zhí)行。對(duì)產(chǎn)生的第一個(gè)子進(jìn)程來(lái)說(shuō), Event::$events
為空,所以沒(méi)有拷貝到父進(jìn)程的事件。Event::$events
再次添加監(jiān)聽(tīng)子進(jìn)程事件,此時(shí),對(duì)產(chǎn)生的第二個(gè)子進(jìn)程來(lái)說(shuō),Event::$events
存在一個(gè)事件!從父進(jìn)程拷貝了一個(gè)事件。Event::$events
再次添加監(jiān)聽(tīng)子進(jìn)程事件,此時(shí),對(duì)產(chǎn)生的三個(gè)子進(jìn)程來(lái)說(shuō), Event::$events
存在兩個(gè)事件!從父進(jìn)程拷貝了兩個(gè)事件。Event::$evnets
添加事件,此時(shí),相對(duì)產(chǎn)生的第四個(gè)子進(jìn)程來(lái)說(shuō),Event::$events
存在三個(gè)事件,從父進(jìn)程拷貝了三個(gè)事件。由上可知,子進(jìn)程實(shí)際也在監(jiān)聽(tīng)從父進(jìn)程拷貝的事件,如果事件觸發(fā),那么監(jiān)聽(tīng)該事件的父子進(jìn)程實(shí)際上都會(huì)觸發(fā)。從而出現(xiàn)了令人郁悶的:子進(jìn)程亂入到了父進(jìn)程的領(lǐng)域。
在子進(jìn)程中,把從父進(jìn)程拷貝的事件銷毀即可。
for ($i = 0; $i < 4; ++$i)
{
$pid = pcntl_fork();
if ($pid < 0) {
throw new Exception("創(chuàng)建子進(jìn)程失敗");
} else if ($pid > 0) {
// 父進(jìn)程
Select::addIo( .... );
// ...添加相關(guān)事件
} else {
// 子進(jìn)程
// 銷毀從父進(jìn)程拷貝的事件
Select::clear();
// ....做些什么
}
}
北大青鳥(niǎo)APTECH成立于1999年。依托北京大學(xué)優(yōu)質(zhì)雄厚的教育資源和背景,秉承“教育改變生活”的發(fā)展理念,致力于培養(yǎng)中國(guó)IT技能型緊缺人才,是大數(shù)據(jù)專業(yè)的國(guó)家
北大青鳥(niǎo)中博軟件學(xué)院創(chuàng)立于2003年,作為華東區(qū)著名互聯(lián)網(wǎng)學(xué)院和江蘇省首批服務(wù)外包人才培訓(xùn)基地,中博成功培育了近30000名軟件工程師走向高薪崗位,合作企業(yè)超4
中公教育集團(tuán)創(chuàng)建于1999年,經(jīng)過(guò)二十年潛心發(fā)展,已由一家北大畢業(yè)生自主創(chuàng)業(yè)的信息技術(shù)與教育服務(wù)機(jī)構(gòu),發(fā)展為教育服務(wù)業(yè)的綜合性企業(yè)集團(tuán),成為集合面授教學(xué)培訓(xùn)、網(wǎng)
達(dá)內(nèi)教育集團(tuán)成立于2002年,是一家由留學(xué)海歸創(chuàng)辦的高端職業(yè)教育培訓(xùn)機(jī)構(gòu),是中國(guó)一站式人才培養(yǎng)平臺(tái)、一站式人才輸送平臺(tái)。2014年4月3日在美國(guó)成功上市,融資1
曾工作于聯(lián)想擔(dān)任系統(tǒng)開(kāi)發(fā)工程師,曾在博彥科技股份有限公司擔(dān)任項(xiàng)目經(jīng)理從事移動(dòng)互聯(lián)網(wǎng)管理及研發(fā)工作,曾創(chuàng)辦藍(lán)懿科技有限責(zé)任公司從事總經(jīng)理職務(wù)負(fù)責(zé)iOS教學(xué)及管理工作。
浪潮集團(tuán)項(xiàng)目經(jīng)理。精通Java與.NET 技術(shù), 熟練的跨平臺(tái)面向?qū)ο箝_(kāi)發(fā)經(jīng)驗(yàn),技術(shù)功底深厚。 授課風(fēng)格 授課風(fēng)格清新自然、條理清晰、主次分明、重點(diǎn)難點(diǎn)突出、引人入勝。
精通HTML5和CSS3;Javascript及主流js庫(kù),具有快速界面開(kāi)發(fā)的能力,對(duì)瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網(wǎng)頁(yè)制作和網(wǎng)頁(yè)游戲開(kāi)發(fā)。
具有10 年的Java 企業(yè)應(yīng)用開(kāi)發(fā)經(jīng)驗(yàn)。曾經(jīng)歷任德國(guó)Software AG 技術(shù)顧問(wèn),美國(guó)Dachieve 系統(tǒng)架構(gòu)師,美國(guó)AngelEngineers Inc. 系統(tǒng)架構(gòu)師。