本來(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)聽子進(jìn)程消息
listenChild($child);
} else {
fclose($pair[0]);
$parent = $pair[1];
// 監(jiān)聽父進(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)聽客戶端連接。
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ǔ)了 ....跪求大神解救
1 回答
慕森卡
TA貢獻(xiàn)1806條經(jīng)驗(yàn) 獲得超8個(gè)贊
坑人代碼還原如下
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)程亂入到父進(jìn)程領(lǐng)域！）
父進(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)程領(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分析：為什么子進(jìn)程會(huì)調(diào)用在父進(jìn)程定義的事件呢？？
這得仔細(xì)分析 for 循環(huán)！
- 第一次循環(huán)，父進(jìn)程向
Event::$events添加子進(jìn)程監(jiān)聽事件，子進(jìn)程平行執(zhí)行。對(duì)產(chǎn)生的第一個(gè)子進(jìn)程來(lái)說(shuō)，Event::$events為空，所以沒(méi)有拷貝到父進(jìn)程的事件。 - 第二次循環(huán)，父進(jìn)程向
Event::$events再次添加監(jiān)聽子進(jìn)程事件，此時(shí)，對(duì)產(chǎn)生的第二個(gè)子進(jìn)程來(lái)說(shuō)，Event::$events存在一個(gè)事件！從父進(jìn)程拷貝了一個(gè)事件。 - 第三次循環(huán)，父進(jìn)程再次向
Event::$events再次添加監(jiān)聽子進(jìn)程事件，此時(shí)，對(duì)產(chǎn)生的三個(gè)子進(jìn)程來(lái)說(shuō)，Event::$events存在兩個(gè)事件！從父進(jìn)程拷貝了兩個(gè)事件。 - 第四次循環(huán)，父進(jìn)程再次向
Event::$evnets添加事件，此時(shí)，相對(duì)產(chǎn)生的第四個(gè)子進(jìn)程來(lái)說(shuō)，Event::$events存在三個(gè)事件，從父進(jìn)程拷貝了三個(gè)事件。
由上可知，子進(jìn)程實(shí)際也在監(jiān)聽從父進(jìn)程拷貝的事件，如果事件觸發(fā)，那么監(jiān)聽該事件的父子進(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();
// ....做些什么
}
}- 1 回答
- 0 關(guān)注
- 366 瀏覽
添加回答
舉報(bào)
0/150
提交
取消