Laravel 8 队列系统的新功能和变化
下面由Laravel教程欄目給大家介紹Laravel 8 隊列系統的新功能和變化,希望對需要的朋友有所幫助!
Laravel 8 附帶了很酷的新特性,并對隊列系統的一些更改。在本文中,我們將研究這些特性和更改。
變化
Backoff (回退)
已將 retryAfter() 方法和 retryAfter 排隊作業,郵件,通知和偵聽器的屬性重命名為backoff。
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 繼續重試作業,直到將來的某個時間為止。
您可以將 retryUntil 作為作業類的公共屬性或 retryUntil 方法添加:
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,
],
],
],
原文地址:https://dev.to/themsaid/features-and-changes-coming-to-laravel-8-s-queue-system-5amg
譯文地址:https://learnku.com/laravel/t/50086
總結
以上是生活随笔為你收集整理的Laravel 8 队列系统的新功能和变化的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 网上商城有哪些 关于网上商城的基本类型介
- 下一篇: php 时间如何增加1天