Условия гонки в Laravel при использовании разделенных подключений к базе данных «чтение» и «запись»

Думал, что обновлю и отвечу на это, если кто-то еще столкнется с той же проблемой.

Это не идеальное решение, но оно хорошо сработало за последнюю неделю или около того.

Внутри метода AppServiceProviderboot() я добавил следующее

            DB::listen(function ($query) {
                if (strpos($query->sql, 'select') !== FALSE) {
                    if (time() < session('force_pdo_write_until')) {
                        DB::connection()->recordsHaveBeenModified(true);
                    }
                } else {
                    session(['force_pdo_write_until' => time() + 1]);
                }
            });

В двух словах, это прослушивает каждый запрос БД. Если текущий запрос представляет собой SELECT (чтение БД), мы проверяем, имеет ли ключ «force_pdo_write_until» внутри пользовательского сеанса отметку времени, превышающую текущее время. Если это так, мы обманываем текущее соединение с БД, используя ReadPDO, используя метод recordsHaveBeenModified() — это как обычно обнаруживаются основные липкие сессии Laravel.

Если текущий запрос не является SELECT (скорее всего, запись в БД), мы устанавливаем переменную сеанса для «force_pdo_write_until» на 1 секунду в будущем.

Каждый раз, когда отправляется запрос POST, если следующий запрос GET находится в пределах 1 секунды от предыдущего запроса, мы можем быть уверены, что текущий пользователь будет использовать соединение RW DB и получит правильные результаты.

Обновлять (12.09.19):

Оказывается, приведенное выше решение на самом деле вообще не изменяет соединение с БД, оно просто добавляет несколько миллисекунд времени обработки к любому запросу, поэтому выглядело так, как будто оно работает примерно в 75% случаев (поскольку задержка реплики БД колеблется в зависимости от в процессе).

В конце концов я решил пойти немного глубже и напрямую переопределить класс соединения с БД и изменить соответствующие функции. Мои экземпляры Laravel используют MySQL, поэтому я переопределил класс Illuminate\Database\MySqlConnection. Этот новый класс был зарегистрирован через нового поставщика услуг, который, в свою очередь, загружается через конфиг.

Я скопировал конфигурацию и файлы, которые я использовал ниже, чтобы облегчить понимание для любых новых разработчиков. Если вы копируете их напрямую, убедитесь, что вы также добавили флаг «sticky_by_session» в конфигурацию вашего подключения.

config/database.php

    'connections' => [
        'mysql' => [
            'sticky' => true,
            'sticky_by_session' => true,
             ...
        ],
    ],

config/app.php

    'providers' => [
        App\Providers\DatabaseServiceProvider::class
        ...
    ],

app/Providers/DatabaseServiceProvider.php

<?php

namespace App\Providers;

use App\Database\MySqlConnection;
use Illuminate\Database\Connection;
use Illuminate\Support\ServiceProvider;

class DatabaseServiceProvider extends ServiceProvider
{
    /**
     * Register the service provider.
     *
     * @return void
     */
    public function register()
    {
        if (config('database.connections.mysql.sticky_by_session')) {
            Connection::resolverFor('mysql', function ($connection, $database, $prefix, $config) {
                return new MySqlConnection($connection, $database, $prefix, $config);
            });
        }
    }
}

app/Database/MySqlConnection.php

<?php

namespace App\Database;

use Illuminate\Database\MySqlConnection as BaseMysqlConnection;

class MySqlConnection extends BaseMysqlConnection
{
    public function recordsHaveBeenModified($value = true)
    {
        session(['force_pdo_write_until' => time() + 1]);
        parent::recordsHaveBeenModified($value);
    }

    public function select($query, $bindings = [], $useReadPdo = true)
    {
        if (time() < session('force_pdo_write_until')) {
            return parent::select($query, $bindings, false);
        }
        return parent::select($query, $bindings, $useReadPdo);
    }
}

Внутри recordsHaveBeenModified() мы просто добавляем переменную сеанса для последующего использования. Этот метод используется при обычном обнаружении липких сессий Laravel, как упоминалось ранее.

Внутри select() мы проверяем, была ли переменная сеанса установлена ​​менее секунды назад. Если это так, мы вручную заставляем запрос использовать соединение RW, в противном случае просто продолжаем как обычно.

Теперь, когда мы напрямую модифицируем запрос, я не видел никаких условий гонки RO или эффектов от задержки реплики.

Я опубликовал как пакет!

• mpyw/laravel-cached-база данных-липкость: гарантирует привязку базы данных к последовательным запросам одного и того же пользователя.

Installing

composer require mpyw/laravel-cached-database-stickiness

The default implementation is provided by ConnectionServiceProvider, however, package discovery is not available. Be careful that you MUST register it in config/app.php by yourself.

<?php

return [

    /* ... */

    'providers' => [

        /* ... */

        Mpyw\LaravelCachedDatabaseStickiness\ConnectionServiceProvider::class,

        /* ... */

    ],

    /* ... */
];

Это все! Все проблемы будут решены.