Laravel判断队列是否启动、Laravel队列失败了如何处理

在使用Laravel框架时，队列服务是处理异步任务的重要工具。本文将介绍如何判断Laravel队列是否启动，并提供几种处理队列失败的方法。

解决方案概述

1. 判断队列是否启动：通过检查队列工作进程的状态来判断队列是否启动。
2. 处理队列失败：配置队列失败处理器，记录失败日志，重试失败任务，或发送通知。

判断队列是否启动

使用命令行检查

最直接的方法是通过命令行检查队列工作进程是否在运行。打开终端并执行以下命令：

sh
ps aux | grep "php artisan queue:work"


如果队列工作进程正在运行，你会看到类似如下的输出：


user 12345 0.1 0.2 123456 7890 ?? Ss 10:00AM 0:01.23 php artisan queue:work


如果没有输出，则说明队列未启动。

使用Laravel代码检查

你也可以在Laravel应用中编写代码来检查队列是否启动。以下是一个示例：

php
use IlluminateSupportFacadesArtisan;</p>

<p>public function checkQueueStatus()
{
    $output = [];
    exec('ps aux | grep "php artisan queue:work"', $output);</p>

<pre><code>// 检查输出中是否有队列工作进程
foreach ($output as $line) {
    if (strpos($line, 'php artisan queue:work') !== false && strpos($line, 'grep') === false) {
        return true; // 队列已启动
    }
}

return false; // 队列未启动

}

你可以在控制器或其他地方调用这个方法来检查队列状态。

处理队列失败

配置队列失败处理器

Laravel允许你配置一个队列失败处理器，以便在任务失败时执行特定的逻辑。你可以在 app/Console/Kernel.php 文件中配置失败处理器：

php
use AppJobsExampleJob;
use IlluminateSupportFacadesLog;</p>

<p>protected $listen = [
    'default' => [
        AppJobsExampleJob::class,
    ],
];</p>

<p>protected $afterResolving = [
    IlluminateQueueInteractsWithQueue::class => [
        AppListenersQueueFailedListener::class,
    ],
];</p>

<p>protected function schedule(Schedule $schedule)
{
    // 定时任务
}</p>

<p>public function commands()
{
    $this->load(<strong>DIR</strong>.'/Commands');</p>

<pre><code>require base_path('routes/console.php');

}

创建一个监听器来处理失败的任务：

php
namespace AppListeners;</p>

<p>use IlluminateQueueEventsJobFailed;</p>

<p>class QueueFailedListener
{
    public function handle(JobFailed $event)
    {
        // 记录失败日志
        Log::error('Queue job failed: ' . $event->job->getRawBody(), [
            'exception' => $event->exception,
        ]);</p>

<pre><code>    // 发送通知
    // AppNotificationsQueueFailedNotification::send($event);
}

}

重试失败任务

Laravel提供了多种方式来重试失败的任务。你可以在任务类中设置重试次数：

php
namespace AppJobs;</p>

<p>use IlluminateBusQueueable;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateQueueInteractsWithQueue;
use IlluminateQueueSerializesModels;</p>

<p>class ExampleJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;</p>

<pre><code>public $tries = 3; // 重试次数

public function handle()
{
    // 任务逻辑
}

}

你还可以在命令行中手动重试失败的任务：

sh
php artisan queue:retry all


发送通知

当任务失败时，你可以发送通知给管理员或其他相关人员。首先，创建一个通知类：

php
php artisan make:notification QueueFailedNotification


编辑生成的通知类：

php
namespace AppNotifications;</p>

<p>use IlluminateBusQueueable;
use IlluminateNotificationsNotification;
use IlluminateContractsQueueShouldQueue;
use IlluminateNotificationsMessagesMailMessage;</p>

<p>class QueueFailedNotification extends Notification implements ShouldQueue
{
    use Queueable;</p>

<pre><code>public $job;
public $exception;

public function __construct($job, $exception)
{
    $this->job = $job;
    $this->exception = $exception;
}

public function via($notifiable)
{
    return ['mail'];
}

public function toMail($notifiable)
{
    return (new MailMessage)
                ->subject('Queue Job Failed')
                ->line('The following job has failed:')
                ->line(print_r($this->job->getRawBody(), true))
                ->line('Exception: ' . $this->exception->getMessage());
}

}

在 QueueFailedListener 中调用这个通知：

php
namespace AppListeners;</p>

<p>use IlluminateQueueEventsJobFailed;
use AppNotificationsQueueFailedNotification;
use IlluminateSupportFacadesNotification;</p>

<p>class QueueFailedListener
{
    public function handle(JobFailed $event)
    {
        // 记录失败日志
        Log::error('Queue job failed: ' . $event->job->getRawBody(), [
            'exception' => $event->exception,
        ]);</p>

<pre><code>    // 发送通知
    Notification::route('mail', 'admin@example.com')
                ->notify(new QueueFailedNotification($event->job, $event->exception));
}

}

通过以上方法，你可以有效地判断Laravel队列是否启动，并在队列任务失败时采取适当的措施。希望这些方法能帮助你更好地管理和维护Laravel应用中的队列服务。