swoole_process父子进程管道通信案例

Cheng_Gang 发布于2019-07-01 12:32 / 2758人阅读

摘要：话不多说直接上代码创建的子进程获取异步获取更高性能启动子进程子进程处理逻辑异步非阻塞网关连接失败读取父进程管道消息父进程获取子进程的管道消息子进程消息子进程的客户端可以忽略不计，本只是

话不多说直接上代码

创建的子进程：

public function __construct()
    {
        $this->redis   = Container::get(SwooleRedis::class);//获取异步redis获取更高性能
        $this->process = new swoole_process(function (swoole_process $process) {
            return $this->process($process);
        }, false, SOCK_DGRAM);
        $this->process->name("Test_Gateway");
        $this->process->useQueue();
        $this->process->start();//启动子进程
    }
    
    /**
     * 子进程处理逻辑
     * @param swoole_process $process
     */
    private function process(swoole_process $process)
    {
        $client = new swoole_client(SWOOLE_SOCK_TCP, SWOOLE_SOCK_ASYNC); //异步非阻塞
        
        $client->on("connect", function (swoole_client $cli) use ($process) {
            $process->write("connected");
        });
        
        $client->on("receive", function (swoole_client $cli, $data) use ($process) {
            $process->write($data);
        });
        
        $client->on("error", function (swoole_client $cli) use ($process) {
            $process->write("error");
        });
        
        $client->on("close", function (swoole_client $cli) use ($process) {
            $process->write("close");
        });
        
        if ($client->connect("127.0.0.1", 90, -1)) {
        
        } else {
            $process->write("网关连接失败");
        }
        
        swoole_event_add($process->pipe,
            function ($pipe) use ($process, $client) {//读取父进程管道消息
                $client->send($process->read());
            });
    }

父进程onWorkerStart:

/**
     * @param swoole_server $serv
     * @param               $worker_id
     */
    public function onWorkerStart(swoole_server $serv, $worker_id)
    {
        if ($worker_id === 0) {
            swoole_timer_tick(1000, function () {
                $this->process->write("ping");
            });
            $process = $this->process;
            swoole_event_add($process->pipe,
                function ($pipe) use ($process) {//获取子进程的管道消息
                    echo "子进程消息：" . $process->read() . PHP_EOL;
                });
        }
    }

子进程的client客户端可以忽略不计，本demo只是掩饰管道通信的例子

使用管道就不可以使用消息队列：$process_push()和$process->pop();

理论上在父子进程各注册一个event_loop即可实现一边发消息一边接收

其他的后续补充

私有云混合云 linux的父子进程 php 杀死父子进程父子组件通信 javascript父子通信

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/30929.html

PHP多进程系列笔记（五）

摘要：消息队列更常见的用途是主进程分配任务，子进程消费执行。子进程前面加了个，这是为了防止父进程还未往消息队列中加入内容直接退出。前面几节都是讲解pcntl扩展实现的多进程程序。本节给大家介绍swoole扩展的swoole_process模块。 swoole多进程 swoole_process 是swoole提供的进程管理模块，用来替代PHP的pcntl扩展。首先，确保安装的swoole...

qianfeng 2019-07-01 10:13 评论0 收藏0
使用 swoole_process 实现 PHP 进程池

摘要：本文使用与完成一个的进程池，并且支持动态创建新进程。接着遍历所有的进程，并且加入中，设置可读事件，用于接收子进程的空闲信号。最后每隔一秒向进程投递任务。由于只模拟了十次任务，则第十个任务完成之后在父进程中发送使所有子进程退出。 swoole_process 主要是用来代替 PHP 的 pcntl 扩展。我们知道 pcntl 是用来进行多进程编程的，而 pcntl 只提供了 fork 这...

CrazyCodes 2019-07-01 18:55 评论0 收藏0
使用 swoole_process 实现 PHP 进程池

摘要：本文使用与完成一个的进程池，并且支持动态创建新进程。接着遍历所有的进程，并且加入中，设置可读事件，用于接收子进程的空闲信号。最后每隔一秒向进程投递任务。由于只模拟了十次任务，则第十个任务完成之后在父进程中发送使所有子进程退出。 swoole_process 主要是用来代替 PHP 的 pcntl 扩展。我们知道 pcntl 是用来进行多进程编程的，而 pcntl 只提供了 fork 这...

Andrman 2019-07-01 10:52 评论0 收藏0
swoole——从入门到放弃（三）

摘要：从入门到放弃三一进程子进程创建成功后要执行的函数重定向子进程的标准输入和输出。默认为阻塞读取。是否创建管道，启用后，此选项将忽略用户参数，强制为。 swoole——从入门到放弃（三）一、进程 swoole_process SwooleProcess swoole_process::__construct(callable $function, $redirect_stdin...

王笑朝 2019-07-01 12:29 评论0 收藏0
swoole——从入门到放弃（三）

摘要：从入门到放弃三一进程子进程创建成功后要执行的函数重定向子进程的标准输入和输出。默认为阻塞读取。是否创建管道，启用后，此选项将忽略用户参数，强制为。 swoole——从入门到放弃（三）一、进程 swoole_process SwooleProcess swoole_process::__construct(callable $function, $redirect_stdin...

rottengeek 2019-07-25 14:19 评论0 收藏0