Laravel開發(fā)：如何使用Laravel Queues處理非同步任務(wù)？

Laravel是一種流行的PHP框架，其強(qiáng)大的功能使其成為Web應(yīng)用程式開發(fā)的最佳選擇。使用Laravel，您可以快速輕鬆地建立複雜的網(wǎng)路應(yīng)用程式。在本文中，我們將討論Laravel Queues的使用，這是一個(gè)有助於處理非同步任務(wù)的功能。

非同步任務(wù)的概念

當(dāng)使用者在網(wǎng)路應(yīng)用程式中執(zhí)行某個(gè)任務(wù)時(shí)，需要等待任務(wù)完成後才能獲得結(jié)果。這就是同步任務(wù)。但是，如果我們想要在使用者不需要等待任務(wù)完成的情況下進(jìn)行處理，該怎麼辦呢？這就是異步任務(wù)！

非同步任務(wù)不會(huì)影響使用者的即時(shí)回應(yīng)效能，因?yàn)樗鼈儾坏却蝿?wù)完成才傳回結(jié)果。相反，這些任務(wù)被放入隊(duì)列中，並在後臺(tái)逐一處理。例如，用戶向伺服器上傳文件。如果因?yàn)闄n案太大而導(dǎo)致上傳時(shí)間過長，使用者可能會(huì)變得不耐煩並取消上傳。此時(shí)，使用非同步任務(wù)將有助於避免使用者流失。

Laravel Queues是Laravel框架的一部分，它有助於處理非同步任務(wù)。

建立Laravel Queues

在Laravel使用佇列的第一步是讓電腦知道該處理哪個(gè)佇列。在Queue.php檔案中，您可以定義佇列並指定佇列使用哪種驅(qū)動(dòng)程式。驅(qū)動(dòng)程式可以是本機(jī)驅(qū)動(dòng)程式、資料庫驅(qū)動(dòng)程式、Redis驅(qū)動(dòng)程式、Beanstalk驅(qū)動(dòng)程式等。以下是一個(gè)範(fàn)例：

'connection' => env('QUEUE_DRIVER', 'sync'),

'driver' => env('QUEUE_DRIVER', 'sync'),

'queue' => [

    'default' => [

        'connection' => 'default',

        'queue' => 'default',

        'retry_after' => 90,

        'backoff' => [

            'strategy' => 'exponential',

            'max_attempts' => 3,

            'delay' => 1000,

        ],

    ],

],

上面的程式碼範(fàn)例表明，佇列預(yù)設(shè)使用'sync'驅(qū)動(dòng)程式。但是，您可以在.env檔案中定義不同的驅(qū)動(dòng)程式。

新增佇列

現(xiàn)在，我們已經(jīng)定義了佇列和它的驅(qū)動(dòng)程序，需要將任務(wù)新增到佇列中以進(jìn)行處理。在Laravel框架中，使用dispatch()方法將任務(wù)加入佇列。例如，我們使用下面的程式碼將任務(wù)新增至佇列：

ProcessPodcasts::dispatch($podcast);

上述程式碼中，ProcessPodcasts是我們要執(zhí)行的任務(wù)，$ podcast是傳遞給任務(wù)的參數(shù)。

建立任務(wù)

現(xiàn)在，讓我們使用Laravel建立一個(gè)非同步任務(wù)。為此，我們將在app/Jobs目錄中建立一個(gè)新的Job.php檔案。以下是範(fàn)例程式碼：

<?php

namespace AppJobs;

use AppMailSendWelcomeEmail;
use AppUser;
use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;
use IlluminateSupportFacadesMail;

class SendWelcomeEmailJob implements ShouldQueue
{
    // Traits used by the class
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $user;

    /**
     * Create a new job instance.
     *
     * @param User $user
     */
    public function __construct(User $user)
    {
        $this->user = $user;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        Mail::to($this->user->email)->send(new SendWelcomeEmail($this->user));
    }
}

上面的程式碼建立了一個(gè)名為SendWelcomeEmailJob的非同步任務(wù)。該任務(wù)向新用戶發(fā)送郵件。由於該任務(wù)在佇列中，因此使用者不必等待電子郵件的發(fā)送完成。

執(zhí)行佇列

透過上述操作，我們已經(jīng)建立了一個(gè)任務(wù)並將其新增至佇列。但是，我們需要執(zhí)行佇列中的任務(wù)。有幾種方法可以執(zhí)行佇列，以下是範(fàn)例程式碼：

php artisan queue:work 

在上面的程式碼中，我們使用Laravel CLI中的queue:work指令執(zhí)行佇列。此命令將持續(xù)執(zhí)行直到?jīng)]有任務(wù)可以處理為止。

還有其他方法可以執(zhí)行佇列，例如在supervisor的幫助下執(zhí)行佇列。 supervisor是一個(gè)進(jìn)程管理工具，讓我們可以在背景管理Laravel應(yīng)用程式。若要在supervisor協(xié)助下執(zhí)行佇列，請(qǐng)依照下列步驟操作：

1. 安裝supervisor（請(qǐng)參考supervisor的使用）。
2. 建立一個(gè)新檔案queue-worker.conf位於/etc/supervisor/conf.d目錄中。
3. 輸入以下程式碼：

[program:queue-worker]

process_name=%(program_name)s_%(process_num)02d

command=php /path/to/artisan queue:work 

autostart=true

autorestart=true

user=user

numprocs=1

redirect_stderr=true

stdout_logfile=/path/to/your/logs/queue-worker.log

上述程式碼為supervisor建立了一個(gè)佇列工作程式。當(dāng)supervisor啟動(dòng)時(shí)，此程式將開始處理佇列，並在背景執(zhí)行。

結(jié)論

在本文中，我們學(xué)習(xí)如何使用Laravel Queues進(jìn)行非同步任務(wù)處理。我們了解了Queue的概念，定義了新的佇列和驅(qū)動(dòng)程式。我們還建立了一個(gè)非同步任務(wù)，並了解如何使用Laravel Queues執(zhí)行它。整體而言，Laravel Queues是Laravel開發(fā)中非常有用的元件，它可以幫助我們輕鬆地處理非同步任務(wù)。

以上是Laravel開發(fā)：如何使用Laravel Queues處理非同步任務(wù)？的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！