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