> 隊列任務類 app\\queue\\Task.php 修改驅動類型為 redis ~~~ 'default' => 'redis', ~~~ ~~~ <?php namespace app\queue; use think\queue\Job; class Task { /** * 隊列任務 * @param Job $job * @param [type] $data 自定義數據 */ public function fire(Job $job, $data) { //....這里執行具體的任務 try { $this->json($data); ######## 執行任務邏輯 ######## $rand = mt_rand(1, 10); $result = $rand > 5; if ( $result === true ) throw new \Exception('執行任務發生錯誤'); ######## 執行任務邏輯 / ######## $job->delete(); } catch (\Throwable $th) { // $job->attempts() 當前任務執行次數 if ( $job->attempts() > 2 ) { // 如果任務執行成功后 記得刪除任務， // 不然這個任務會重復執行，直到達到最大重試次數后失敗后，執行failed方法 $job->delete(); } else { // 重新發布任務 $delay = 1; $job->release($delay);//$delay為延遲時間 } } } /** * 任務執行失敗時觸發 */ public function failed($data) { // 任務達到最大重試次數后，失敗了 } /** * 執行任務時輸出自定義數據 */ public function json($data) { echo json_encode($data, JSON_UNESCAPED_UNICODE) . PHP_EOL; } } ~~~