基于 Process\Pool 通过进程池实现数据库和 Redis 的持久连接
Swoole 进程池的简单实现
从 2.1.2 版本开始，Swoole 开始支持进程池功能，该功能基于 Server 的 Manager 模块实现，可用于管理多个工作进程。相比 Process 实现多进程，Process\Pool 更加简单，封装层次更高，开发者无需编写过多代码即可实现进程管理功能。
下面我们来看一个简单的异步进程池实现示例，通过监听 WorkerStart 事件启动 Redis 进程池，并且在 WorkerStop 时断开所有连接：
xxxxxxxxxx<?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 中有数据的话，将其取出并打印出来，哪个连接进程先读取到数据则进行处理。
我们在本地启动这个进程池：
xxxxxxxxxxphp 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 的持久连接配置接即可实现二者的持久连接：
xxxxxxxxxx// 数据库持久连接配置'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 扩展包可供使用，感兴趣的同学可以去看看。
No Comments