Cet article vous apporte des connaissances pertinentes sur PHP, qui présentent principalement comment utiliser PHPphp pour permettre au pool de processus Swoole/Pool d'obtenir une connexion persistante Redis. Les amis intéressés peuvent y jeter un œil ensemble. J'espère que cela sera utile à tout le monde. .
php permet au pool de processus Swoole|Pool d'implémenter des connexions persistantes Redis
pool de processus, basé sur le module de processus de gestion Manager de SwooleServer. Il peut gérer plusieurs processus de travail. Par rapport à Process pour implémenter plusieurs processus, ProcessPool est plus simple et a un niveau d'encapsulation plus élevé. Les développeurs peuvent implémenter des fonctions de gestion de processus sans écrire trop de code, ils peuvent créer un style de coroutine pur et utiliser. programme de serveur CPU à plusieurs cœurs.
Le pool de processus Swoole implémente la lecture des données Redis
Dans le cas suivant, le pool de processus Redis est démarré via WorkerStart et les données de la liste Redis sont lues de manière persistante ; tous les processus enfants sont recyclés lorsque WorkerStop déconnecte toutes les connexions.
Première étape : Encodage du code
Fichier : 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();
Deuxième étape : Démarrez le service Redis et écrivez les données de la liste via le client
Ce cas nécessite que PHP installe l'extension redis
# 通过redis客户端连接 ./redis-cli 127.0.0.1:6379> lpush key1 'world'
Copiez le code
Troisième étape : Exécutez d10.php
php d10.php
Étape 4 : Vérifiez le processus
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
Étape 5 : Afficher le résultat
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#1
Le fichier d10.php sera toujours bloqué après l'exécution et continuera à lire les données de la liste Redis une fois le fichier redis terminé. La liste Redis est la sortie qui apparaît immédiatement et s'imprime à l'écran.
Apprentissage recommandé : "Tutoriel vidéo PHP"
Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!