Laravel 5.1 失败的排队作业在 failed() 方法上失败，防止调用队列失败事件处理程序

Question

我正在 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

我已尝试在文档中概述的 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 这里有错误还是我遗漏了什么？

更新：

我做了更多的研究。当队列作业发生故障时，处理该故障的逻辑在 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() 可以防止此事件发生。

更新：

问题似乎源于我如何让它失败。如果我故意破坏作业队列表中的数据，则永远不会调用 failed() 方法。日志中有堆栈跟踪：

Stack trace:
#0 [internal function]: Illuminate\Foundation\Bootstrap\HandleExceptions->handleError(8, 'unserialize():

如果我真的进入 vendor/laravel/framework/src/Illuminate/Queue/Worker.php 并在每次运行时强制它失败（当然是以无异常的方式），那么 failure() 会被调用。显然，问题是我怎么知道这个队列在现实世界的故障中会如何表现？如果损坏的 db 数据导致失败，但又阻止了 failure() 被调用，那就不好了。如果现实世界中的数据库队列数据实际损坏怎么办？

Answer 1

从我在https://github.com/laravel/framework/issues/9799 与 Graham 的对话中尝试一下

最后，我能找到的最优雅的解决方案是在作业类本身上触发 failed() 方法是添加到下面的 EventServiceProvider.php 的 boot() 方法中。捕获触发的完整失败事件，然后挖掘命令/作业并将其反序列化以调用 failed() 方法。

Queue::failing(function($connection, $job, $data)
        {
            $command = (unserialize($data['data']['command']));
            $command->failed();
        });

Answer 2

如果你像这样启动队列监听器

nohup php artisan queue:listen > storage/logs/queue.log 2>&1 &

然后会自动创建并填充队列日志文件。