Laravel 8 隊列系統的新功能和變化

Laravel 8 附帶了很酷的新特性，並對隊列系統的一些更改。在本文中，咱們將研究這些特性和更改。php

變化

Backoff (回退)

已將 retryAfter() 方法和 retryAfter 排隊做業，郵件，通知和偵聽器的屬性重命名爲backoff。web

php artisan queue：work 命令的 --delay 選項也已重命名爲 --backoff。數據庫

您還應該知道，如今能夠將數組傳遞給 backoff 屬性，以指示 worker 實現指數回退 (exponential backoff)：數組

public $backoff = [30, 60];

或者從 backoff() 方法返回一個數組：微信

public function backoff()
{
    return [30, 60]; 
}

在這裏使用指數回退，咱們指示 worker 在第一次失敗後延遲 30 秒重試做業，而後在每次失敗後延遲 60 秒。閉包

您還能夠在 queue:work 命令上使用指數回退：工具

php artisan queue:Work --backoff=30,60

做業過時

排隊做業，通知和偵聽器的 timeoutAt 屬性已重命名爲 retryUntil。編碼

使用 $retryUntil 指示 worker 繼續重試做業，直到未來的某個時間爲止。spa

您能夠將 retryUntil 做爲做業類的公共屬性或 retryUntil 方法添加：.net

public function retryUntil()
{
    return now()->addDay();
}

新特性

隊列閉包

您如今能夠在調度隊列閉包時鏈式調用 catch() 方法：

dispatch(function () {
    // Job logic...
})->catch(function (Throwable $e) {
    // Handle Failure...
});

若是做業失敗，將調用提供給 catch() 方法的閉包。

數據庫驅動程序可靠性

當使用數據庫隊列驅動程序將做業釋放回隊列時，Laravel 如今將在事務內執行操做。這意味着除非添加了新的已發佈實例，不然不會從隊列中刪除做業。這大大減小了做業失敗的機會。

Redis 驅動程序效率

當使用 Redis 隊列驅動程序批量分發一組做業時， Laravel 將經過向 Redis 發送單個命令來執行操做。之前， Laravel曾經向 Redis 發送多個 rpush 命令，每一個做業一個。

Worker 優雅終止

從 Laravel 8 開始， Workers 將優雅退出，並調用由 App：：Terminating() 註冊的任何終止回調。

Worker 自我終止

爲了不內存泄漏，一般的作法是不時終止您的工做程序，而後讓您的過程監視工具啓動新的工做程序。一般是經過添加一個運行 queue:restart 令的CRON做業來完成的。

在 Laravel 8中，您能夠指示 Workers 在處理了必定數量的做業或運行了特定的秒數後退出：

php artisan queue:work --max-jobs=1000 --max-time=3600

命名 Workers

你如今添加 --name 選項到 queue:work 命令:

php artisan queue:work --name=notifications

添加此功能的主要目的是容許人們自定義 Workers 在運行時如何選擇哪一個隊列來處理任務：

Worker::popUsing('notifications', function ($pop) {
    $queues = time()->atNight() 
        ? ['mail', 'webhooks'] 
        : ['push-notifications', 'sms', 'mail', 'webhooks'];

    foreach ($queues as $queue) {
        if (! is_null($job = $pop($queue))) {
            return $job;
        }
    }
});

任務批處理

Laravel 的任務批處理使您能夠分派許多任務，以供您的 Workers 並行處理。您能夠在批處理中的全部任務都處理完畢或任何批處理任務失敗後執行操做：

Bus::batch([
    new ProcessFile(1),
    new ProcessFile(2),
    new ProcessFile(3),
])->dispatch();

您能夠在官方文檔中找到有關「做業批處理」的更多信息。

做業鏈

您如今可使用 Bus 直接調度一系列做業：

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->dispatch();

您還能夠添加一個 catch() 回調，若是鏈中的任何做業失敗都會被調用：

Bus::chain([
    new ExtractReports,
    new GenerateReport,
    new SendResults,
])->catch(function(){
    // Handle the chain failure.
})
->dispatch();

Horizon 平衡率

Horizon 中添加了兩個新的配置選項： balanceMaxShift and balanceCooldown。

'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceMaxShift' => 5,
        ],
    ],
],

balanceMaxShift 設置每次 Horizon 擴展工做程序池時要添加或刪除的最大工做進程數。在 Horizon 的早期版本中，僅添加或刪除了一個工做進程，如今您能夠控制該數目。

至於 balanceCooldown ，它設置每一個縮放操做之間等待的秒數。在 Horizon 的早期版本中，這被硬編碼爲3秒。

'environments' => [
    'environment' => [
        'supervisor-1' => [
            'balanceCooldown' => 1,
        ],
    ],
],

本文分享自微信公衆號 - PHP開源Hub（php_open）。
若有侵權，請聯繫 support@oschina.cn 刪除。
本文參與「OSC源創計劃」，歡迎正在閱讀的你也加入，一塊兒分享。