fastadmin运用think-queue实现队列功能-天涯论坛

6257rv7 发表于 2024-10-10 04:28:06

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

功能介绍
管理端后台选取信息记录置顶，设置置顶天数，到期运用think-queue取消置顶
<div style="color: black; text-align: left; margin-bottom: 10px;"><img src="https://p3-sign.toutiaoimg.com/tos-cn-i-qvj2lq49k0/0b3a516eb3454d029fb33e7433f89557~noop.image?_iz=58558&from=article.pc_detail&lk3s=953192f4&x-expires=1728743394&x-signature=jKxqKROWmUBGSagzutJPoVYo8Bc%3D" style="width: 50%; margin-bottom: 20px;"></div>
① 安装think-queue
运用Composer进行安装，命令行切换到项目的根目录，执行：composer require topthink/think-queue② 配置队列储存环境，这儿运用redisreturn [
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." ";
}else{
echo 加入队列err;
}
}⑤ 前端代码//html
<a class="btn btn-info btn-jobtop" href="javascript:;">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
<div style="color: black; text-align: left; margin-bottom: 10px;"><img src="https://p3-sign.toutiaoimg.com/tos-cn-i-qvj2lq49k0/5473c4cc9dd04b28a2f6664345b326ee~noop.image?_iz=58558&from=article.pc_detail&lk3s=953192f4&x-expires=1728743394&x-signature=d7Hczu3LUQ2Uob6LKmZ82M2aZBM%3D" style="width: 50%; margin-bottom: 20px;"></div>

wrjc1hod 发表于 2024-10-10 19:26:09

i免费外链发布平台 http://www.fok120.com/

页: [1]

天涯论坛's Archiver

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