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); $up = 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
微信扫一扫,打开小程序浏览更便捷
转载作品,原作者:世界上最好的语言,文章来源:https://www.toutiao.com/article/7160191957845688840