tp5.0 queue 队列操作

检查是否安装redis(没有请自行百度安装)：

phpinfo：

配置thinkphp-queue，没有请执行 composer require topthink/think-queue 加入：

创建队列文件：

use think\Queue;class TestQueue
{// 测试public function queue(){// 推迟 n 秒执行  $queue = '指定队列名'Queue::later('2', 'app\message\job\Work','aa@qq.com','');// 执行 Work 的 send 方法//Queue::push('app\message\job\Work@send','aa@qq.com');// 默认执行 Work 的 fire 方法//Queue::push('app\message\job\Work','aa@qq.com');
echo '加入队列成功';}
}

队列逻辑处理文件：

namespace app\message\job;use think\queue\Job;class Work
{// 默认执行的方法public function fire(Job $job, $data){$isJobDone = $this->send($data);if ($isJobDone) {//成功删除任务$job->delete();} else {//任务轮询4次后删除if ($job->attempts() > 3) {// 第1种处理方式：重新发布任务,该任务延迟10秒后再执行//$job->release(10);// 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数//$job->failed();// 第3种处理方式：删除任务$job->delete();}}}/*** 根据消息中的数据进行实际的业务处理* @param array|mixed    $data     发布任务时自定义的数据* @return boolean                 任务执行的结果*/private function send($data){// 开始执行队列的逻辑echo 'int ....';echo PHP_EOL;echo 'data: ' .$data;echo PHP_EOL;// ...return true;}
}

后台监听即可：

php think queue:listen

php think queue:listen --queue 'queuename'   // 监听指定队列

访问 127.0.0.1/message/testqueue (路由自行配置)

控制台查看

参考文档：https://github.com/coolseven/notes/blob/master/thinkphp-queue/README.md

守护进程(supervisor)：https://blog.csdn.net/qq_34856247/article/details/86741533

转载于:https://www.cnblogs.com/xdtx/p/9540904.html

tp5.0 queue 队列操作相关推荐

Tp5 实现 think-queue 队列操作
安装首先查看ThinkPHP框架版本,然后进入Packagist官网搜索think-queue,并根据ThinkPHP版本选择对应think-queue版本. thinkphp-queue地址:ht ...
Queue队列操作-peek、pool、take等区别
Java基础在Java中阻塞队列的一些操作特性 add 增加一个元索如果队列已满,则抛出一个IIIegaISlabEepeplian异常 remove 移除并返回队列头部的元素如果队列为空,则抛 ...
tp5 queue.php,tp5(think-queue)消息队列+supervisor进程管理实现队列常驻进程
前言传统的程序执行流程一般是即时|同步|串行的,在某些场景下,会存在并发低,吞吐量低,响应时间长等问题.在大型系统中,一般会引入消息队列的组件,将流程中部分任务抽离出来放入消息队列,并由专门的消费 ...
tp5.0 think-queue 消息队列
安装 think-queue composer require topthink/think-queue 1.1.4 不加版本号默认安装的最新的queue ,适用于tp6.0. 使用tp5.0 只需 ...
python线性表和队列_[笔记]python数据结构之线性表：linkedlist链表,stack栈,queue队列...
python数据结构之线性表 python内置了很多高级数据结构,list,dict,tuple,string,set等,在使用的时候十分舒心.但是,如果从一个初学者的角度利用python学习数据结构 ...
python【蓝桥杯vip练习题库】ADV-233 队列操作
VIP到期了,今天开始暂时不更新了. 试题算法提高队列操作资源限制时间限制:1.0s 内存限制:256.0MB 问题描述队列操作题.根据输入的操作命令,操作队列(1)入队.(2)出队并输出 ...
python 进程间通信效率_Python进程间通信 multiProcessing Queue队列实现详解
一.进程间通信 IPC(Inter-Process Communication) IPC机制:实现进程之间通讯管道:pipe 基于共享的内存空间队列:pipe+锁的概念--->queue 二 ...
【C++ 语言】容器 ( queue 队列 | stack 栈 | priority_queue 优先级队列 | set 集合 | 容器遍历 | map )
文章目录 queue 队列 stack 栈 priority_queue 优先级队列 priority_queue 优先级队列指定排序方法 priority_queue 优先级队列排序行为 prior ...
java集合类——Stack栈类与Queue队列
今日走读代码时,遇到stack栈类,特查看java的API文档,总结如下: Stack继承Vector类,它通过五个操作对类 Vector 进行了扩展. 栈是后进先出的. 栈提供了通常的 push ...

tp5.0 queue 队列操作

tp5.0 queue 队列操作相关推荐

最新文章

热门文章