安装
使用composer安装拓展包
composer require topthink/think-queue
默认安装是最新版的，如果不是tp6，使用2.0版本
composer require topthink/think-queue 2.0
配置
配置文件位于 config/queue.php
[
'connector'=>'sync' //驱动类型，可选择 sync(默认):同步执行，database:数据库驱动,redis:Redis驱动,topthink:Topthink驱动
//或其他自定义的完整的类名
]
推荐用redis，使用database时，每3秒就会访问一次数据库，日志生成超级多，好无语
任务类
创建job类
<?php
namespace app\job
use think\queue\Job;
class RegisterPushJobs
{
public function fire(Job $job, $data){
//....这里执行具体的任务
if ($job->attempts() > 3) {
//通过这个方法可以检查这个任务已经重试了几次了
}
//如果任务执行成功后 记得删除任务，不然这个任务会重复执行，直到达到最大重试次数后失败后，执行failed方法
$job->delete();
// 也可以重新发布这个任务
$job->release($delay); //$delay为延迟时间
}
public function failed($data){
// ...任务达到最大重试次数后，失败了
}
}
调用并且发布任务
在控制器调用队列
$data=['key'=>'value'];
//延迟两小时执行
Queue::later(2*60*60,'app\job\RegisterPushJobs',$data);
//即刻执行
Queue::push(2*60*60,'app\job\RegisterPushJobs',$data);
监听任务并执行的指令
php think queue:listen
php think queue:work --daemon（不加--daemon为执行单个任务）
通过supervisor实现常驻进程
安装supervisor之后，supervisor配置文件可以看到,可以在 supervisord.d目录下自定义增加后缀为ini的配置文件
[include]
files = supervisord.d/*.ini
在etc/supervisord.d目录下创建queue.ini
[program:queue_worker] ;项目名称
directory = /www/wwwroot/tp5.com ;目录，项目根目录的上一级
command = php think queue:listen --queue zhan,hai ; 启动命令 zhan 就是队列名,多个队列就用逗号拼接起来
process_name=%(program_name)s_%(process_num)02d
numprocs = 3 ; 开启的进程数量
autostart = true ; 在 supervisord 启动的时候也自动启动
startsecs = 5 ; 启动 5 秒后没有异常退出，就当作已经正常启动了
autorestart = true ; 程序异常退出后自动重启
startretries = 3 ; 启动失败自动重试次数，默认是 3
user = root ; 用哪个用户启动
redirect_stderr = true ; 把 stderr 重定向到 stdout，默认 false
stdout_logfile_maxbytes = 50MB ; stdout 日志文件大小，默认 50MB
stdout_logfile_backups = 20 ; stdout 日志文件备份数
; stdout 日志文件,需要手动创建目录（supervisord 会自动创建日志文件）
stdout_logfile = /usr/local/supervisor/log/queue_worker.log ;日志的位置
loglevel=info
重启supervisor
systemctl restart supervisord
拓展，supervisor常用指令
#查看任务状态，可以查看单个任务状态: supervisorctl status 服务名
supervisorctl status
#启动任务
supervisorctl start 服务名
#停止任务
supervisorctl start 服务名
#重启任务
supervisorctl restart 服务名
#当增加任务配置文件后，可以更新任务
supervisorctl update //配置文件修改后使用该命令加载新的配置
supervisorctl reload //重新启动配置中的所有程序
supervisorctl shutdown //关闭supervisord
supervisorctl clear 进程名 //清空进程日志
