Laravel队列配置问询：能否设置两个'failed'实例及MongoDB与MySQL共存存储失败任务的方案

嘿，针对你的两个问题，我来给你详细梳理下：

问题1：Laravel队列能不能配置两个'failed'实例？ #

Laravel默认的队列失败处理是单驱动模式，直接在queue.php里重复写'failed'配置项肯定行不通——因为PHP数组里相同的键会被后面的配置覆盖，最后只会生效最后一个配置。不过我们可以通过其他方式实现同时把失败任务存储到MySQL和MongoDB哦。

问题2：重复配置'failed'的问题及替代方案 #

重复配置的坑 #

要是你在queue.php里写两个'failed'键，比如：

'failed' => [
    'database' => env('DB_CONNECTION', 'mysql'),
    'table' => 'failed_jobs',
],
'failed' => [
    'driver' => 'mongodb',
    'collection' => 'failed_jobs',
]

这在PHP里完全无效，第二个'failed'会直接把第一个覆盖掉，最终只会使用MongoDB的配置，MySQL的配置直接丢失，所以绝对不能这么搞。

两种可行的实现方式 #

这里给你推荐两种常用的方案，都能实现多存储需求：

方案1：用队列failed事件同步数据

Laravel的任务失败时会触发JobFailed事件，我们可以监听这个事件，在事件处理逻辑里把失败任务的数据同时写入MongoDB和原有的MySQL存储。

步骤如下：

1. 保留原有的failed配置（MySQL），保证原生的失败任务表正常工作。
2. 创建事件监听器：

php artisan make:listener RecordFailedJobToMongoDB

3. 在生成的app/Listeners/RecordFailedJobToMongoDB.php中编写存储逻辑：

<?php

namespace App\Listeners;

use Illuminate\Queue\Events\JobFailed;
use MongoDB\Client;

class RecordFailedJobToMongoDB
{
    protected $mongoClient;

    public function __construct(Client $mongoClient)
    {
        $this->mongoClient = $mongoClient;
    }

    public function handle(JobFailed $event)
    {
        // 整理失败任务的数据
        $failedJob = [
            'uuid' => $event->job->uuid(),
            'connection' => $event->connectionName,
            'queue' => $event->job->getQueue(),
            'payload' => $event->job->getRawBody(),
            'exception' => (string) $event->exception,
            'failed_at' => now()->toDateTimeString(),
        ];

        // 写入MongoDB集合
        $this->mongoClient->your_db_name->failed_jobs->insertOne($failedJob);
    }
}

4. 在app/Providers/EventServiceProvider.php中注册监听器：

protected $listen = [
    \Illuminate\Queue\Events\JobFailed::class => [
        \App\Listeners\RecordFailedJobToMongoDB::class,
    ],
];

这种方式的好处是不破坏Laravel原生的失败处理流程，只是额外同步数据，后续要扩展其他存储也很方便。

方案2：自定义多驱动的失败任务提供者

如果你想完全掌控失败任务的存储逻辑，可以自定义一个实现FailedJobProviderInterface的类，在里面同时操作MySQL和MongoDB。

1. 创建自定义提供者类：

<?php

namespace App\Queue\Failed;

use Illuminate\Queue\Failed\DatabaseFailedJobProvider;
use Illuminate\Queue\Failed\FailedJobProviderInterface;
use MongoDB\Client;

class MultiStoreFailedJobProvider implements FailedJobProviderInterface
{
    protected $mysqlProvider;
    protected $mongoClient;

    public function __construct(DatabaseFailedJobProvider $mysqlProvider, Client $mongoClient)
    {
        $this->mysqlProvider = $mysqlProvider;
        $this->mongoClient = $mongoClient;
    }

    // 记录失败任务
    public function log($connection, $queue, $payload, $exception)
    {
        // 先存储到MySQL
        $mysqlId = $this->mysqlProvider->log($connection, $queue, $payload, $exception);
        
        // 再存储到MongoDB
        $this->mongoClient->your_db_name->failed_jobs->insertOne([
            'uuid' => $payload['uuid'] ?? $mysqlId,
            'connection' => $connection,
            'queue' => $queue,
            'payload' => $payload,
            'exception' => (string) $exception,
            'failed_at' => now()->toDateTimeString(),
        ]);

        return $mysqlId;
    }

    // 实现接口的其他方法
    public function all()
    {
        // 可根据需求返回MySQL数据，或合并两个存储的数据
        return $this->mysqlProvider->all();
    }

    public function find($id)
    {
        return $this->mysqlProvider->find($id);
    }

    public function delete($id)
    {
        // 同时删除两个存储中的记录
        $mysqlResult = $this->mysqlProvider->delete($id);
        $this->mongoClient->your_db_name->failed_jobs->deleteOne(['uuid' => $id]);
        
        return $mysqlResult;
    }
}

2. 在app/Providers/AppServiceProvider.php中绑定自定义提供者：

use App\Queue\Failed\MultiStoreFailedJobProvider;
use Illuminate\Queue\Failed\DatabaseFailedJobProvider;
use Illuminate\Queue\Failed\FailedJobProviderInterface;
use MongoDB\Client;

public function register()
{
    $this->app->bind(FailedJobProviderInterface::class, function ($app) {
        $mysqlProvider = $app->make(DatabaseFailedJobProvider::class);
        $mongoClient = new Client(env('MONGODB_URI'));
        return new MultiStoreFailedJobProvider($mysqlProvider, $mongoClient);
    });
}

这种方式更灵活，适合需要深度定制失败任务管理的场景，比如统一处理两个存储的查询、删除操作。

内容的提问来源于stack exchange，提问作者Fernando