ビジネス規(guī)模の拡大に伴い、データベースで処理する必要のあるデータ量も増加しており、単一のデータベースでは逼迫しています?，F(xiàn)時點では、データベースの水平サブデータベース操作を?qū)g行してデータを異なるデータベースに分散し、それによってシステムのパフォーマンスとスケーラビリティを向上させる必要があります。この記事では、ThinkPHP6 でデータベースの水平シャーディング操作を?qū)g行する方法を紹介します。

1. データベース水平サブデータベースとは何ですか?

データベースの水平シャーディングは、1 つのデータベース內(nèi)のデータを複數(shù)のデータベースに分散するプロセスです。特定のルール (ユーザー ID や期間など) に従ってデータを異なるデータベースに分割することで、単一データベースへの負荷を軽減できます。同時に、データ量が多い場合、水平シャーディングによりクエリ効率が向上し、データのセキュリティが強化されます。

2. ThinkPHP6 での水平サブライブラリの実裝

ThinkPHP6 では、データベースミドルウェアを使用して水平サブライブラリを?qū)g裝できます。 ThinkPHP6 の MySQL 接続にデータベースミドルウェアを配置し、サブデータベースを制御します。

1. Thinkswoole のインストール

ThinkPHP6 では、データベースミドルウェアとして Thinkswoole が使用されています。プロジェクトに Thinkswoole をインストールする必要があります。

ThinkSwoole のバージョン情報をcomposer.json ファイルに追加し、composer を使用してインストールします。

2. データベース構(gòu)成を変更する

まず config/database.php ファイルを見つけて、MySQL 接続を Swoole 接続に置き換えます。元の MySQL 接続情報をコメントアウトします:

// 'mysql' => [
    //     // 默認數(shù)據(jù)連接標(biāo)識
    //     'default' => env('database.driver', 'mysql'),
    //     // 數(shù)據(jù)庫連接信息
    //     'connections' => [
    //         'mysql' => [
    //             // 數(shù)據(jù)庫類型
    //             'type' => 'mysql',
    //             // 主機地址
    //             'host' => env('database.hostname', '127.0.0.1'),
    //             // 數(shù)據(jù)庫名
    //             'database' => env('database.database', ''),
    //             // 用戶名
    //             'username' => env('database.username', 'root'),
    //             // 密碼
    //             'password' => env('database.password', ''),
    //             // 端口
    //             'hostport' => env('database.hostport', '3306'),
    //             // 數(shù)據(jù)庫連接參數(shù)
    //             'params' => [],
    //             // 數(shù)據(jù)庫編碼默認采用utf8
    //             'charset' => 'utf8',
    //             // 數(shù)據(jù)庫表前綴
    //             'prefix' => env('database.prefix', ''),
    //             // 數(shù)據(jù)庫調(diào)試模式
    //             'debug' => env('database.debug', true),
    //             // 數(shù)據(jù)庫部署方式:0 集中式(單一服務(wù)器),1 分布式(主從服務(wù)器)
    //             'deploy' => 0,
    //             // 數(shù)據(jù)庫讀寫是否分離 主從式有效
    //             'rw_separate' => false,
    //             // 讀寫分離后 主服務(wù)器數(shù)量
    //             'master_num' => 1,
    //             // 指定從服務(wù)器序號
    //             'slave_no' => '',
    //             // 是否嚴格檢查字段是否存在
    //             'fields_strict' => true,
    //             // 數(shù)據(jù)集返回類型
    //             'resultset_type' => 'array',
    //             // 自動寫入時間戳字段
    //             'auto_timestamp' => false,
    //             // 時間字段取出后的默認時間格式
    //             'datetime_format' => false,
    //             // Builder類
    //             'builder' => '',
    //             // Query類
    //             'query' => '\think\db\Query',
    //             // 是否需要進行SQL性能分析
    //             'sql_explain' => false,
    //         ],
    //     ],
    // ],

Swoole 接続情報を追加します:

 // swoole
    'swoole' => [
        // 默認數(shù)據(jù)連接標(biāo)識
        'default' => 'swoole',
        // 數(shù)據(jù)庫連接信息
        'connections' => [
            'swoole' => [
                // 數(shù)據(jù)庫類型
                'type' => 'mysql',
                // 服務(wù)器地址
                'hostname' => [
                    '127.0.0.1:3305',
                    '127.0.0.1:3306',
                ],
                // 數(shù)據(jù)庫名
                'database' => 'test',
                // 用戶名
                'username' => 'root',
                // 密碼
                'password' => '',
                // 端口
                'hostport' => '',
                // 數(shù)據(jù)庫連接參數(shù)
                'params' => [],
                // 數(shù)據(jù)庫編碼默認采用utf8mb4
                'charset' => 'utf8mb4',
                // 數(shù)據(jù)庫表前綴
                'prefix' => '',
                // 數(shù)據(jù)庫調(diào)試模式
                'debug' => true,
                // 數(shù)據(jù)庫部署方式:0 集中式(單一服務(wù)器),1 分布式(主從服務(wù)器)
                'deploy' => 0,
                // 數(shù)據(jù)庫讀寫是否分離 主從式有效
                'rw_separate' => false,
                // 讀寫分離后 主服務(wù)器數(shù)量
                'master_num' => 1,
                // 指定從服務(wù)器序號
                'slave_no' => '',
                // 自動寫入時間戳字段
                'auto_timestamp' => false,
                // 時間字段取出后的默認時間格式
                'datetime_format' => 'Y-m-d H:i:s',
                // Builder類
                'builder' => '',
                // Query類
                'query' => '\think\db\Query',
                // 是否需要進行SQL性能分析
                'sql_explain' => false,
            ],
        ],
    ],

上記のコードでは、2 つのサーバー アドレス (127.0.0.1:3305 と 127.0.0.1:3306 ) を定義しました。 , これは複數(shù)のデータノードのサブライブラリを?qū)g裝するためです。データベース名、ユーザー名、パスワードなどの情報は変更されません。

3. データベース ミドルウェアの作成

Db.php のデータベース ミドルウェアを app/middleware ディレクトリに作成し、次のコードを追加します:

<?php
namespace appmiddleware;

use thinkRequest;
use thinkContainer;

class Db
{
    public function handle(Request $request, Closure $next)
    {
        $serverIds = $this->getServerIds($request);
        //定義一個連接池
        $conns = [];
        foreach($serverIds as $sid) {
            $sid = $request->$sid;
            if(empty($conns[$sid])) {
                $conns[$sid] = Container::getInstance()
                                         ->make('db')->connect($sid);
            }
        }
        Container::getInstance()->bind('db', function() use ($conns) {
            return $conns;
        });
        return $next($request);
    }

    protected function getServerIds(Request $request)
    {
        return ['uid'];
    }
}

ここに作成Db というミドルウェアが作成されます。 handle メソッドでは、まず現(xiàn)在のリクエストのサーバー ID 配列を取得します。次に、これらのサーバー アドレスを接続プール $cons 內(nèi)の既存のアドレスと比較し、存在しない場合は接続プールに追加します。最後に、接続プール $conns をコンテナー インスタンスにバインドします。 getServerIds メソッドでは、サーバー ID の名前を設(shè)定できます。デフォルトは uid です。

4. ミドルウェアの登録

次のコードを config/middleware.php に追加します:

return [
    ...
    appmiddlewareDb::class,
];

このコードはミドルウェアの登録に使用されます。Db ミドルウェアを追加しました。ミドルウェア実行アクティビティのリストに追加します。

5. サブライブラリ操作の実裝

次に、モデルに水平サブライブラリ操作を?qū)g裝します。ユーザーテーブルを例にとると、ユーザー ID はデータベースの制限として 100,000 と 100,000 に分割されます。これは、ユーザー ID が 0 から 100,000 までのデータがデータベースに格納されることを意味し、ユーザー ID が一致するまで続きます。 10 番目のデータベースには 90 萬から 100 萬件のデータが格納されます。

<?php
namespace appmodel;

use thinkModel;

class User extends Model
{
    protected $connection = [
        1 => 'user_1',
        2 => 'user_2',
        3 => 'user_3',
        4 => 'user_4',
        5 => 'user_5',
        6 => 'user_6',
        7 => 'user_7',
        8 => 'user_8',
        9 => 'user_9',
        10 => 'user_10',
    ];

    protected $pk = 'uid';

    public function getTableName(): string
    {
        $id = ceil($this->id / 100000);
        return $this->connection[$id] . '.' . $this->table;
    }
}

ここでは 10 個のデータベース接続を定義します。各接続はデータベース シャードを表し、水平シャーディングの目的を達成します。次に、現(xiàn)在のモデルに対応するデータ テーブル名を取得する getTableName メソッドを定義します。モデル內(nèi)の主キー ID 値に基づいてアクセスする必要があるデータベース接続を計算し、データベース接続とデータ テーブル名の組み合わせを返します。

概要:

この記事では、ThinkPHP6 の水平サブライブラリ操作を紹介します。ビジネスが拡大し続け、データの規(guī)模が増大するにつれて、水平シャーディングによってシステムのパフォーマンスと拡張性が向上し、データのセキュリティも強化されます。 ThinkPHP6 では、Thinkswoole ミドルウェアおよびその他のメソッドを使用して、水平サブライブラリ操作を?qū)g裝できます。

以上がThinkPHP6 でデータベースの水平サブデータベース操作を?qū)g行するにはどうすればよいですか?の詳細內(nèi)容です。詳細については、PHP 中國語 Web サイトの他の関連記事を參照してください。