laravel 隊列如何使用-Laravel-PHP中文網

laravel 隊列如何使用

WBOY

發布： 2023-05-26 18:38:07

原創

2499 人瀏覽過

隨著網路產業的不斷發展，我們的網站越來越複雜，訪問量也越來越大。在高同時的情況下，處理大量的耗時任務是一項非常棘手的任務，會導致我們的業務出現卡頓、堵塞的情況。為了解決這個問題，Laravel提供了佇列功能，可用來處理一些非同步可延遲的任務，讓使用者不會感覺到停留。接下來，我們就來了解laravel隊列如何使用。

一、安裝佇列

1.安裝佇列套件

在Laravel中，佇列被放置在Laravel佇列工作包中，我們可以使用Composer來安裝該套件：

composer require illuminate/queue

2.新增佇列提供者

Laravel支援多個佇列後端，包括資料庫、Redis、Beanstalkd等。我們需要在config/queue.php中設定佇列提供者。例如，我們可以使用Redis佇列提供者：

'connections' => [

'redis' => [
    'driver' => 'redis',
    'connection' => 'default',
    'queue' => 'default',
    'retry_after' => 90,
    'block_for' => null,
],

登入後複製

二、建立任務

##佇列被設計用來處理長時間運行的任務，這可以是任何任務或命令。我們可以使用命令列來產生一個新的佇列任務：

php artisan make:job SendEmail

產生的佇列任務類別被放置在app/Jobs目錄下，手動產生的SendEmail任務類別是基礎類，看起來像這樣：

namespace AppJobs;

use IlluminateBusQueueable;

use IlluminateContractsQueueShouldQueue;
#useuminateFoundationBusDispableable) ;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;

class SendEmail implements ShouldQueue

{

use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

/**
 * Create a new job instance.
 *
 * @return void
 */
public function __construct()
{
    //
}

/**
 * Execute the job.
 *
 * @return void
 */
public function handle()
{
    //
}

登入後複製

}

我們可以在handle()方法中編寫任務的具體實作邏輯。

三、推送任務到佇列

在Laravel中，我們可以使用$dispatch()靜態方法將任務加入佇列。我們可以在控制器、路由或其他任何地方使用此方法，如下所示：

use AppJobsSendEmail;

SendEmail::dispatch();

我們也可以使用佇列的delay()和onQueue()方法指定延遲和佇列名稱。

例如，將任務推送到名為"emails"的隊列，並在10秒後處理：

SendEmail::dispatch()->onQueue('emails')-> ;delay(now()->addSeconds(10));

四、運行佇列

我們已經將任務推送到佇列中，現在需要執行佇列並處理任務。在Laravel中，我們可以使用Artisan指令來啟動佇列處理器：