swoole 父子進程間通信

 

<?php
/**
 * 場景：
 * 監控訂單表狀態 父子進程通信
 * 一個主進程 兩個子進程實現
 */

//設置主進程名
echo '主進程id:' . posix_getpid() . PHP_EOL;
cli_set_process_title('php_main');

//1、此子進程用於監聽數據的改變
$process1 = new Swoole\Process(function (\Swoole\Process $process) {
//    cli_set_process_title('php_child');
    $process->name('php_child1');
    $pdo = new PDO('mysql:host=mysql;dbname=test', 'root', 'root');

    while (true) {
        $statement = $pdo->query('select * from `order` where is_pay=1 and is_notice=0 order by id desc');
        $data = $statement->fetch(PDO::FETCH_ASSOC);
        if ($data) {
            //向主進程發送消息
            $process->write('php_child1發送' . $data['client_name'] . '已支付 ');
            $pdo->exec('update `order` set is_notice=1 where id=' . $data['id']);
        }
        sleep(3);
    }
}, false, SOCK_STREAM, true);
echo '子進程1 id:' . $process1->start() . PHP_EOL;

//2、此子進程用於發送郵件
$process2 = new Swoole\Process(function (\Swoole\Process $process) {
    $process->name('php_child2');
    while (true) {
        $orderInfo = $process->read();
        if ($orderInfo) {
            echo $orderInfo;
            echo 'php_child2發送郵件' . PHP_EOL;
        }
        sleep(3);
    }
}, false, SOCK_STREAM, true);
echo '子進程2 id:' . $process2->start() . PHP_EOL;


while (true) {
    //主進程讀取子進程1中的消息
    $orderInfo = $process1->read();
    if ($orderInfo) {
        //主進程發送數據給子進程2
        $process2->write($orderInfo);
    }
    sleep(3);
}

//\Swoole\Process::wait();
//使用Process作為監控父進程，創建管理子進程時，父類必須注冊信號SIGCHLD對退出的進程執行wait，否則子進程退出時會變成僵屍進程
Swoole\Process::signal(SIGTERM, function ($signo) {
    echo "shutdown.";
});