我正在使用Laravel 8和Horizon来异步跟踪付款。作业实现如下所示:
<?php
namespace App\Jobs;
// use ...
class TrackOrderPayment implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
const RETRY_INTERVAL_SECONDS = 60;
public function handle()
{
// Anticipate errors
try {
// implementation ...
} catch (Throwable $exception) {
// Re-queue the job
$this->reQueueJob();
}
}
/**
* Re-queue the job with a delay to try again later
*/
private function reQueueJob(): void
{
$this->delete();
if (this->order->status === Constants::ORDER_STATUS_AWAITING_PAYMENT) {
dispatch(new TrackOrderPayment($this->order))->delay(self::RETRY_INTERVAL_SECONDS);
}
}
}
我将等待15分钟来检测付款,如果没有检测到-一个单独的cron作业更新订单到不同的状态,因此作业将不会在15分钟后回到队列(或15次尝试,因为重新排队之间的延迟设置为60秒)
在我的config/queue.php
中,redis队列连接配置如下:
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'),
'retry_after' => 960,
'block_for' => null,
],
我没有看到任何其他配置在这里或config/horizon.php
关于最大尝试/超时。
我试图弄清楚这一点,为什么有些工作会失败,并出现此错误:
App\Jobs\TrackOrderPayment尝试次数过多或运行时间过长。该作业以前可能已超时。
关于这个主题的所有相关问题都说提高retry_after
,我已经这样做了,它似乎没有帮助。
每次作业运行时,作业的实际“处理”花费< 0.5s,如果未检测到支付,则其返回延迟60秒的队列。
我错过了什么?
1条答案
按热度按时间enxuqcxy1#
下面是来自我的
config/horizon.php
的一段配置,它展示了如何实现超时:上面的内容可能没有写在这里的文档中,但它确实有效。
我一直在自己挖掘源代码以找到这些参数,无论如何,我相信上面的配置与以下命令直接相关,您可以看到所有选项,如下图所示(在类
Laravel\Horizon\SupervisorOptions
中也可见):