php如何让Swoole/Pool进程池实现Redis持久连接

本篇内容主要讲解“php如何让Swoole/Pool进程池实现Redis持久连接”，感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷，实用性强。下面就让小编来带大家学习“php如何让Swoole/Pool进程池实现Redis持久连接”吧! php 让 Swoole | Pool进程池实现Redis持久连接进程池，基于SwooleServer的Manager管理进程模块实现。可管理多个工作进程，相比 Process 实现多进程，ProcessPool 更加简单，封装层次更高，开发者无需编写过多代码即可实现进程管理功能，配合 CoServer 可以创建纯协程风格的，能利用多核 CPU 的服务端程序。Swoole进程池实现redis数据读取如下案例，通过WorkerStart启动Redis进程池，并持久读取Redis列表数据；当WorkerStop断开所有连接时回收所有子进程。第一步：编码代码文件：d10.php


set(['enable_coroutine'=>true]);

/**
*onWorkerStart子进程启动
*@paramSwooleProcessPool$poolPool对象
*@paramint$workerIdWorkerId当前工作进程的编号，底层会对子进程进行标号
**/
$pool->on("WorkerStart",function(ProcessPool$pool,$workerId){
//输出当前工作进程
echo"Worker#{$workerId}isstartedn";

//实例化化连接redis
$redis=newRedis();
$redis->pcon免费云主机域名nect('127.0.0.1',6379);
//指定redis键
$key="key1";

//循环读取列表数据
while(true){
//弹出列表最后一个元素
$msgs=$redis->brpop($key,2);
//元素值为空则跳过
if($msgs==null){
continue;
}
//打印获取的值
var_dump($msgs);
echo"ProcessedbyWorker#{$workerId}n";
}
});

//子进程结束
$pool->on("WorkerStop",function($pool,$workerId){
echo"Worker#{$workerId}isstoppedn";
});

//启动工作进程
$pool->start();

第二步：启动Redis服务并通过客户端写列表数据该案例需要php安装redis扩展


#通过redis客户端连接
./redis-cli

127.0.0.1:6379>lpushkey1'world'

复制代码第三步：运行d10.php


phpd10.php

第四步：查看进程


psaux|grepphp
root9380.01.212916412412?SsApr210:00php-fpm:masterprocess(/usr/local/php-8.0.1/etc/php-fpm.conf)
www9510.00.61291646636?SApr210:00php-fpm:poolwww
www9520.00.61291646640?SApr210:00php-fpm:poolwww
root123270.01.212699212800pts/2S+00:020:00phpd10.php
root123280.00.71310967444pts/2S+00:020:00phpd10.php
root123290.00.71310967448pts/2S+00:020:00phpd10.php
root123300.00.71310967448pts/2S+00:020:00phpd10.php
root123310.00.71310967448pts/2S+00:020:00phpd10.php
root123320.00.71310967448pts/2S+00:020:00phpd10.php
root123550.00.0112812976pts/3R+00:090:00grep--color=autophp

第五步：输出结果


phpd10.php

Worker#1isstarted
Worker#2isstarted
Worker#3isstarted
Worker#4isstarted
Worker#0isstarted
array(2){
[0]=>
string(4)"key1"
[1]=>
string(5)"world"
}
ProcessedbyWorker#1

d10.php文件运行后会一直处于阻塞状态而一直读取redis列表数据，一旦Redis列表中输出，则立刻被弹出并打印在屏幕中。到此，相信大家对“php如何让Swoole/Pool进程池实现Redis持久连接”有了更深的了解，不妨来实际操作一番吧！这里是百云主机网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！

相关推荐: Mysql聚合函数如何使用

这篇文章主要介绍了Mysql聚合函数如何使用的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇Mysql聚合函数如何使用文章都会有所收获，下面我们一起来看看吧。聚合函数用来对表中的数据进行统计和计算。users表结构如下:聚合函数是用…