fastadmin使用think-queue实现队列功能
功能介绍
管理端后台选择信息记录置顶，设置置顶天数，到期使用think-queue取消置顶
① 安装think-queue
使用Composer进行安装，命令行切换到项目的根目录，执行：
composer require topthink/think-queue② 配置队列储存环境，这里使用redis
return [
'connector' => 'redis', // 队列驱动使用 redis 推荐， 可选 database 不推荐
'host' => '127.0.0.1', // redis 主机地址
'password' => '', // redis 密码
'port' => 6379, // redis 端口
'select' => 2, // redis db 库, 建议显示指定 1-15 的数字均可，如果缓存驱动是 redis，避免和缓存驱动 select 冲突
'timeout' => 0, // redis 超时时间
'persistent' => false,
];③ 任务消费类
application/admin/job/JobTop.php
<?php
namespace app\admin\job;
use think\queue\Job;
use think\Db;
class JobTop
{
public function fire(Job $job, $data){
try {
$data = json_decode($data,true);
$res = Db::name('job')->where('id',$data['job_id'])->update(['is_top'=>0]);
if($res){
$job->delete();
}
} catch (\Exception $e) {
// 队列执行失败ad
\think\Log::write('queue-' . get_class() . '-置顶-id:'.$data['job_id'] . '：执行失败1，错误信息：' . $e->getMessage());
}
}
public function failed($data){
// ...任务达到最大重试次数后，失败了
}
}
④ 创建任务
public function jobtop(){
$topIds = $this->request->param('topIds/a');
$day = $this->request->param('day');
if(count($topIds) > 0){
foreach ($topIds as $k => $v) {
//前端传递的ids记录设置置顶
db('job')->where('id', $v)->update(['is_top'=>1]);
//前端传递的指定天数取消置顶，加入队列执行。
$this->addqueue($v, $day);
}
}
}
public function addqueue($job_id, $day){
$data = json_encode(['job_id' =>$job_id]);
$jobHandlerClassName = 'app\admin\job\JobTop';
// 当前任务归属的队列名称，如果为新队列，会自动创建
$jobQueueName = "jobtopQueue";
// // 即时执行
// $isPushed = Queue::push($jobHandlerClassName, $jobDataArr, $jobQueueName);
// // 延迟 2 秒执行
// $isPushed = Queue::later( 2, $jobHandlerClassName, $jobDataArr, $jobQueueName);
// // 延迟到 2017-02-18 01:01:01 时刻执行
// $time2wait = strtotime('2017-02-18 01:01:01') - strtotime('now');
// $isPushed = Queue::later($time2wait,$jobHandlerClassName, $jobDataArr, $jobQueueName);
$isPushed = Queue::later(3600 * 24 * $day, $jobHandlerClassName, $data, $jobQueueName);
if( $isPushed !== false ){
echo date('Y-m-d H:i:s') . " 加入队列ok,job_id=".$job_id."<br>";
}else{
echo '加入队列err';
}
}⑤ 前端代码
//html
<a class="btn btn-info btn-jobtop" href="javascript:;"><i class="fa fa-top"></i> 置顶</a>
//js
$(document).on("click", ".btn-jobtop", function () {
var jobids = table.bootstrapTable('getOptions').selectedIds
if(jobids.length == 0){
Toastr.error("请先选择信息");
return;
}
Layer.prompt({
formType: 0,
value: '',
title: '设置置顶天数',
area: ['200px', '50px'] //自定义文本域宽高
}, function(value, index, elem){
$.ajax({
type: 'POST',
data:{topIds: jobids, day:Number(value)},
url: 'job/jobtop',
success:function(res){
table.bootstrapTable('refresh');
layer.close(index);
}
});
});
});⑥ 监听任务并执行
php think queue:listen --queue jobtopQueue #jobtopQueue为发布任务时定义的队列名称⑦ 宝塔面板使用supervisor守护进程
启动用户：www
运行目录：当前站点运行目录
启动命令：php think queue:listen --queue jobtopQueue