PHP+redis+常驻进程处理队列数据

1、首先将我们需要处理的数据插入redis队列，代码如下：

//将数据插入redis队列
public function ruDui(){$codeObj = new DataIntegrationCode();$this->redis = new \Redis();//连接redis$this->redis->connect($codeObj::REDIS_HOST, $codeObj::REDIS_PORT);$this->redis->auth($codeObj::REDIS_AUTH);$this->redis->select(2);//入队$this->redis->rpush("unit_Que",'**********');}

2、数据处理，出队操作：代码如下：

 //出队操作       public function chuDui(){set_time_limit(0);ini_set('default_socket_timeout', -1); // 不超时$queue = 'unit_Que';$codeObj            = new DataIntegrationCode();$this->redis = new \Redis();$this->redis->connect($codeObj::REDIS_HOST, $codeObj::REDIS_PORT);$this->redis->auth($codeObj::REDIS_AUTH);$this->redis->select(2);while(true) {$r = $this->redis->brPop($queue, 0);在这里进行数据操作}}

3、linux系统设置常驻进程，命令如下：

PHP+redis+常驻进程处理队列数据相关推荐

tp5 queue.php,tp5(think-queue)消息队列+supervisor进程管理实现队列常驻进程
前言传统的程序执行流程一般是即时|同步|串行的,在某些场景下,会存在并发低,吞吐量低,响应时间长等问题.在大型系统中,一般会引入消息队列的组件,将流程中部分任务抽离出来放入消息队列,并由专门的消费 ...
简述thinkphp自带队列think-queue的使用以及通过supervisor实现常驻进程
think-queue是thinkphp官方提供的一个消息队列服务,适用于大并发.返回结果时间较长.需要批量操作等专门支持队列服务的扩展包.例如短信发送.模板消息邮件等推送.可以进行发布.获取.执行. ...
python使用redis队列_Python的Flask框架应用调用Redis队列数据的方法
任务异步化打开浏览器,输入地址,按下回车,打开了页面.于是一个HTTP请求(request)就由客户端发送到服务器,服务器处理请求,返回响应(response)内容. 我们每天都在浏览网页,发送大大小 ...
python redis 消息队列_Python的Flask框架应用调用Redis队列数据的方法
任务异步化打开浏览器,输入地址,按下回车,打开了页面.于是一个HTTP请求(request)就由客户端发送到服务器,服务器处理请求,返回响应(response)内容. 我们每天都在浏览网页,发送大大小 ...
python实时监控redis队列_Python的Flask框架应用调用Redis队列数据
任务异步化打开浏览器,输入地址,按下回车,打开了页面.于是一个HTTP请求(request)就由客户端发送到服务器,服务器处理请求,返回响应(response)内容. 我们每天都在浏览网页,发送大大 ...
进程锁、事件、进程队列、进程间共享数据、生产者消费者模型
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档文章目录进程锁(Lock) 锁的基本概念锁的基本用法模拟12306抢票软件信号量:Semaphone 概念 Semaphore ...
一看就懂系列之如何实现与控制php常驻进程
版权声明:本文为博主原创文章,未经博主允许不得转载. 目录(?)[+] 前言关于如何实现与控制php常驻进程,不管是google还是baidu上进行搜索,都没有感觉看起来赏心悦目的解答,于是决定自己 ...
Spark删除redis千万级别set集合数据
1.使用pipline的原因 Redis 使用的是客户端-服务器(CS)模型和请求/响应协议的 TCP 服务器.这意味着通常情况下一个请求会遵循以下步骤: 客户端向服务端发送一个查询请求,并监听 So ...
如何管理php常驻进程,一看就懂系列之如何实现与控制php常驻进程-Go语言中文社区...
前言关于如何实现与控制php常驻进程,不管是google还是baidu上进行搜索,都没有感觉看起来赏心悦目的解答,于是决定自己动手总结下. 有同学会问了,整这个干甚?简单的说就是,可以让一个php脚 ...

PHP+redis+常驻进程处理队列数据

PHP+redis+常驻进程处理队列数据相关推荐

最新文章

热门文章