> 自定義日志通道 修改驅動類型為 redis ~~~ 'default' => 'redis', ~~~ ~~~ // 其它日志通道配置 'queue' => [ // 日志記錄方式 'type' => 'File', // 日志保存目錄 'path' => base_path() . '/queue/log', // 單文件日志寫入 默認值 false 'single' => date('Ymd'), // 獨立日志級別 'apart_level' => ['success', 'error', 'failed'], // 最大日志文件數量 'max_files' => 0, // 使用JSON格式記錄 'json' => false, // 日志處理 'processor' => null, // 關閉通道日志寫入 'close' => false, // 自定義時間顯示格式 'time_format' => 'Y-m-d H:i:s', // 日志輸出格式化 'format' => '[%s][%s] %s', // 是否實時寫入 'realtime_write' => false, ], ~~~ > 帶有日志的任務類 app\\queue\\Task.php ~~~ <?php namespace app\queue; use think\queue\Job; use think\facade\Log; class Task { /** * 隊列任務 * @param Job $job * @param [type] $data 自定義數據 */ public function fire(Job $job, $data) { //....這里執行具體的任務 try { $this->json($data); $log = [ 'data' => $data, 'attempts' => $job->attempts(), ]; ######## 執行任務邏輯 ######## $rand = mt_rand(1, 10); $log['rand'] = $rand; $result = $rand > 5; if ( $result ) throw new \Exception('執行任務發生錯誤'); ######## 執行任務邏輯 / ######## $log['message'] = '任務執行成功'; Log::channel('queue')->success($log); $job->delete(); } catch (\Throwable $th) { $log['errMsg'] = $th->getMessage(); Log::channel('queue')->error($log); // $job->attempts() 當前任務執行次數 if ( $job->attempts() > 2 ) { // 如果任務執行成功后 記得刪除任務， // 不然這個任務會重復執行，直到達到最大重試次數后失敗后，執行failed方法 $job->delete(); } else { // 重新發布任務 $delay = 1; $job->release($delay);//$delay為延遲時間 } } } /** * 任務執行失敗時觸發 */ public function failed($data) { // 任務達到最大重試次數后，失敗了 $data['message'] = '任務執行失敗'; Log::channel('queue')->failed($data); } /** * 執行任務時輸出自定義數據 */ public function json($data) { echo json_encode($data, JSON_UNESCAPED_UNICODE) . PHP_EOL; } } ~~~