删除Laravel队列中的延迟

Question

我是Laravel-Lumen框架的粉丝。这些设计非常好，我们可以开始实现这些应用程序了。但是有一个小问题。也许这不是问题，但在我看来这是个小问题。让我解释一下。

例如，我有一个模型，我正在使用弹性搜索。当创建了一个模型(插入到数据库(时，我正在调度一个为该模型编制索引的作业。

public static function boot()
{
parent::boot();
static::created(function ($model) {
$modelClass = get_class($model);
lgi('>>> model created:' . $modelClass, $model);
dispatch(new ElasticIndexerJob('creted', $model));
});
static::updated(function ($model) {
$modelClass = get_class($model);
lgi('>>> model updated:' . $modelClass, $model);
dispatch(new ElasticIndexerJob('updated', $model));
});
static::deleted(function ($model) {
$modelClass = get_class($model);
lgi('>>> model deleted:' . $modelClass, $model);
dispatch(new ElasticIndexerJob('deleted', $model));
});
}

这会输出日志：

[2021-04-18 11:28:36] local.INFO: /app/Models/Traits/Indexable.php:25 [
">>> model updated:App\Models\City",
{
"id": 3,
"country_id": 85,
"state_id": 1,
"zip_code": "87506",
"name": "Nambe",
"lat": 35.8890389,
"lng": -106.0657318,
"status": "passive",
"created_at": "2021-04-13 09:38:09",
"updated_at": "2021-04-18 11:28:36"
}
]

时间为11:28:36。之后，我将对日志输出进行排队。

[2021-04-18 11:28:38][27] Processing: AppJobsElasticIndexerJob
[2021-04-18 11:28:38] local.INFO: /app/Jobs/ElasticIndexerJob.php:32 [
"App\Models\City",
"updated",
{
"id": 3,
"country_id": 85,
"state_id": 1,
"zip_code": "87506",
"name": "Nambe",
"lat": 35.8890389,
"lng": -106.0657318,
"status": "passive",
"created_at": "2021-04-13 09:38:09",
"updated_at": "2021-04-18 11:28:36"
}
]  
[2021-04-18 11:28:38][27] Processed:  AppJobsElasticIndexerJob

队列输出时间为11:28:38。如您所见，存在2 seconds延迟(或差异(。这个问题出现在所有队列中(发送邮件、执行其他作业等(。当发送邮件时，这不是问题，但有时我需要实时执行。我想在调度时立即执行作业。

通常，如果我自己使用beanstalkd，那么我可以立即收到消息(作业(，我可以用这些消息做一些事情。但在Laravel(或Lumen(有一个延迟，这让我很恼火

为什么Laravel有延迟，我该如何消除这种延迟？

我在数据库队列和beanstalkd队列中测试了这一点。出现相同行为：

QUEUE_CONNECTION=beanstalkd
; QUEUE_CONNECTION=database

注：lgi()函数是Log::info()的一个包络

Answer 1

你试过dispatchSync吗，我不知道它在Lumen上是否可用。Laravel dispatchSync

Answer 2

我找到了解决方案。我查看了Laravel的源代码，在这个文件中看到了代码：IlluminateQueueListener

/**
* The amount of seconds to wait before polling the queue.
*
* @var int
*/
protected $sleep = 3;

我更深入地调查了一下，发现：

/**
* Create the command with the listener options.
*
* @param  string  $connection
* @param  string  $queue
* @param  IlluminateQueueListenerOptions  $options
* @return array
*/
protected function createCommand($connection, $queue, ListenerOptions $options)
{
return array_filter([
$this->phpBinary(),
$this->artisanBinary(),
'queue:work',
$connection,
'--once',
"--name={$options->name}",
"--queue={$queue}",
"--backoff={$options->backoff}",
"--memory={$options->memory}",
"--sleep={$options->sleep}",
"--tries={$options->maxTries}",
], function ($value) {
return ! is_null($value);
});
}

正如您所看到的，有一个CLI参数--sleep=[second]。我们可以将该值设置为零(0(。之后，队列工作人员不等待处理下一个作业。

php artisan queue:work --sleep=0.1

我认为这些参数必须在文档中，但Laravel开发人员没有添加这些参数。也许是我错过了这个我不知道。

编辑：如果您使用数据库作为队列后端，则此用法可以加载您的数据库。Beouse数据库驱动程序正在向jobs表发送SELECT查询。我建议使用这种用法的beanstalkd驱动程序。

编辑2：如果将--sleep设置为0(零(，则它可能会占用cpu。

编辑3：我现在看到这个了。也许我必须去看眼科医生：Shttps://laravel.com/docs/8.x/queues#worker-睡眠持续时间