简体中文（ZH-CN）English（EN）繁体中文（ZH-TW）日本語（JA）한국어（KO）Melayu（MS）Français（FR）Deutsch（DE）
ホームページ
記事
に質問
コース
特集
ダウンロード
ゲーム
辞書
最近の更新

ホームページ  >  記事  >  バックエンド開発  >  mysql プロキシの読み書き分離設定と php mysql 読み書き分離クラス

mysql プロキシの読み書き分離設定と php mysql 読み書き分離クラス

WBOY
WBOYオリジナル
2016-07-25 08:56:031161ブラウズ
  2. mysql-proxy
  3. –proxy-backend-addresses=narcissus:3306
  4. –proxy-backend-addresses=nostromo:3306
コードをコピー

3. データベースの読み取りと書き込みの分離、192.168.18 .11 0 Enter は書き込みを担当し、192.168.18.107 はデータの読み取りを担当します。 もちろん、データを読み取るためのサーバーを追加することもできます。

  2. mysql-proxy
  3. –proxy-backend-addresses=192.168.18.110:3306
  4. –proxy-read-only-backend-addresses=192.168.18.107:3306
コードをコピー

このメソッドは読み取りと書き込みを分離しません。 mysql-proxy はどれがスレーブサーバーに送信されるかを区別できないため、スクリプトを使用してそれらを制御する必要があります。4 番目の方法を参照してください。

4. Lua スクリプトは、接続と配布、クエリと返される結果セットを適切に制御できます。 Lua スクリプトを使用する場合は、-proxy-lua-script を使用してスクリプトの名前を指定する必要があります。 接続が生成されるまでスクリプトは読み取られません。つまり、スクリプトの変更後にサービスを再起動する必要はありません。 mysql-proxy –proxy-lua-script=rw-splitting.lua –proxy-backend-addresses=192.168.18.110:3306 –proxy-read-only-backend-addresses=192.168.18.107:3306

注: 1. プロキシの読み取り/書き込み分離メカニズムは、まず最初のいくつかのクエリをマスターに送信して接続を確立します。 マスターに送信されるクエリの数が接続プールの最小値を超えると、クエリの送信が開始されます

2. LAST_INSERT_ID をメインサーバーに送信することはできません。226 行目を次のように変更します。 elseif is_insert_id かつ token.token_name == “TK_FUNCTION” then

3. デフォルトの rw-splitting.lua を使用すると、proxy-command が見つからないというメッセージが表示されます。mysql-proxy のパスをシステム パスに設定し、共有ディレクトリで実行すると問題ありません。操作中に cmd を入力します。 次に、 C:toolsmysql-proxyshare を cd します。

4.文字化け プロキシ経由でデータベースに接続した後、見つかった文字列は常に文字化けします。セット名「utf8」を手動で実行しても効果はありません。 解決策、mysqlサーバーを設定する必要があります

  2. class mysql_rw_php {
  3. //クエリ数
  4. var $querynum = 0;
  5. //現在の操作のデータベース接続
  6. var $link = null
  7. //文字セット
  8. var $charset; ;
  9. //現在のデータベース
  10. var $cur_db = '';
  12. //有効な読み取り専用データベース接続があるかどうか
  13. var $ro_exist = false
  14. //読み取り専用データベース接続
  15. var $link_ro = null;
  16. // データベース接続の読み取りおよび書き込み
  17. var $link_rw = null;
  19. function mysql_rw_php(){
  20. }
  22. function connect($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0, $ halt = TRUE) {
  23. if($pconnect) {
  24. if(!$this->link = @mysql_pconnect($dbhost, $dbuser, $dbpw)) {
  25. $halt && $this->halt('Can MySQL サーバーに接続しません');
  26. }
  27. } else {
  28. if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
  29. $halt && $this->halt( 'MySQL サーバーに接続できません');
  30. }
  31. }
  33. //読み取り専用接続に失敗しました
  34. if(!$this->link && !$halt) return false;
  36. //rw が初期化されていない場合、最初の接続は rw
  37. if($this->link_rw == null)
  38. $this->link_rw = $this->link;
  40. if($this->version() > ' 4.1') {
  41. if ($this->charset) {
  42. @mysql_query("SETcharacter_set_connection=$this->charset,character_set_results=$this->charset,character_set_client=binary", $this->link );
  43. }
  44. if ($this->version() > '5.0.1') {
  45. @mysql_query("SET sql_mode=''", $this->link); ($dbname) {
  46. $this->select_db($dbname);
  47. }
  48. }
  50. //読み取り専用の mysql データベースに接続します
  51. function connect_ro($dbhost, $dbuser, $dbpw, $dbname = '' , $pconnect = 0) {
  52. if($this->link_rw == null)
  53. $this->link_rw = $this->link = null;
  54. //停止なしエラー
  55. $this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false);
  56. if($this->link){
  57. //接続成功
  58. //echo "link ro sussess! $this->ro_exist = true;
  59. $this->link_ro = $this->link;
  60. if($this->cur_db){
  61. //データベースの場合選択されているため、操作が必要です Once
  62. @mysql_select_db($this->cur_db, $this->link_ro)
  63. }
  64. }else{
  65. //接続に失敗しました
  66. //echo "link ro failed! $this- >link = &$this->link_rw;
  67. }
  68. }
  70. //一連の読み取り専用データベースを設定し、そのうちの 1 つに接続します
  71. function set_ro_list($ro_list){
  72. if(is_array($ro_list)){
  73. / /ランダムに 1 つを選択
  74. $link_ro = $ro_list[array_rand($ro_list)]
  75. $this->connect_ro($link_ro['dbhost'], $link_ro ['dbuser'], $link_ro['dbpw'] ; $dbname, $this->link_ro)
  76. }
  77. return @mysql_select_db($dbname, $this->link_rw);
  79. function fetch_array( $query, $result_type = MYSQL_ASSOC) {
  80. return mysql_fetch_array($ query, $result_type)
  81. }
  83. function fetch_one_array($sql, $type = '') {
  84. $qr = $this->query($sql) , $type);
  85. return $this->fetch_array( $qr); }
  87. function query($sql, $type = '') {
  88. $this->link = &$this->link_rw ;
  89. //選択文を判定する
  90. if($this- >ro_exist && preg_match ("/^(s*)select/i", $sql)){
  91. $this->link = &$this- >link_ro;
  92. }
  93. $func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query')
  94. 'mysql_unbuffered_query' : 'mysql_query' ? (!($query = $sql, $ this->link)) && $type != 'SILENT' ) {
  95. $this->halt('MySQL クエリ エラー', $sql);
  96. $this->querynum++;
  97. return $query;
  98. }
  100. functionaffected_rows() {
  101. return mysql_affected_rows($this->link);
  102. }
  104. function error() {
  105. return (($this->link) ? mysql_error($this->link) : mysql_error());
  106. }
  108. function errno() {
  109. return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
  110. }
  112. 関数 result($query, $row) {
  113. $query = @mysql_result($query, $row);
  114. $query を返す;
  115. }
  117. 関数 num_rows($query) {
  118. $query = mysql_num_rows($query);
  119. $query を返す;
  120. }
  122. function num_fields($query) {
  123. return mysql_num_fields($query);
  124. }
  126. function free_result($query) {
  127. return mysql_free_result($query);
  128. }
  130. function insert_id() {
  131. return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);
  132. }
  134. 関数 fetch_row($query) {
  135. $query = mysql_fetch_row($query);
  136. $query を返す;
  137. }
  139. function fetch_fields($query) {
  140. return mysql_fetch_field($query);
  141. }
  143. function version() {
  144. return mysql_get_server_info($this->link);
  145. }
  147. function close() {
  148. return mysql_close($this->link);
  149. }
  151. function halt($message = '', $sql = '') {
  152. $dberror = $this->error();
  153. $dberrno = $this->errno();
  154. echo "
  155. MySQL エラー
  156. メッセージ: $message
  157. SQL
  158. エラー ;br>
  159. エラー: $dberrno
  • exit();
  • }
  • }
  • ?>
    • 复制代

    调用例：

    2. /*****************************************
    3. *** mysql-rw-php バージョン 0.1
    4. *** http://bbs.it-home.org
    5. *** http://code.google.com/p/mysql-rw-php/
    6. *** class_mysql.php (uchome) からコードを修正します
    7. ***************************************/
    9. require_once('mysql_rw_php.class.php');
    11. //rw 情報
    12. $db_rw = array(
    13. 'dbhost'=>'bbs.it-home.org',
    14. 'dbuser'=>'jbxue',
    15. 'dbpw'=>'bbs. it-home.org',
    16. 'dbname'=>'test'
    17. );
    19. $db_ro = array(
    20. array(
    21. 'dbhost'=>'bbs.it-home.org:4306',
    22. 'dbuser'=>'jbxue',
    23. 'dbpw'=>'bbs. it-home.org'
    24. )
    25. );
    27. $DB = 新しい mysql_rw_php;
    29. //マスターに接続します
    30. $DB->connect($db_rw[dbhost], $db_rw[dbuser], $db_rw[dbpw], $db_rw[dbname]);
    32. //方法 1: 1 つのサーバーに接続します
    33. $DB->connect_ro($db_ro[0][dbhost], $db_ro[0][dbuser], $db_ro[0][dbpw]);
    35. //方法 2: rand によりリストから 1 つのサーバーに接続します
    36. $DB->set_ro_list($db_ro);
    38. //rw に送信
    39. $sql = "セットに挿入 a='test'";
    40. $DB->クエリ($sql);
    42. //ro に送信
    43. $sql = "select * from a";
    44. $qr = $DB->クエリ($sql);
    45. while($row = $DB->fetch_array($qr)){
    46. echo $row[a];
    47. }
    48. ?>
    复制發


    声明：
    この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
    前の記事：PHP 出力バッファリングの小さな例次の記事：PHP 出力バッファリングの小さな例

    関連記事

    続きを見る