Thinkphp で分散データベースに接続する方法
- *文オリジナル
- 2017-12-23 14:00:312708ブラウズ
Thinkphpは中国では主流のフレームワークで、使っている人も多いのではないでしょうか。今日は、Thinkphp で分散データベースに接続する方法を見ていきます。
もちろん、ここではモデルを使用してデータベースを追加、削除、変更、クエリする方法を説明するつもりはありません。私たちは、thinkphp によるデータベースの操作をより深く理解するのに役立つ、基礎となる接続コードの分析を行っています。将来の利用を容易にするため。
1. 単一データベース接続
単一データベースの接続構成は非常に簡単です。構成ファイルにいくつかの情報を構成するだけで済みます。
'DB_TYPE' => 'mysql', 'DB_HOST' => '192.168.5.102', 'DB_NAME' => 'databasename', 'DB_USER' => 'user', 'DB_PWD' => 'password', 'DB_PORT' => '3306', 'DB_PREFIX' => 'onmpw_',
セットアップ完了後、ご利用いただけます。デフォルトは単一のデータベース接続です。
2. 分散データベース接続
単一データベースへの接続は非常に簡単ですが、分散データベースへの接続を分析してみましょう。
'DB_TYPE' => 'mysql', 'DB_HOST' => '192.168.5.191,192.168.5.88,192.168.5.103', 'DB_NAME' => 'test,test,test', 'DB_USER' => 'masteruser,slaveuser,slaveuser', 'DB_PWD' => 'masterpass,slavepass,slavepass', 'DB_PORT' => '3306', 'DB_PREFIX' => '', 'DB_DEPLOY_TYPE' => 1, // 数据库部署方式:0 集中式(单一服务器),1 分布式(主从服务器) 'DB_RW_SEPARATE' => true, // 数据库读写是否分离 主从式有效 'DB_MASTER_NUM' => 1, // 读写分离后 主服务器数量 'DB_SLAVE_NO' => '', // 指定从服务器序号
上記の設定に従って、分散データベースに接続します。
次のオプションを見てみましょう
「DB_HOST」
分散データベースの場合、複数のサーバーがある場合は、複数のサーバー アドレスを入力し、各アドレスをカンマで区切る必要があります。マスター/スレーブディストリビューションの場合、以前のアドレスはマスター データベースのアドレスである必要があります。
次のユーザー名、パスワード、リスニングポートなどについては、もちろん、持っているだけ書き留めてください。各データベースのユーザー名とパスワードが同じ場合は、1 つのみしか書き込めません。
これらのオプションを解析するコードは次のとおりです
$_config['username'] = explode(',',$this->config['username']); $_config['password'] = explode(',',$this->config['password']); $_config['hostname'] = explode(',',$this->config['hostname']); $_config['hostport'] = explode(',',$this->config['hostport']); $_config['database'] = explode(',',$this->config['database']); $_config['dsn'] = explode(',',$this->config['dsn']); $_config['charset'] = explode(',',$this->config['charset']); ‘DB_DEPLOY_TYPE’=>1
1 は分散を意味し、0 は集中 (つまり、単一サーバー) を意味します。
このオプションの実装はクラス ThinkDbDirver
protected function initConnect($master=true) {
if(!empty($this->config['deploy']))
// 采用分布式数据库
$this->_linkID = $this->multiConnect($master);
else
// 默认单数据库
if ( !$this->_linkID ) $this->_linkID = $this->connect();
}$this->config['deploy'] にあり、上記の構成は使用前に解析されており、構成項目はすべて In です。 $this->config 配列。設定ファイルの解析方法についてはここでは紹介しませんので、興味のある方はThinkDbクラスを参照してください。
$this->multiConnect() 関数は分散接続に使用されます。「DB_DEPLOY_TYPE」オプションが 1 に設定されている場合、この関数が実行されます。それ以外の場合は、$this->connect() 関数を直接実行します。
‘DB_RW_SEPARATE’=>true
true は読み取りと書き込みが分離されていることを意味し、false は読み取りと書き込みが分離されていないことを意味します。
ここで、読み取りと書き込みの分離はマスター/スレーブ データベース システムに基づいていることに注意してください。このオプションを true に設定すると、マスター データベースが書き込みを行い、スレーブ データベースが読み取りを行います。
if($this->config['rw_separate']){
// 主从式采用读写分离
if($master)
// 主服务器写入
$r = $m;
else{
if(is_numeric($this->config['slave_no'])) {// 指定服务器读
$r = $this->config['slave_no'];
}else{
// 读操作连接从服务器
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
}
}
}else{
// 读写操作不区分服务器
$r = floor(mt_rand(0,count($_config['hostname'])-1)); // 每次随机连接的数据库
}$this->config[‘rw_ Separate’] trueの場合、読み込みと書き込みを分離します。 falseの場合、読み込みと書き込みを分離しません。なぜ読み取りと書き込みをマスターとスレーブに分離する必要があるのでしょうか?スレーブサーバーは書き込みができず読み取りのみが可能なため、スレーブサーバーにデータを書き込むとデータを同期できません。これにより、データの不整合が発生します。したがって、システムがマスター/スレーブの場合は、読み取りと書き込みを分離する必要があります。つまり、DB_RW_SEPARATE オプションを true に設定する必要があります。
'DB_MASTER_NUM'=>1
このオプションの後の数字は、読み取りと書き込みを分離した後のプライマリ サーバーの数を示します。したがって、このオプションはマスター/スレーブ データベース システムでも使用されます。
以下のコードはメインサーバーを選択します。
$m = floor(mt_rand(0,$this->config['master_num']-1));
マスター/スレーブ データベースから読み取るときにスレーブ サーバーから読み取るコア コードを選択します
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
ここで、$this->config[‘master_num’] はマスター サーバーの数を表します。
'DB_SLAVE_NO'=> ''
データを読み込むスレーブサーバーのシリアル番号を指定します。設定されていない場合、スレーブ サーバーの数はマスター サーバーの数に基づいて計算され、読み取り用にランダムに 1 台が選択されます。
if(is_numeric($this->config['slave_no'])) {// 指定服务器读
$r = $this->config['slave_no'];
}else{
// 读操作连接从服务器
$r = floor(mt_rand($this->config['master_num'],count($_config['hostname'])-1)); // 每次随机连接的数据库
}以上が各オプションの機能の実装コードの簡単な説明です。
接続部分を見てみましょう
if($m != $r ){
$db_master = array(
'username' => isset($_config['username'][$m])?$_config['username'][$m]:$_config['username'][0],
'password' => isset($_config['password'][$m])?$_config['password'][$m]:$_config['password'][0],
'hostname' => isset($_config['hostname'][$m])?$_config['hostname'][$m]:$_config['hostname'][0],
'hostport' => isset($_config['hostport'][$m])?$_config['hostport'][$m]:$_config['hostport'][0],
'database' => isset($_config['database'][$m])?$_config['database'][$m]:$_config['database'][0],
'dsn' => isset($_config['dsn'][$m])?$_config['dsn'][$m]:$_config['dsn'][0],
'charset' => isset($_config['charset'][$m])?$_config['charset'][$m]:$_config['charset'][0],
);
}
$db_config = array(
'username' => isset($_config['username'][$r])?$_config['username'][$r]:$_config['username'][0],
'password' => isset($_config['password'][$r])?$_config['password'][$r]:$_config['password'][0],
'hostname' => isset($_config['hostname'][$r])?$_config['hostname'][$r]:$_config['hostname'][0],
'hostport' => isset($_config['hostport'][$r])?$_config['hostport'][$r]:$_config['hostport'][0],
'database' => isset($_config['database'][$r])?$_config['database'][$r]:$_config['database'][0],
'dsn' => isset($_config['dsn'][$r])?$_config['dsn'][$r]:$_config['dsn'][0],
'charset' => isset($_config['charset'][$r])?$_config['charset'][$r]:$_config['charset'][0],
);
return $this->connect($db_config,$r,$r == $m ? false : $db_master);これを見ると、上記の各構成オプションのコードを紹介するときの $r と $m の役割を誰もが理解できると思います。
$r == $m ? false : $db_master を見てみましょう。データベースの読み取りと書き込みが分離されておらず、読み取りと書き込みがサーバーである場合、connect 関数に渡される値は false です。または、マスターとスレーブの書き込みが分離されている場合、connect に渡される値も false になります。上記のコードから、$r と $m が等しくない場合、$db_master が設定されることがわかります。実際、これはバックアップに相当します。選択した $r サーバーに障害が発生して接続できない場合は、$db_master に接続します。
connect() 関数の 3 番目のパラメーターは、実際には、$db_config サーバー接続が失敗した場合にバックアップ接続を選択するかどうかを示します。 False は再接続しないことを意味し、他の値は再接続を意味します。
コアコードは以下の通りです
try{
if(empty($config['dsn'])) {
$config['dsn'] = $this->parseDsn($config);
}
if(version_compare(PHP_VERSION,'5.3.6','<=')){
// 禁用模拟预处理语句
$this->options[PDO::ATTR_EMULATE_PREPARES] = false;
}
$this->linkID[$linkNum] = new PDO( $config['dsn'], $config['username'], $config['password'],$this->options);
}catch (\PDOException $e) {
if($autoConnection){ //$autoConnection不为false，而是默认的主服务器
trace($e->getMessage(),'','ERR');
return $this->connect($autoConnection,$linkNum); //出现异常，使用递归函数重新连接
}elseif($config['debug']){
E($e->getMessage());
}
}このように、マスタースレーブ型の場合、$rと$mは絶対に同じにはなりません。したがって、選択したスレーブ サーバーでデータの読み取りに障害が発生した場合、マスター サーバーがバックアップとなり、最終的にはマスター サーバーにアクセスして読み取りが行われます。データ読み取りの適時性を確保できます。
しかし、まだ完璧ではないといつも感じています。複数のスレーブ サーバーがあり、読み取り中に選択したスレーブ サーバーとマスター サーバーの両方が失敗した場合、データの読み取りは失敗します。このとき、他のスレーブサーバーを再度読み取ることができれば、より安全になるはずです。もちろん、thinkphp の現在の機能は非常に完成されており、使用するには十分です。しかし私は、thinkphp が今後ますます完璧になることを期待しています。
上記の紹介が開発に thinkphp を使用する際に皆さんに役立つことを願っています。
関連する推奨事項:
ThinkPHP5 フレームワークの基礎知識、開発仕様、ディレクトリ構造
以上がThinkphp で分散データベースに接続する方法の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。