我正在尝试开发一个 Multi-Tenancy 多数据库应用程序，这基本上意味着每个租户都有自己的数据库、自己的用户、资源等。

自然地，当收到请求时，Laravel 需要知道要使用哪个数据库连接，所以我编写了一个中间件，它基本上解析请求中的 JWT 并查找租户 ID 或用户名，然后简单地连接到租户的数据库。

但现在我正在使用队列，我正试图超越 laravel 5 的默认行为，它连接到主数据库并插入失败的作业记录。

当我深入研究供应商文件时，我发现了一个FailedJobProvider 接口(interface):

<?php

namespace Illuminate\Queue\Failed;

interface FailedJobProviderInterface
{
    /**
     * Log a failed job into storage.
     *
     * @param  string  $connection
     * @param  string  $queue
     * @param  string  $payload
     * @return void
     */
    public function log($connection, $queue, $payload);

    /**
     * Get a list of all of the failed jobs.
     *
     * @return array
     */
    public function all();

    /**
     * Get a single failed job.
     *
     * @param  mixed  $id
     * @return array
     */
    public function find($id);

    /**
     * Delete a single failed job from storage.
     *
     * @param  mixed  $id
     * @return bool
     */
    public function forget($id);

    /**
     * Flush all of the failed jobs from storage.
     *
     * @return void
     */
    public function flush();
}

还有一个实现该接口(interface)的DatabaseFailedJobProvider类:

<?php

namespace Illuminate\Queue\Failed;

use Carbon\Carbon;
use Illuminate\Database\ConnectionResolverInterface;

class DatabaseFailedJobProvider implements FailedJobProviderInterface
{
    /**
     * The connection resolver implementation.
     *
     * @var \Illuminate\Database\ConnectionResolverInterface
     */
    protected $resolver;

    /**
     * The database connection name.
     *
     * @var string
     */
    protected $database;

    /**
     * The database table.
     *
     * @var string
     */
    protected $table;

    /**
     * Create a new database failed job provider.
     *
     * @param  \Illuminate\Database\ConnectionResolverInterface  $resolver
     * @param  string  $database
     * @param  string  $table
     * @return void
     */
    public function __construct(ConnectionResolverInterface $resolver, $database, $table)
    {
        $this->table = $table;
        $this->resolver = $resolver;
        $this->database = $database;
    }

    /**
     * Log a failed job into storage.
     *
     * @param  string  $connection
     * @param  string  $queue
     * @param  string  $payload
     * @return void
     */
    public function log($connection, $queue, $payload)
    {
        $failed_at = Carbon::now();

        $this->getTable()->insert(compact('connection', 'queue', 'payload', 'failed_at'));
    }

    /**
     * Get a list of all of the failed jobs.
     *
     * @return array
     */
    public function all()
    {
        return $this->getTable()->orderBy('id', 'desc')->get();
    }

    /**
     * Get a single failed job.
     *
     * @param  mixed  $id
     * @return array
     */
    public function find($id)
    {
        return $this->getTable()->find($id);
    }

    /**
     * Delete a single failed job from storage.
     *
     * @param  mixed  $id
     * @return bool
     */
    public function forget($id)
    {
        return $this->getTable()->where('id', $id)->delete() > 0;
    }

    /**
     * Flush all of the failed jobs from storage.
     *
     * @return void
     */
    public function flush()
    {
        $this->getTable()->delete();
    }

    /**
     * Get a new query builder instance for the table.
     *
     * @return \Illuminate\Database\Query\Builder
     */
    protected function getTable()
    {
        return $this->resolver->connection($this->database)->table($this->table);
    }
}

所以我想如果我编写自己的提供程序或者可以超越这个提供程序，我将能够在插入失败的作业之前告诉 laravel 要连接到哪个数据库。但我对 SOLID 或 OOP 不是很熟悉，在这种情况下我很困惑该怎么做。

如何编写我自己的提供程序或超越这个提供程序来随时更改数据库连接？

最佳答案

我知道这太晚了，但我遇到了同样的问题。我想到了。因此，对于遇到此问题的任何其他人，这是如何完成的:

首先，您需要创建自己的失败作业提供程序类来实现 FailedJobProviderInterface界面。我建议从 Illuminate\Queue\Failed\DatabaseFailedJobProvider 复制代码进入您的自定义类，然后简单地将其更改为您需要的工作。 Laravel 使用这个类中的其余函数做多件事，类本身需要与实现的接口(interface)相匹配。

我只是更改了日志方法，将额外的数据记录到我的数据库中的额外列中。

一旦完成，然后在服务提供者(您自己的或默认的服务提供者)中，您需要包含刚刚创建的新的失败作业提供者类。

然后在服务提供者的boot方法中放入如下代码:

// Get a default implementation to trigger a deferred binding
$_ = $this->app['queue.failer'];

//regiter the custom class you created
$this->app->singleton('queue.failer', function ($app) {

    $config = $app['config']['queue.failed'];
    return new NAMEOFYOURCLASS($app['db'], $config['database'], $config['table']);

});

该代码正在覆盖 this registration done by Laravel .

为了代码清晰，您可以将该代码作为一个函数放在服务提供程序中，并且也只需在引导方法中运行该方法。

如果您想将不同的数据记录到数据库中，请确保同时更新失败的作业迁移和/或数据库表。

现在，当作业失败时，您的自定义代码将根据需要运行记录失败的作业，即使您更新了 Laravel 版本，它也应该继续正常工作。

关于php - 如何在 laravel 5 中覆盖作业插入失败的数据库连接？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/34333890/