发表新帖

关于useQueue的问题

我在学习swoole的进程之间的通讯
{{{
<?php
$workers = array();
$numbers = 2;
for($i=1;$i<=$numbers ; $i++){
$process = new swoole_process('callback' , false ,false );
$process->useQueue();
$pid = $process->start();
$workers[$pid]=$process;
}

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
}

From Master:  hi 4863 worker , i am master ; 
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 16

From Master:

}}}
我感到很好奇，好像没写错什么啊？为什么第一个进程正常，第二个就出现了错误呢？
之后在我原先的代码上，添加了这么一段
{{{
<?php
$workers = array();
$numbers = 2;
for($i=1;$i<=$numbers ; $i++){
$process = new swoole_process('callback' , false ,false );
$process->useQueue();
$pid = $process->start();
$workers[$pid]=$process;
}

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
}

function callback( swoole_process $worker ){//子进程
$recv = $worker->pop();//如果队列中没有数据，pop()方法会阻塞等待
echo PHP_EOL."From Master: ".$recv.PHP_EOL;
$worker->exit(0);
}
//上面的没变，只是多了下面这段
for($i = 0; $i < $numbers; $i++)
{
$ret = swoole_process::wait();
$pid = $ret['pid'];
unset($workers[$pid]);
echo "Worker Exit, PID=".$pid.PHP_EOL;
}

}}}
这样一来，输出结果是
{{{

From Master:  hi 4876 worker , i am master ;

From Master:  hi 4877 worker , i am master ; 
Worker Exit, PID=4876
Worker Exit, PID=4877

}}}
看着输出变好了，是我预想的那样，
但是 swoole_process::wait() 是 回收结束运行的子进程 。
 这个和我的进程通讯，消息队列有什么关系呢?

我又接着测试
{{{
<?php
$workers = array();
$numbers = 2;
for($i=1;$i<=$numbers ; $i++){
	$process = new swoole_process('callback' , false ,false );
	$process->useQueue();
	$pid  = $process->start();
	$workers[$pid]=$process;
}

foreach($workers as $pid =>$worker){
	$worker->push(" hi $pid worker , i am master ; ");
	$recv =  $worker->pop();//父进程接收
	echo PHP_EOL."From worker:  ".$recv.PHP_EOL;
}

function callback( swoole_process $worker ){//子进程
        $recv = $worker->pop();//如果队列中没有数据，pop()方法会阻塞等待
        echo PHP_EOL."From Master:  ".$recv.PHP_EOL;
        $worker->push(" h1  master ,   i  am  ".$worker->pid);//子进程向父进程发送
       $worker->exit(0);
}

for($i = 0; $i < $numbers; $i++)
{
    $ret = swoole_process::wait();
    $pid = $ret['pid'];
    unset($workers[$pid]);
    echo "Worker Exit, PID=".$pid.PHP_EOL;
}

}}}
这个代码的意思是主进程和子进程的数据通信
输出结果
{{{

From Master:   hi 4803 worker , i am master ;

From worker:   h1  master ,   i  am  4803
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Identifier removed[43] in /var/www/learn/SWOOLE/process/demo.php on line 13

From worker:

From Master:   hi 4804 worker , i am master ; 
PHP Warning:  swoole_process::push(): msgsnd() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 20
Worker Exit, PID=4804
Worker Exit, PID=4803

}}}
这点我就不理解了，我尝试去掉最后的swoole_process::wait();
{{{
<?php
$workers = array();
$numbers = 2;
for($i=1;$i<=$numbers ; $i++){
$process = new swoole_process('callback' , false ,false );
$process->useQueue();
$pid = $process->start();
$workers[$pid]=$process;
}

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
$recv = $worker->pop();//父进程接收
echo PHP_EOL."From worker: ".$recv.PHP_EOL;
}

function callback( swoole_process $worker ){//子进程
$recv = $worker->pop();//如果队列中没有数据，pop()方法会阻塞等待
echo PHP_EOL."From Master: ".$recv.PHP_EOL;
$worker->push(" h1 master , i am ".$worker->pid);//子进程向父进程发送
$worker->exit(0);
}

//下面的删除了
}}}
结果是
{{{

From Master:  hi 4934 worker , i am master ;

From worker:  h1 master , i am 4934
PHP Warning:  swoole_process::push(): msgsnd() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 12
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 13

From worker: 
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Identifier removed[43] in /var/www/learn/SWOOLE/process/demo.php on line 18

From Master: 
PHP Warning:  swoole_process::push(): msgsnd() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 20

}}}

我不明白为什么运行结果这样，
难道消息队列的通讯，主进程和所有子进程共用一个消息队列吗？（和管道一个子进程一个管道不同？）
难道消息队列的通讯，必须使用 swoole_process::wait(); 全部的子进程才能收到主进程的信息？否则就只能和第一个进程通讯？
pleas help  me ！！

发布于8年前 · 0 次浏览 · 来自提问

文

文刀无尽Nick

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
}

From Master:  hi 4863 worker , i am master ; 
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 16

From Master:

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
}

}}}
这样一来，输出结果是
{{{

From Master:  hi 4876 worker , i am master ;

From Master:  hi 4877 worker , i am master ; 
Worker Exit, PID=4876
Worker Exit, PID=4877

}}}
看着输出变好了，是我预想的那样，
但是 swoole_process::wait() 是 回收结束运行的子进程 。
 这个和我的进程通讯，消息队列有什么关系呢?

foreach($workers as $pid =>$worker){
	$worker->push(" hi $pid worker , i am master ; ");
	$recv =  $worker->pop();//父进程接收
	echo PHP_EOL."From worker:  ".$recv.PHP_EOL;
}

for($i = 0; $i < $numbers; $i++)
{
    $ret = swoole_process::wait();
    $pid = $ret['pid'];
    unset($workers[$pid]);
    echo "Worker Exit, PID=".$pid.PHP_EOL;
}

}}}
这个代码的意思是主进程和子进程的数据通信
输出结果
{{{

From Master:   hi 4803 worker , i am master ;

From worker:   h1  master ,   i  am  4803
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Identifier removed[43] in /var/www/learn/SWOOLE/process/demo.php on line 13

From worker:

foreach($workers as $pid =>$worker){
$worker->push(" hi $pid worker , i am master ; ");
$recv = $worker->pop();//父进程接收
echo PHP_EOL."From worker: ".$recv.PHP_EOL;
}

function callback( swoole_process $worker ){//子进程
$recv = $worker->pop();//如果队列中没有数据，pop()方法会阻塞等待
echo PHP_EOL."From Master: ".$recv.PHP_EOL;
$worker->push(" h1 master , i am ".$worker->pid);//子进程向父进程发送
$worker->exit(0);
}

//下面的删除了
}}}
结果是
{{{

From Master:  hi 4934 worker , i am master ;

From worker: 
PHP Warning:  swoole_process::pop(): msgrcv() failed. Error: Identifier removed[43] in /var/www/learn/SWOOLE/process/demo.php on line 18

From Master: 
PHP Warning:  swoole_process::push(): msgsnd() failed. Error: Invalid argument[22] in /var/www/learn/SWOOLE/process/demo.php on line 20

}}}