基于 Process\Pool 通过进程池实现数据库和 Redis 的持久连接

Swoole 进程池的简单实现

从 2.1.2 版本开始，Swoole 开始支持进程池功能，该功能基于 Server 的 Manager 模块实现，可用于管理多个工作进程。相比 Process 实现多进程，Process\Pool 更加简单，封装层次更高，开发者无需编写过多代码即可实现进程管理功能。

下面我们来看一个简单的异步进程池实现示例，通过监听 WorkerStart 事件启动 Redis 进程池，并且在 WorkerStop 时断开所有连接：

<?php
$workerNum = 5;
$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);
        echo "Processed by Worker#{$workerId}\n";
    }
});

$pool->on("WorkerStop", function ($pool, $workerId) {
    echo "Worker#{$workerId} is stopped\n";
});

$pool->start();

注：上述代码需要安装 PHP Redis 扩展才能生效。

将上述代码保存到 process/pool.php，可以看到，我们在上述 Redis 进程池中维护 5 个 Redis 连接，在 WorkerStart 时通过 pconnect 函数建立与 Redis 服务器的长连接，然后监听连接，如果列表 key1 中有数据的话，将其取出并打印出来，哪个连接进程先读取到数据则进行处理。

我们在本地启动这个进程池：

php process/pool.php

然后新建一个 Terminal 窗口，通过 ps -ef | grep php 即可看到运行的 PHP CLI 进程：

然后通过 redis-cli 启动 Redis 客户端，往 key1 列表推送数据：

在运行 php process/pool.php 的窗口即可看到打印的结果：

具体由哪个进程处理是随机的，谁先拿到数据谁处理，显然，使用进程池的方式可以维护多个长连接，避免了每次请求重复建立连接的开销，提供了系统的性能和并发性，而在传统的 PHP-FPM 模式中，每次 HTTP 请求都会创建新的 Redis 连接。

在 Laravel 中实现数据库和 Redis 的持久连接

在 Laravel 项目中，如果使用了 LaravelS 扩展包，则只需要在 config/database.php 中启用 MySQL 和 Redis 的持久连接配置接即可实现二者的持久连接：

// 数据库持久连接配置
'mysql' => [
        'driver' => 'mysql',
        'host' => env('DB_HOST', '127.0.0.1'),
        'port' => env('DB_PORT', '3306'),
        'database' => env('DB_DATABASE', 'forge'),
        'username' => env('DB_USERNAME', 'forge'),
        'password' => env('DB_PASSWORD', ''),
        'unix_socket' => env('DB_SOCKET', ''),
        'charset' => 'utf8mb4',
        'collation' => 'utf8mb4_unicode_ci',
        'prefix' => '',
        'prefix_indexes' => true,
        'strict' => true,
        'engine' => null,
        'options' => extension_loaded('pdo_mysql') ? array_filter([
            PDO::MYSQL_ATTR_SSL_CA => env('MYSQL_ATTR_SSL_CA'),
            PDO::ATTR_PERSISTENT => true
        ]) : [],
    ],

// Redis 持久连接配置
'redis' => [
    ...
    'default' => [
        'host' => env('REDIS_HOST', '127.0.0.1'),
        'password' => env('REDIS_PASSWORD', null),
        'port' => env('REDIS_PORT', 6379),
        'database' => env('REDIS_DB', 0),
        'persistent' => true
    ],
    ...
]

因为基于 Swoole 的 HTTP 服务器会持久化对象，在已启动的 Swoole 服务器进程中，Redis 和 MySQL 连接实例会一直存在，知道进程退出，并且 LaravelS 会在自动维护 MySQL 的连接状态，一旦断开，会立即重连，而 Redis 持久连接状态则不会自动维护，断开时会抛出异常，需要开发者自行维护持久连接的异常断开情况。

所以，LaravelS 只提供了对数据库和 Redis 的持久连接支持，并没有维护相应的进程池，不过，持久连接已经大大优于 PHP-FPM 模式下每次请求需要新建连接的性能了，如果你的系统并发量更大，则可以考虑监听 Swoole 的 WorkerStart 事件来启动进程池维护多个长连接，对于 MySQL 数据库，有现成的 SMProxy 扩展包可供使用，感兴趣的同学可以去看看。