佇列優先權

有時你可能會想決定佇列執行的優先權。例如在config/queue.php 中你可以將redis 連接的queue 佇列的優先權從default 設定為 low。然而， 偶爾你也想像如下方式將一個任務推送到high 隊列：

dispatch((new Job)->onQueue('high'));

要運行一個處理器來確認low 隊列中的任務在全部的high 佇列任務完成後才繼續執行，你可以傳遞一個逗號分隔的佇列名稱清單作為work 指令的參數。

php artisan queue:work --queue=high,low

佇列處理器& 部署

因為佇列處理器是常駐進程，他們在重新啟動前不會應用你程式碼的變更。因此，部署使用佇列處理器的應用最簡單的方法是在部署進程中重新啟動佇列處理器。你可以平滑地重啟所有佇列處理器透過使用queue:restart 方法：

php artisan queue:restart

這個指令將會引導所有的佇列處理器在完成目前任務後平滑「中止」，這樣不會有遺失的任務。由於在執行 queue:restart 後佇列處理器將會中止，所以你應該執行一個行程管理器例如 Supervisor 來自動重啟佇列處理器。

{tip} 佇列使用 快取 儲存重新啟動訊號，所以你應該確定在使用這個功能之前配置好快取驅動。

任務過期& 逾時

任務過期

在你的config/queue.php 設定檔中，每個佇列連線都定義了一個retry_after 選項。這個選項指定了隊列連線在重試一個任務前應該等它執行多久。例如，如果 retry_after 的值設定為 90 ，那麼任務在執行了 90 秒後將會放回佇列而不是刪除它。一般情況下，你應該將 retry_after 的值設定為你認為你的任務可能會執行需要最長時間的值。

{note} 只有在 Amazon SQS 中不存在 retry_after 這個值。 SQS 將會以 AWS 控制台配置的 預設可見逾時值 作為重試任務的依據。

處理器逾時

queue:work Artisan 指令包含一個 --timeout 選項。 --timeout 選項指定了 Laravel 的佇列主程序在中止一個執行任務的子程序之前需要等到多久。有時一個子程序可能會因為各種原因而「凍結」，例如一個外部的 HTTP 請求失去回應。 --timeout 選項會移除那些超過指定時間被凍結的進程。

php artisan queue:work --timeout=60

retry_after 設定項和--timeout 命令列配置並不同，但將它們同時使用可以確保任務不會遺失且任務只會成功執行一次。

{note} --timeout 的值應該比你在 retry_after 中配置的值至少短幾秒鐘。這會確保處理器永遠會在一個任務被重試之前中止。如果你的 --timeout 值比 retry_after 的值長的話，你的任務可能會被執行兩次。

佇列進程睡眠時間

當任務在佇列中可用時，處理器將會一直無間隔地處理任務。然而， sleep 選項定義瞭如果沒有新任務的​​時候處理器將會「睡眠」多久。在處理器睡眠時，它不會處理任何新任務 —— 任務將會在佇列處理器再次啟動後執行。

php artisan queue:work --sleep=3

Supervisor 設定

安裝Supervisor

Supervisor 是Linux作業系統下中的一個行程監控器，它可以在queue:work 掛掉時自動重啟之。在Ubuntu 上安裝Supervisor，你可以使用以下指令：

sudo apt-get install supervisor

{小提醒} 如果覺得設定Supervisor 難於登天，可以考慮使用Laravel Forge，它將自動為你的Laravel 專案安裝和設定Supervisor。

設定 Supervisor

Supervisor 的設定檔通常位於 /etc/supervisor/conf.d 目錄下。在該目錄中，你可以建立任意數量的配置文件，用來控制 supervisor 將如何監控你的進程。例如，建立一個laravel-worker.conf 檔案使之啟動和監控一個queue:work 進程：

[program:laravel-worker]
process_name=%(program_name)s_%(process_num)02d
command=php /home/forge/app.com/artisan queue:work sqs --sleep=3 --tries=3
autostart=true
autorestart=true
user=forge
numprocs=8
redirect_stderr=true
stdout_logfile=/home/forge/app.com/worker.log

在這個範例中，numprocs 指令將指定Supervisor 運行8 個queue:work 進程並對其進行監控，如果它們掛掉就自動重新啟動它們。你應該更改 command 選項中的 queue：work sqs 部分以表示你所需的佇列連線。

啟動Supervisor

設定檔創建完畢後，你就可以使用如下命令更新Supervisor 配置並啟動進程了：

sudo supervisorctl reread

sudo supervisorctl update

sudo supervisorctl start laravel-worker:*

獲取關於Supervisor 的更多信息，可以查閱Supervisor 文件.

#處理失敗的任務

有時你的佇列化任務會執行失敗。放平心態，好事多磨。 Laravel 包含了一個方便的方法來指定任務應該嘗試的最大次數。如果一個任務已經到達了最大嘗試次數，它就會被插入到 failed_jobs 資料庫表中。要建立failed_jobs 資料庫遷移表，你可以使用queue:failed-table 指令：

php artisan queue:failed-table

php artisan migrate

然後，當你執行queue worker，你應該使用queue：work 指令中的--tries 開關指定應嘗試執行任務的最大次數。如果沒有為--tries 選項指定值，則將死循環嘗試執行任務：

php artisan queue:work redis --tries=3

failed 方法，讓你在任務失敗時執行針對於該任務的清理工作。這是向用戶發送警報或恢復任務執行的任何操作的絕佳位置。導致任務失敗的Exception 將會傳遞給failed 方法：

<?php
    namespace App\Jobs;
    use Exception;use App\Podcast;
    use App\AudioProcessor;
    use Illuminate\Bus\Queueable;
    use Illuminate\Queue\SerializesModels;
    use Illuminate\Queue\InteractsWithQueue;
    use Illuminate\Contracts\Queue\ShouldQueue;
    class ProcessPodcast implements ShouldQueue{ 
       use InteractsWithQueue, Queueable, SerializesModels;    
       protected $podcast;   
     /**
     * 创建任务实例
     *
     * @param  Podcast  $podcast
     * @return void
     */   
     public function __construct(Podcast $podcast)  
       {       
        $this->podcast = $podcast;  
        }   
    /**
     * 执行任务
     *
     * @param  AudioProcessor  $processor
     * @return void
     */  
     public function handle(AudioProcessor $processor) 
        {     
           // 上传播客……   
         }  
    /**
     * 任务失败的处理过程
     *
     * @param  Exception  $exception
     * @return void
     */   
     public function failed(Exception $exception) 
        {     
          // 给用户发送任务失败的通知，等等……   
         }
      }

如果你想在任務失敗時註冊一個可呼叫的事件，你可以使用

方法。該事件是透過 email 或 Slack 通知你團隊的絕佳時機。例如，我們可以在Laravel 中的AppServiceProvider 中附加一個回呼事件：

<?php
    namespace App\Providers;
    use Illuminate\Support\Facades\Queue;
    use Illuminate\Queue\Events\JobFailed;
    use Illuminate\Support\ServiceProvider;
    class AppServiceProvider extends ServiceProvider{   
     /**
     * 启动任意服务。
     *
     * @return void
     */    
    public function boot()   
     {       
      Queue::failing(function (JobFailed $event) {     
             // $event->connectionName            
             // $event->job            
             // $event->exception        
           }); 
       }    
    /**
     * 注册服务提供者。
     *
     * @return void
     */    
    public function register()    { 
           //   
           }
    }

要想查看所有被放入

資料表中的任務，你可以使用Artisan 指令queue:failed ：

php artisan queue:failed

指令會列出任務ID ，佇列，以及失敗的時間。任務 ID 可能會被用於重試失敗的任務。例如，要重試一個任務ID 為5 的任務，使用以下指令：

php artisan queue:retry 5

指令，將all 作為ID 傳入：

php artisan queue:retry all

指令：

php artisan queue:forget 5

指令：

php artisan queue:flush

忽略缺少的模型

在向任務中註入 Eloquent 模型時，模型被放入佇列前將被自動序列化並在執行任務時還原。但是，如果在任務等待執行時刪除了模型，任務可能會失敗並拋出 ModelNotFoundException 。

為了方便，你可以選擇設定任務的 deleteWhenMissingModels 屬性為 true 來自動地刪除缺失模型的任務。

/**
 * 如果模型缺失即删除任务。
 *
 * @var bool
 */
 public $deleteWhenMissingModels = true;

任務事件

透過在Queue facade 中使用before 和after 方法，你可以指定一個佇列任務被執行前後的回呼。這些回調是添加額外的日誌或增加統計的絕佳時機。通常，你應該在 服務提供者中呼叫這些方法。例如，我們可以使用Laravel 的AppServiceProvider ：

<?php
    namespace App\Providers;
    use Illuminate\Support\Facades\Queue;
    use Illuminate\Support\ServiceProvider;
    use Illuminate\Queue\Events\JobProcessed;
    use Illuminate\Queue\Events\JobProcessing;
    class AppServiceProvider extends ServiceProvider{    
     /**
     * 引导启动任意应用服务。
     *
     * @return void
     */    
    public function boot()   
     {       
        Queue::before(function (JobProcessing $event) {   
                // $event->connectionName            
                // $event->job            
                // $event->job->payload()      
              });      
        Queue::after(function (JobProcessed $event) {      
              // $event->connectionName            
              // $event->job            
              // $event->job->payload()       
            });    }   
    /**
     * 注册服务提供者。
     *
     * @return void
     */   
    public function register()   
   {      
    //  
     }
  }

在Queue facade 使用looping 方法可以在處理器嘗試取得任務之前執行回調。例如，你也許想用一個閉包來回滾之前失敗的任務尚未關閉的事務：

Queue::looping(function () { 
   while (DB::transactionLevel() > 0) { 
          DB::rollBack();   
       }
    });