发表新帖

swoole_proces 子进程变量串数据

我用swoole_process 起了2个子进程 在子进程里面处理业务  子进程时间运行长了 变量间串数据了，这是啥方面问题

{{{php
$workers    = [];
$worker_num = 2;
swoole_process::daemon(1);
$redis = new Redis();
function onReceive($pipe)
{
    global $workers;
    $worker = $workers[$pipe];
    $data = $worker->read();
    if ($data == false)
    {
        //表示子进程已关闭，回收它
        $status = swoole_process::wait();
        echo "Worker#{$status['pid']} exit\n";
    }
    else
    {
        echo "RECV: ".$data;
    }
}

for($i = 0; $i < $worker_num; $i++)
{
    $process = new swoole_process('worker');
    $process->id = $i;
    $process->name('testdaemon');

$pid = $process->start();
    $workers[$process->pipe] = $process;
    swoole_event_add($process->pipe, 'onReceive');
}

function worker($process)
{
    global $redis;
    $i = 1;
    while($i++)
    {

$tpl = $token = 0;
        //业务
        $tpl   = $redis->rPop('templateMsg:msg_list');
        $token = $redis->get('accessToken:3');
        //curl 请求
        $process->write("Worker#{$process->id}: hello master\n");
        $tpl = $token = 0;

}
}
}}}
$tpl ,$token 串了

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

我用swoole_process 起了2个子进程 在子进程里面处理业务  子进程时间运行长了 变量间串数据了，这是啥方面问题

for($i = 0; $i < $worker_num; $i++)
{
    $process = new swoole_process('worker');
    $process->id = $i;
    $process->name('testdaemon');

$pid = $process->start();
    $workers[$process->pipe] = $process;
    swoole_event_add($process->pipe, 'onReceive');
}

function worker($process)
{
    global $redis;
    $i = 1;
    while($i++)
    {

}
}
}}}
$tpl ,$token 串了