我正在测试 Laravel 5.1 中的队列功能。我可以让作业在我的数据库表中排队,称为作业,并且可以让它们成功运行。我还创建了一个名为 failed_jobs 的队列失败表。为了测试它,在作业表中,我操作有效负载数据以使其失败,然后像这样运行队列工作守护进程,因此在一次失败的尝试后,它会将作业放入 failed_jobs 表中:
php artisan queue:work --daemon --tries=1 --queue=myqueue
当作业失败时,它会立即按预期放入 failed_jobs 表中。
仅供参考,我已经按照 Laravel 5.1 文档的建议进行了设置:
http://laravel.com/docs/5.1/queues#dealing-with-failed-jobs http://laravel.com/docs/5.1/queues#dealing-with-failed-jobs
我已尝试在 AppServiceProvider 的 boot() 方法中注册队列失败事件,如文档中所述:
Queue::failing(function ($connection, $job, $data) {
Log::error('Job failed!');
});
我还在实际作业脚本中尝试了 failed() 方法,如下所示:
/**
* Handle a job failure.
*
* @return void
*/
public function failed()
{
Log::error('failed!');
}
无论哪种方式,当排队作业失败时都不会触发这些事件。除了我故意发生的异常堆栈跟踪之外,我在日志中看不到任何内容。 Laravel 5.1 是否有错误,或者我遗漏了什么?
UPDATE:
我还做了一些研究。当队列作业发生失败时,处理该失败的逻辑位于vendor/laravel/framework/src/Illuminate/Queue/Worker.php:
protected function logFailedJob($connection, Job $job)
{
if ($this->failer) {
$this->failer->log($connection, $job->getQueue(), $job->getRawBody());
$job->delete();
$job->failed();
$this->raiseFailedJobEvent($connection, $job);
}
return ['job' => $job, 'failed' => true];
}
发生的情况是 failed() 函数永远不会执行,并且它会阻止调用下一个函数 raiseFailedJobEvent()。就好像当调用 failed() 时脚本会默默地停止。现在,如果我颠倒这些行的顺序,我可以触发 raiseFailedJobEvent(),如果我在 EventServiceProvider.php 或 AppServiceProvider.php 中注册队列事件处理程序,我可以验证它是否被触发并且我可以成功处理该事件。不幸的是,在 raiseFailedJobEvent() 之前使用 failed() 会阻止此事件发生。
UPDATE:
问题似乎源于我如何让它失败。如果我故意损坏作业队列表中的数据,则 failed() 方法永远不会被调用。日志中有堆栈跟踪:
Stack trace:
#0 [internal function]: Illuminate\Foundation\Bootstrap\HandleExceptions->handleError(8, 'unserialize():
如果我实际上进入vendor/laravel/framework/src/Illuminate/Queue/Worker.php并强制它在每次运行时失败(当然以无异常的方式),那么 failure() 就会被调用。显然,问题是我如何知道这个队列在现实世界的故障中将如何表现?如果损坏的数据库数据导致失败但又阻止了 failure() 的调用,那么这是不好的。如果现实世界中数据库队列数据实际损坏怎么办?