# 使用think-queue隊列筆記 ## 一、安裝 github地址： [top-think/think-queue: ThinkPHP 隊列支持 (github.com)](https://github.com/top-think/think-queue) composer 安裝： ~~~ composer require topthink/think-queue ~~~ ## 二、配置： > 配置文件位于`config/queue.php` ### 公共配置 ~~~ [ 'default'=>'sync' //驅動類型，可選擇 sync(默認):同步執行，database:數據庫驅動,redis:Redis驅動//或其他自定義的完整的類名 ] ~~~ ## 使用： 任務類不需繼承任何類，如果這個類只有一個任務，那么就只需要提供一個`fire`方法就可以了，如果有多個小任務，就寫多個方法，下面發布任務的時候會有區別 每個方法會傳入兩個參數`think\queue\Job $job`（當前的任務對象） 和`$data`（發布任務時自定義的數據） 還有個可選的任務失敗執行的方法`failed`傳入的參數為`$data`（發布任務時自定義的數據） 案例： ~~~ namespace app\job; use think\queue\Job; class Job1{ public function fire(Job $job, $data){ //....這里執行具體的任務 if ($job->attempts() > 3) { //通過這個方法可以檢查這個任務已經重試了幾次了 } //如果任務執行成功后 記得刪除任務，不然這個任務會重復執行，直到達到最大重試次數后失敗后，執行failed方法 $job->delete(); // 也可以重新發布這個任務 $job->release($delay); //$delay為延遲時間 } public function failed($data){ // ...任務達到最大重試次數后，失敗了 } } ~~~ ~~~ namespace app\lib\job; use think\queue\Job; class Job2{ public function task1(Job $job, $data){ } public function task2(Job $job, $data){ } public function failed($data){ } } ~~~ ~~~ $jobPushAll = "\app\job\PushAll"; Queue::push($jobPushAll, [ 'article' => '', 'admin_id' => 0, 'push_content' => $param, 'push_app' => $device_type, 'mobile_arr' => json_encode($mobileArr), 'push_active' => 1 //后臺活動推送 ], 'push_all_active_job_queue'); ~~~ ## 監聽任務并執行 ~~~ &> php think queue:listen &> php think queue:work ~~~ ### supervisor使用: ~~~ think queue:listen --queue push_all_active_job_queue ~~~