Swoole-2.1.2 进程池模块的使用

男娘i 2023-10-18 00:57 126阅读 0赞

在 `Swoole-2.1.2`  
版本中我们将 `Server`  
的 [进程 ][Link 1][管理 ][Link 2]模块封装成了 `PHP`  
类，现在可以在 `PHP`  
[代码 ][Link 3]中使用 `Swoole`  
的进程管理器了。

在实际项目中经常需要写一些长期运行的脚本，如基于 `redis`  
、 `kafka`  
、 `rabbitmq`  
实现的多进程队列消费者，多进程爬虫等等。 [程序员 ][Link 4]需要使用 `pcntl`  
和 `posix`  
相关的扩展库实现多进程编程，需要 [开发者 ][Link 5]具备深厚的 `Linux`  
系统编程功底，否则很容易出现问题。

`Swoole`  
提供的进程管理器来自于 `Swoole/Server`  
，经过大量生产项目验证，稳定性和健壮性都非常高。可大大简化多进程脚本编程工作。

### 一、 创建进程池 ###

在 `PHP`  
代码中使用 `new Swoole/Process/Pool`  
即可创建一个进程池，构造方法的第一个 [参数 ][Link 6]传入工作进程的数量。使用 `on`  
方法设置 `WorkerS tar t`  
即可在工作进程启动时执行指定的代码，可以在这里进行 `while(true)`  
循环从 `redis`  
队列中获取任务并处理。使用 `start`  
方法启动所有进程，管理器开始进入 `wait`  
状态。

$workerNum = 10;
    $pool = new Swoole/Process/Pool($workerNum);
    
    $pool->on("WorkerStart", function ($pool, $workerId) {
        echo "Worker#{$workerId} is started/n";
        $redis = new Redis();
        $redis->pconnect('127.0.0.1', 6379);
        $key = "key1";
        while (true) {
             $msgs = $redis->brpop($key, 2);
             if ( $msgs == null) continue;
             var_dump($msgs);
         }
    });
    
    $pool->on("WorkerStop", function ($pool, $workerId) {
        echo "Worker#{$workerId} is stopped/n";
    });
    
    $pool->start();

使用进程管理器，可以保证工作进程的稳定性。

*  某个工作进程遇到致命错误、主动退出时管理器会进行回收，避免出现僵尸进程
 *  工作进程退出后，管理器会自动拉起、创建一个新的工作进程

### 二、信号处理 ###

`Swoole`  
进程管理器自带了信号处理，向管理器进程发送：

*  `SIGTERM`  
    信号：中止服务，向所有工作进程发送 `SIGTERM`  
    关闭进程
 *  `SIGUSR1`  
    信号：重启工作进程，管理器会逐个重启工作进程

在工作进程中可以配合使用 `pcntl_signal`  
和 `pcntl_signal_dispatch`  
实现信号处理。

$pool->on("WorkerStart", function ($pool, $workerId) {
        $running = true;
        pcntl_signal(SIGTERM, function () use (&$running) {
            $running = false;
        });
        echo "Worker#{$workerId} is started/n";
        $redis = new Redis();
        $redis->pconnect('127.0.0.1', 6379);
        $key = "key1";
        while ($running) {
             $msgs = $redis->brpop($key, 2);
             pcntl_signal_dispatch();
             if ( $msgs == null) continue;
             var_dump($msgs);
         }
    });

### 三、任务投递 ###

`Swoole`  
进程管理器自带了 [消息队列 ][Link 7]和 `TCP -Socket`  
消息投递的支持。可设置监听系统队列或者 `TCP`  
[端口 ][Link 8]，接收任务 [数据 ][Link 9]。此项功能是可选的，要使用任务投递功能，需要对进程池对象设置 `onMessage`  
回调。

消息队列

$pool = new Swoole/Process/Pool(2, SWOOLE_IPC_MSGQUEUE, 0x7000001);
    
    $pool->on("Message", function ($pool, $message) {
        echo "Message: {$message}/n";
    });
    
    $pool->start();

需要在构造方法的第二个参数传入 `SWOOLE_IPC_MSGQUEUE`  
，第三个参数设置监听的消息队列 `KEY`  
。其他程序中使用消息队列相关 `API`  
就可以向工作进程投递任务了。

TCP 端口

$pool = new Swoole/Process/Pool(2, SWOOLE_IPC_SOCKET);
    $pool->on("Message", function ($pool, $message) {
        echo "Message: {$message}/n";
    });
    $pool->listen('127.0.0.1', 8089);
    $pool->start();

使用 `TCP`  
端口监听，需要设置构造方法的第二个参数为 `SWOOLE_IPC_SOCKET`  
，并使用 `listen`  
方法设置监听的 [主机 ][Link 10]和端口。

底层使用了 `4`  
字节长度+包体的 [协议 ][Link 11]。其他程序中向此端口发送数据时，需要在数据包之前增加一个长度字段。

$fp = stream_socket_client("tcp://127.0.0.1:8089", $errno, $errstr) or die("error: $errstr/n");
    $msg = json_encode(['data' => 'hello', 'uid' => 1991]);
    fwrite($fp, pack('N', strlen($msg)).$msg);
    fclose($fp);

*原文*

[https ][https]://segmentfault.com/a/1190000014303621

> *本站部分文章源于互联网，本着传播知识、有益学习和研究的目的进行的转载，为网友免费提供。如有著作权人或出版方提出异议，本站将立即删除。如果您对文章转载有任何疑问请告之我们，以便我们及时纠正。 **PS：如果您想和业内技术大牛交流的话，请加qq群(474807195)或者关注微信公众号(AskHarries)，谢谢！***

转载请注明原文出处： [Harries Blog™ ][Harries Blog_]» [Swoole-2.1.2 进程池模块的使用][Swoole-2.1.2]

来源:[http://ju.outofmemory.cn/entry/350679][Swoole-2.1.2]

[Link 1]: http://www.liuhaihua.cn/archives/tag/%E8%BF%9B%E7%A8%8B
[Link 2]: http://www.liuhaihua.cn/archives/tag/%E7%AE%A1%E7%90%86
[Link 3]: http://www.liuhaihua.cn/archives/tag/%E4%BB%A3%E7%A0%81
[Link 4]: http://www.liuhaihua.cn/archives/tag/%E7%A8%8B%E5%BA%8F%E5%91%98
[Link 5]: http://www.liuhaihua.cn/archives/tag/%E5%BC%80%E5%8F%91%E8%80%85
[Link 6]: http://www.liuhaihua.cn/archives/tag/%E5%8F%82%E6%95%B0
[Link 7]: http://www.liuhaihua.cn/archives/tag/%E6%B6%88%E6%81%AF%E9%98%9F%E5%88%97
[Link 8]: http://www.liuhaihua.cn/archives/tag/port
[Link 9]: http://www.liuhaihua.cn/archives/tag/%E6%95%B0%E6%8D%AE
[Link 10]: http://www.liuhaihua.cn/archives/tag/%E4%B8%BB%E6%9C%BA
[Link 11]: http://www.liuhaihua.cn/archives/tag/protocol
[https]: http://www.liuhaihua.cn/archives/tag/https
[Harries Blog_]: http://www.liuhaihua.cn/
[Swoole-2.1.2]: http://ju.outofmemory.cn/entry/350679