Laravel 8 队列系统的新功能和变化

2022-05-15 0 657

下面由Laravel教程栏目给大家介绍Laravel 8 队列系统的新功能和变化,希望对需要的朋友有所帮助!

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

收藏 (0) 打赏

感谢您的支持,我会继续努力的!

打开微信/支付宝扫一扫,即可进行扫码打赏哦,分享从这里开始,精彩与您同在
点赞 (0)

【声明:根据2013年1月30日《计算机软件保护条例》2次修订第17条规定: 为了学习和研究软件内含的设计思想和原理,通过安装、显示、传输或者存 储软件等方式使用软件的,可以不经软件著作权人许可,不向其支付报酬! 鉴于此,也希望大家按此说明研究软件!】
本站所有源码尽量保证原汁原味,如有特殊情况会作出声明及标注,网站资源不做任何二次加密(原版加密除外,不影响程序使用的不会做解密处理),方便您更好的学习参考。 在您的能力范围内,为了大环境的良性发展,请尽可能的选择正版资源。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。

即刻码站__国内靠谱的站长资源下载平台 php教程 Laravel 8 队列系统的新功能和变化 https://www.jike1995.com/36380.html

常见问题
  • 本站所有资源版权均属于原作者所有,这里所提供资源均只能用于参考学习用,请勿直接商用。若由于商用引起版权纠纷,一切责任均由使用
查看详情
  • 最常见的情况是下载不完整: 可对比下载完压缩包的与网盘上的容量,若小于网盘提示的容量则是这个原因。这是浏览器下载的bug,建议用百度
查看详情

相关文章

发表评论
暂无评论
官方客服团队

为您解决烦忧 - 24小时在线 专业服务