這篇文章為大家帶來了關於php的相關知識，其中主要介紹了透過PHPphp讓Swoole/Pool進程池實現Redis持久連接，有興趣的朋友下面一起來看一下吧，希望對大家有幫助。
php 讓Swoole | Pool程序池實作Redis持久連接
進程池，基於Swoole\Server的Manager管理進程模組實現。可管理多個工作進程，相較於Process 實作多進程，Process\Pool 更加簡單，封裝層次更高，開發者無需編寫過多程式碼即可實現進程管理功能，配合Co\Server 可以創建純協程風格的，能利用多核心CPU 的服務端程式。
Swoole進程池實現redis資料讀取
如下案例，透過WorkerStart啟動Redis進程池，並持久讀取Redis列表資料；當WorkerStop斷開所有連接時回收所有子進程。
第一步：編碼程式碼
檔案：d10.php
<?php
use Swoole\Process;
use Swoole\Coroutine;
// 指定5个工作进程
$pool = new Process\Pool(5);
// 设置启用协程
$pool->set(['enable_coroutine' => true]);
/**
* onWorkerStart 子进程启动
* @param \Swoole\Process\Pool $pool Pool对象
* @param int $workerId WorkerId当前工作进程的编号，底层会对子进程进行标号
**/
$pool->on("WorkerStart", function (Process\Pool $pool, $workerId) {
// 输出当前工作进程
echo "Worker #{$workerId} is started\n";
// 实例化化连接redis
$redis = new Redis();
$redis->pconnect('127.0.0.1', 6379);
// 指定redis键
$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();第二步：啟動Redis服務並透過客戶端寫入清單資料
案例需要php安裝redis擴充
# 通过redis客户端连接 ./redis-cli 127.0.0.1:6379> lpush key1 'world'
複製程式碼
第三個步驟：執行d10.php
php d10.php
第四步：查看進程
ps aux | grep php root 938 0.0 1.2 129164 12412 ? Ss Apr21 0:00 php-fpm: master process (/usr/local/php-8.0.1/etc/php-fpm.conf) www 951 0.0 0.6 129164 6636 ? S Apr21 0:00 php-fpm: pool www www 952 0.0 0.6 129164 6640 ? S Apr21 0:00 php-fpm: pool www root 12327 0.0 1.2 126992 12800 pts/2 S+ 00:02 0:00 php d10.php root 12328 0.0 0.7 131096 7444 pts/2 S+ 00:02 0:00 php d10.php root 12329 0.0 0.7 131096 7448 pts/2 S+ 00:02 0:00 php d10.php root 12330 0.0 0.7 131096 7448 pts/2 S+ 00:02 0:00 php d10.php root 12331 0.0 0.7 131096 7448 pts/2 S+ 00:02 0:00 php d10.php root 12332 0.0 0.7 131096 7448 pts/2 S+ 00:02 0:00 php d10.php root 12355 0.0 0.0 112812 976 pts/3 R+ 00:09 0:00 grep --color=auto php
第五步：輸出結果
php d10.php
Worker #1 is started
Worker #2 is started
Worker #3 is started
Worker #4 is started
Worker #0 is started
array(2) {
[0]=>
string(4) "key1"
[1]=>
string(5) "world"
}
Processed by Worker#1d10.php檔案運行後會一直處於阻塞狀態而一直讀取redis列表數據，一旦Redis列表中輸出，則立刻被彈出並打印在屏幕中。
推薦學習：《PHP影片教學》
以上是聊聊php怎麼讓Swoole/Pool進程池實現Redis持久連接的詳細內容。更多資訊請關注PHP中文網其他相關文章！
