外链论坛

 找回密码
 立即注册
搜索
查看: 12|回复: 1

fastadmin运用think-queue实现队列功能

[复制链接]

2914

主题

144

回帖

9913万

积分

论坛元老

Rank: 8Rank: 8

积分
99139587
发表于 2024-10-10 04:28:06 | 显示全部楼层 |阅读模式

功能介绍

管理端后台选取信息记录置顶,设置置顶天数,到期运用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

回复

使用道具 举报

2930

主题

2万

回帖

9956万

积分

论坛元老

Rank: 8Rank: 8

积分
99569372
发表于 2024-10-10 19:26:09 | 显示全部楼层
i免费外链发布平台 http://www.fok120.com/
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

站点统计|Archiver|手机版|小黑屋|外链论坛 ( 非经营性网站 )|网站地图

GMT+8, 2024-11-6 00:39 , Processed in 0.074067 second(s), 20 queries .

Powered by Discuz! X3.4

Copyright © 2001-2023, Tencent Cloud.