Laravel開發：如何使用Laravel Queues和Supervisor管理非同步任務？-Laravel-PHP中文網

Laravel開發：如何使用Laravel Queues和Supervisor管理非同步任務？

在現代網路應用程式中，非同步任務已成為日常業務中不可或缺的一部分。非同步任務可以提高應用程式的回應時間，優化使用者體驗並增強應用程式的可擴展性。 Laravel Queues是Laravel框架提供的一個強大工具，用於處理非同步任務和訊息佇列。本文將介紹Laravel Queues的概念和使用方法，並結合Supervisor來管理非同步任務。

什麼是Laravel Queues？

Laravel Queues是一種用來處理非同步任務和訊息佇列的方法。透過Laravel Queues，您可以將耗時的任務放入佇列中，而不會影響Web請求的回應時間。例如，發送電子郵件，處理視訊或生成PDF，這些都是耗時的操作，使用佇列將它們放置到後台處理，可以使應用程式更加有效率和回應。

Laravel Queues透過一些內建的佇列驅動程式來支援多個後端技術，例如Database，Redis，Beanstalkd和Amazon SQS。這使開發人員可以使用他們喜歡的佇列技術來處理非同步任務。

使用Laravel Queues

下面我們將一步步驟介紹如何使用Laravel Queues處理非同步任務。

第一步：設定佇列驅動程式

Laravel設定檔中有一個名為queue.php的文件，您可以使用它來設定Queues和佇列驅動程式。您可以透過以下命令產生queue.php檔案：

php artisan queue:table
php artisan queue:failed-table
php artisan migrate

登入後複製

這將產生遷移檔案和隊列表。執行migrate指令以執行遷移。

在queue.php檔案中，您可以選擇使用多種佇列驅動程式：

#Database驅動程式 - 將任務儲存在資料庫中，可作為入門級隊列系統。
Redis驅動程式 - 使用Redis的內建佇列支援。
Beanstalkd驅動程式 - 使用Beanstalkd訊息佇列服務。
Amazon SQS驅動程式 - 使用Amazon Simple Queue Service（SQS）。

例如，如果您要使用Redis佇列驅動程序，請配置queue.php檔案如下：

'default' => env('QUEUE_CONNECTION', 'redis'),
'connections' => [
    'redis' => [
        'driver' => 'redis',
        'connection' => 'default',
        'queue' => env('REDIS_QUEUE', 'default'),
        'retry_after' => 90,
        'block_for' => null,
    ],
]

登入後複製

第二步：建立一個佇列任務類別

接下來，您需要建立一個佇列任務類，用於處理非同步任務。這個類別應該是一個簡單的PHP類，定義了任務的邏輯。例如，以下程式碼是一個用於發送電子郵件的非同步任務類別：

class SendEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $email;
    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($email)
    {
        $this->email = $email;
    }
    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        Mail::to($this->email)->send(new WelcomeEmail());
    }
}

登入後複製

該類別實作了ShouldQueue接口，這是必需的，用於告訴Laravel將該類別轉換為非同步任務類別。 handle()方法定義了任務的具體邏輯，因此可以在這裡執行您需要非同步處理的任務。

第三個步驟：將任務推入佇列

現在您已經準備好了佇列任務和佇列驅動程序，下一步是將任務放入佇列。使用下列程式碼，在專案的任何位置呼叫一個Eloquent佇列：

use AppJobsSendEmail; 
use IlluminateSupportFacadesQueue;
...
Queue::push(new SendEmail('example@test.com'));

登入後複製

或您可以使用dispatch()方法將任務放入佇列中，如下所示：

SendEmail::dispatch('example@test.com');

登入後複製

第四步：執行佇列任務

一旦您將任務放入佇列中，任務將會被dispatch 到佇列中，等待執行。您可以使用下列程式碼來執行佇列：

php artisan queue:work

登入後複製

執行此命令將會啟動一個監聽器並處理佇列中的任務。

使用Supervisor管理非同步任務

由於佇列任務需要在背景執行，因此需要在伺服器上設定進程守護程序，以確保任務可以持續執行。 Supervisor是一種常用的程序守護程序，可確保後台程序不會異常終止，並在需要時重新啟動它們。

第一步：安裝Supervisor

在Ubuntu系統中，您可以使用下列命令來安裝Supervisor：

sudo apt-get update
sudo apt-get install supervisor

登入後複製

第二步：建立一個Supervisor設定檔

在/etc/supervisor/conf.d目錄中建立一個設定文件，例如myqueue.conf：

nano /etc/supervisor/conf.d/myqueue.conf

登入後複製

將以下內容新增到設定檔中，確保更改路徑，命令和使用者名稱以符合您的程式：

[program:myqueue]
process_name=%(program_name)s_%(process_num)02d
command=/usr/bin/php /path/to/artisan queue:work --sleep=3 --tries=3 --daemon
autostart=true
autorestart=true
user=username
numprocs=1
redirect_stderr=true
stdout_logfile=/path/to/storage/logs/myqueue.log

登入後複製

第三步：重新載入Supervisor

在您變更了Supervisor的設定檔之後，您需要通知Supervisor重新載入設定檔。使用以下命令可以重新載入Supervisor：

sudo supervisorctl reread

sudo supervisorctl update

sudo supervisorctl start all

登入後複製

第四步：查看Supervisor日誌

您可以在Supervisor的日誌檔案中查看非同步任務的輸出和錯誤訊息。例如，您可以查看剛才設定檔中指定的路徑和日誌檔案名稱來查看Supervisor日誌：

tail -f /path/to/storage/logs/myqueue.log

登入後複製

結論

本文介紹如何使用Laravel Queues和Supervisor來管理非同步任務，使用Laravel Queues可以輕鬆將耗時的任務放入佇列中，並使應用程式更有效率且更能回應。使用Supervisor可以確保背景任務可以持續運行，並在需要時自動重新啟動。希望該文章對您的開發有所幫助。

以上是Laravel開發：如何使用Laravel Queues和Supervisor管理非同步任務？的詳細內容。更多資訊請關注PHP中文網其他相關文章！