Laravel的隊列機制怎么用

這篇文章主要介紹了Laravel的隊列機制怎么用，具有一定借鑒價值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

為什么 ?

首先，我們要知道為什么要使用隊列，不使用隊列會怎么樣！優缺點如何

我們可以舉例 幾個簡單場景。

郵件發送

郵件發送一般會面臨哪些問題 ??

• 發送緩慢

• 發送失敗

• 發送頻率過高，被服務商拒絕 又或者 被進入垃圾箱

使用隊列的好處在與哪里

• 提高客戶端響應

  當發送時，我們不要立即處理，而是丟給服務器，且隊列進行管理和調度。 你可以自定義選擇立即發送 或者 根據配置延遲發送

• 提高容錯能力

  在發送過程中，或許我們可能會遇到，目標被拒絕。例如大多數人 會遇到給 admin@qq.comn 發送報錯 502 的場景。 那這種場景，那么這種場景，我們可以理解其為是一個事件，在郵件發送的過程中，我們可以 引發構建出如下幾種事件

  通過此郵件發送，可能會導致多個耗時任務的產生，那我們其實也可以構建出多個 隊列服務 出來。每個隊列管理 自己的事情，很好的 解耦 他們

  通過 Laravel 隊列 可以很好的進行設置 立即發送、延遲發送、重試發送

• 發送失敗

• 郵件記錄入庫

• 代碼異常

• 郵件發送成功回調

• 發送失敗重試

• 發送頻率可控

  使用過批量發送的郵件的 開發者 必然會遇到一個問題，那便是，如果我們直接進行批量發送，即同一時間 進行大量的郵件發送。那么郵件服務商很可能會把我們的郵件給拒絕 或者 郵件進入垃圾箱，被識別為 廣告那么，這里便是用到了 延遲發送，我們可以根據當前隊列服務中，已知的 正在等待 投遞的郵件，合理的配置頻率，或者 切換郵件配置，來達到，頻率可控。

  如設置 一個配置一分鐘之類發送10次，等等方案。 同樣，我們這里可以做到 配置、頻率控制、發送控制 解耦

其他

當然 我們還有很多種情況都會用到

• 服務器端下載 excel

• 服務器端異步多任務處理 大數據

• 錯誤消息處理

如何使用 Laravel 隊列

這里只是列出，大概的使用方向，和如何更好的去使用。代碼可能跑不起起來，主要是理解 邏輯 我們這里 使用的是 Redis 作為驅動

驅動設置為 Redis

> .env
QUEUE_CONNECTION=redis
> 在 config/queue.php 中可以找到

快速創建隊列 和 投遞任務

# 創建 任務
php artisan make:job ProcessPodcast

自動生成 app/Jobs/EmailJob.php

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

    protected $data;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct(array $data)
    {
        $this->data = $data;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        $service = new EmailService();

        // ... 檢查當前可用 Mailer
        // 這里你自定義就好了，這個方法中你可以根據你自己的配置，獲取到當前可用的配置
        $mailer = $service->getMailer();

        // ... 獲取當前要發送的數據
        $data = $this->data;
        
        $service->send($mailer, $data);
    }
}

一些常用操作

這些操作都能從 文檔中找到

調用 發送

# 延遲 2分鐘 發送
# 這里使用的是 Crontab 包 (不過 Laravel 自帶)
EmailJob::dispatch()->delay(now()->addMinutes(2));

# 立即發送 (不會進入到隊列中)
EmailJob::dispatchNow();

這里的隊列默認用的 是 defult 隊列，我們可以修改為指定隊列服務

public function __construct(array $data)
{
    # 使用 emailQueue
    $this->onQueue('emailQueue');
    $this->data = $data;
}

設置失敗情況下重試次數

# 重試 5 次
public $tries = 5;

設置超時時間

/**
* 確定任務應該超時的時間
*
* @return \DateTime
*/
public function retryUntil()
{
    return now()->addMinutes(10);
}

啟動我們的隊列

如果不配置 onQueue 的話，可以不帶 ---queue 參數配置

php artisan queue:work --queue=emailQueue

結合 Events 來解耦

Laravel Event 也是通過 隊列實現的

# 創建 Event
php artisan make:event FailEvent

class FailEvent
{
    use Dispatchable, InteractsWithSockets, SerializesModels;

    protected $data;
    protected $tag;

    /**
     * @param array $data 投遞的數據
     * @param string $tag 要操作的事情
     */
    public function __construct(array $data, string $tag = 'system')
    {
        $this->data = $data;
        $this->tag = $tag;
    }
}

# 創建 listener 
php artisan make:listener FailListener
class FailListener
{
    /**
    * Handle the event.
    * 
    * @param  object  $event
    * @return void
    */
    public function handle(FailEvent $event)
    {
        $this->{$event->tag}($event->data);
    }

    /**
     * 處理系統異常
     * DateTime: 2021/12/3 11:02 上午
     * @param array $data
     */
    public function system(array $data)
    {

    }

    /**
    * 處理郵件異常
    * DateTime: 2021/12/3 11:02 上午
    */
    public function email()
    {
    
    }

}

# app/Providers/EventServiceProvider.php
protected $listen = [
    FailEvent::class => [
        FailListener::class,
    ],
]

# 投遞
event(new FailEvent(['error' = '異常信息'], 'email'));

其他

其實，Laravel 大多數幫我實現了整個流程而已。可以嘗試自己使用 redis 來實現一個可控隊列。熟練是掌握 Redis 相關數據類型即可. 這里簡要列出 Redis 中，在以上模式中會用到的數據類型

• List

  使用 它可以完成 出棧 入棧的 隊列功能

• Hash

  使用他 可以用來存儲，序列化后的 Event 或者 Job  __construct 傳入進去的數據，盡量不要將整個 類 序列化進去

  也可以實現存儲，Mailer 數據

• Sorted Set

  可以 設置時間為 Sorted Set 中的分數，通過分數排序，找到我們最近要執行的隊列任務

當然，Redis 的用法還有很多，滿足自己的需求即可。

世界上沒有完美的解決方案，只有最適合你自己的方案，在工作中遇到問題，盡量要學會舉一反三，合理的運用各種 工具，設計方案去實現。 代碼 只是最終一個縮影而已，最終的要學會理解，每個語言 每個框架，也只是一種方案的實現，融會貫通才無敵 ...

感謝你能夠認真閱讀完這篇文章，希望小編分享的“Laravel的隊列機制怎么用”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關注億速云行業資訊頻道，更多相關知識等著你來學習!