鍍金池/ 問答/Java  PHP/ php stream_socket_pair 亂入如何解決??

php stream_socket_pair 亂入如何解決??

本來使用 stream_socket_pair 是用來父子進程間通信的,實現(xiàn)多進程下,某個子進程消息通過父進程轉(zhuǎn)發(fā)給其他子進程(類似于 qq),但是這碰到了一個問題:

$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)建子進程失敗");
    } else if ($pid > 0) {
        fclose($pair[1]);
        $child = $pair[0];
        $childConn[$pid] = $child;
        // 監(jiān)聽子進程消息
        listenChild($child); 
    } else {
        fclose($pair[0]);
        $parent = $pair[1];
        // 監(jiān)聽父進程消息
        listenParent($parent);
    }
}

以上目的就是為每個子進程創(chuàng)建與父進程的通信通道,然結(jié)果卻發(fā)生了令人意外的效果!

比如下面一個通信過程:

父進程pid: 30246
子進程pid: 30247 30248 30249 30250,每個子進程中都監(jiān)聽客戶端連接。

1. 客戶端A 進入子進程 30247
2. 客戶端B 進入子進程 30248
3. A 客戶端發(fā)送消息,子進程 30247 接受到消息,要求轉(zhuǎn)發(fā)給 30248 中的客戶端 B
4. 子進程 30247 調(diào)用事先保存的 $parent(與父進程的通信連接),發(fā)送消息
... 意外產(chǎn)生了??!
你可能想當然的以為,他絕對是發(fā)送給父進程(30246)!
而實際上不是!結(jié)果可能是其他子進程!
到這兒,我就很郁悶了,stream_socket_pair 創(chuàng)建的成對套接字,怎么會發(fā)生這種現(xiàn)象??

我表示特別無語了 ....跪求大神解救

回答
編輯回答
淚染裳

坑人代碼還原如下

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)建子進程失敗");
    } else if ($pid > 0) {
        // 父進程
        fclose($pair[0]);
        
        $child = $pair[1];
        
        fwrite($child , "父進程問候 " . posix_getpid());
        
        Select::addIo($child , Event::READ , function($ctrl , $socket , $child) use($parent_pid){
            $msg = fread($socket , 65535);
            
            echo "父進程領(lǐng)域!父進程 {$parent_pid} 當前執(zhí)行進程 " . posix_getpid() . " 消息:{$msg}" . PHP_EOL;
        } , $child);
    } else {
        // 子進程
        fclose($pair[1]);
        $parent = $pair[0];
        fwrite($parent , "子進程問候 " . posix_getpid());
        
        Select::addIo($parent , Event::READ , function($ctrl , $socket , $parent) use($parent_pid){
            $msg = fread($socket , 65535);
            
            echo "子進程領(lǐng)域!子進程 " . posix_getpid() . " 當前執(zhí)行進程 " . posix_getpid() . " 消息:{$msg}\n";
        } , $parent);
    }
}

產(chǎn)生的進程信息:

父進程:32140
子進程:32141 32142 32143 32144

坑人的結(jié)果:

父進程代碼領(lǐng)域下(子進程亂入到父進程領(lǐng)域?。?/h4>
父進程領(lǐng)域!父進程 32140 當前執(zhí)行進程 32142 消息 子進程問候 32141
父進程領(lǐng)域!父進程 32140 當前執(zhí)行進程 32143 消息 子進程問候 32142
父進程領(lǐng)域!父進程 32140 當前執(zhí)行進程 32144 消息 子進程問候 32143
父進程領(lǐng)域!父進程 32140 當前執(zhí)行進程 32140 消息 子進程問候 32144

子進程代碼領(lǐng)域(正確)

子進程領(lǐng)域!子進程 32141 當前執(zhí)行進程 32141 消息 父進程問候 32140
子進程領(lǐng)域!子進程 32142 當前執(zhí)行進程 32142 消息 父進程問候 32140
子進程領(lǐng)域!子進程 32143 當前執(zhí)行進程 32143 消息 父進程問候 32140
子進程領(lǐng)域!子進程 32144 當前執(zhí)行進程 32144 消息 父進程問候 32140

分析:為什么子進程會調(diào)用在父進程定義的事件呢??

這得仔細分析 for 循環(huán)!

  • 第一次循環(huán),父進程向 Event::$events 添加子進程監(jiān)聽事件,子進程平行執(zhí)行。對產(chǎn)生的第一個子進程來說, Event::$events 為空,所以沒有拷貝到父進程的事件。
  • 第二次循環(huán),父進程向 Event::$events 再次添加監(jiān)聽子進程事件,此時,對產(chǎn)生的第二個子進程來說,Event::$events 存在一個事件!從父進程拷貝了一個事件。
  • 第三次循環(huán),父進程再次向 Event::$events 再次添加監(jiān)聽子進程事件,此時,對產(chǎn)生的三個子進程來說, Event::$events 存在兩個事件!從父進程拷貝了兩個事件。
  • 第四次循環(huán),父進程再次向 Event::$evnets 添加事件,此時,相對產(chǎn)生的第四個子進程來說,Event::$events 存在三個事件,從父進程拷貝了三個事件。

由上可知,子進程實際也在監(jiān)聽從父進程拷貝的事件,如果事件觸發(fā),那么監(jiān)聽該事件的父子進程實際上都會觸發(fā)。從而出現(xiàn)了令人郁悶的:子進程亂入到了父進程的領(lǐng)域。

解決方法

在子進程中,把從父進程拷貝的事件銷毀即可。

for ($i = 0; $i < 4; ++$i)
{
    $pid = pcntl_fork();
    
    if ($pid < 0) {
        throw new Exception("創(chuàng)建子進程失敗");
    } else if ($pid > 0) {
        // 父進程
        Select::addIo( .... );
        // ...添加相關(guān)事件
    } else {
        // 子進程
        // 銷毀從父進程拷貝的事件
        Select::clear();
        
        // ....做些什么
    }
}
2018年2月26日 23:48