欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  后端开发

mysql Proxy读写分离配置与php mysql读写分离类

程序员文章站 2022-03-26 21:33:16
...
  2. mysql-proxy \
  3. –proxy-backend-addresses=narcissus:3306 \
  4. –proxy-backend-addresses=nostromo:3306
复制代码

3、数据库读写分离，192.168.18.110负责写入，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、 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、proxy的读写分离机制是先把最初的几条查询发到master上建立连接， 当发送到master上的查询数超过连接池的最小值时开始把查询

2、LAST_INSERT_ID不能发送到主服务器上， 226 行修改为下面的就可以了 elseif not is_insert_id and token.token_name == “TK_FUNCTION” then

3、使用默认的rw-splitting.lua时，会提示找不到proxy-command，我把mysql-proxy的路径设置为系统路径，然后在 share目录下运行就一切Ok了，在运行中输入cmd，然 后cd C:\tools\mysql-proxy\share。

4、字符乱码 通过proxy连上数据库之后，查到的字符串始终是乱码，即便手工执行了set names ‘utf8′也没有效果。 解决办法，mysql server必须设置

  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 not connect to MySQL server');
  26. }
  27. } else {
  28. if(!$this->link = @mysql_connect($dbhost, $dbuser, $dbpw)) {
  29. $halt && $this->halt('Can not connect to MySQL server');
  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("SET character_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);
  46. }
  47. }
  48. if($dbname) {
  49. $this->select_db($dbname);
  50. }
  51. }
  53. //连接一个只读的mysql数据库
  54. function connect_ro($dbhost, $dbuser, $dbpw, $dbname = '', $pconnect = 0){
  55. if($this->link_rw == null)
  56. $this->link_rw = $this->link;
  57. $this->link = null;
  58. //不产生halt错误
  59. $this->connect($dbhost, $dbuser, $dbpw, $dbname, $pconnect, false);
  60. if($this->link){
  61. //连接成功
  62. //echo "link ro sussess!
    ";
  63. $this->ro_exist = true;
  64. $this->link_ro = $this->link;
  65. if($this->cur_db){
  66. //如果已经选择过数据库则需要操作一次
  67. @mysql_select_db($this->cur_db, $this->link_ro);
  68. }
  69. }else{
  70. //连接失败
  71. //echo "link ro failed!
    ";
  72. $this->link = &$this->link_rw;
  73. }
  74. }
  76. //设置一系列只读数据库并且连接其中一个
  77. function set_ro_list($ro_list){
  78. if(is_array($ro_list)){
  79. //随机选择其中一个
  80. $link_ro = $ro_list[array_rand($ro_list)];
  81. $this->connect_ro($link_ro['dbhost'], $link_ro['dbuser'], $link_ro['dbpw']);
  82. }
  83. }
  85. function select_db($dbname) {
  86. //同时操作两个数据库连接
  87. $this->cur_db = $dbname;
  88. if($this->ro_exist){
  89. @mysql_select_db($dbname, $this->link_ro);
  90. }
  91. return @mysql_select_db($dbname, $this->link_rw);
  92. }
  94. function fetch_array($query, $result_type = MYSQL_ASSOC) {
  95. return mysql_fetch_array($query, $result_type);
  96. }
  98. function fetch_one_array($sql, $type = '') {
  99. $qr = $this->query($sql, $type);
  100. return $this->fetch_array($qr);
  101. }
  103. function query($sql, $type = '') {
  104. $this->link = &$this->link_rw;
  105. //判断是否select语句
  106. if($this->ro_exist && preg_match ("/^(\s*)select/i", $sql)){
  107. $this->link = &$this->link_ro;
  108. }
  109. $func = $type == 'UNBUFFERED' && @function_exists('mysql_unbuffered_query') ?
  110. 'mysql_unbuffered_query' : 'mysql_query';
  111. if(!($query = $func($sql, $this->link)) && $type != 'SILENT') {
  112. $this->halt('MySQL Query Error', $sql);
  113. }
  114. $this->querynum++;
  115. return $query;
  116. }
  118. function affected_rows() {
  119. return mysql_affected_rows($this->link);
  120. }
  122. function error() {
  123. return (($this->link) ? mysql_error($this->link) : mysql_error());
  124. }
  126. function errno() {
  127. return intval(($this->link) ? mysql_errno($this->link) : mysql_errno());
  128. }
  130. function result($query, $row) {
  131. $query = @mysql_result($query, $row);
  132. return $query;
  133. }
  135. function num_rows($query) {
  136. $query = mysql_num_rows($query);
  137. return $query;
  138. }
  140. function num_fields($query) {
  141. return mysql_num_fields($query);
  142. }
  144. function free_result($query) {
  145. return mysql_free_result($query);
  146. }
  148. function insert_id() {
  149. return ($id = mysql_insert_id($this->link)) >= 0 ? $id : $this->result($this->query("SELECT last_insert_id()"), 0);
  150. }
  152. function fetch_row($query) {
  153. $query = mysql_fetch_row($query);
  154. return $query;
  155. }
  157. function fetch_fields($query) {
  158. return mysql_fetch_field($query);
  159. }
  161. function version() {
  162. return mysql_get_server_info($this->link);
  163. }
  165. function close() {
  166. return mysql_close($this->link);
  167. }
  169. function halt($message = '', $sql = '') {
  170. $dberror = $this->error();
  171. $dberrno = $this->errno();
  172. echo "
  173. MySQL Error
  174. Message: $message
  175. SQL: $sql
  176. Error: $dberror
  177. Errno.: $dberrno
";
  • exit();
  • }
  • }
  • ?>
    • 复制代码

    调用示例：

    2. /****************************************
    3. *** mysql-rw-php version 0.1
    4. *** http://bbs.it-home.org
    5. *** http://code.google.com/p/mysql-rw-php/
    6. *** code modify from class_mysql.php (uchome)
    7. ****************************************/
    9. require_once('mysql_rw_php.class.php');
    11. //rw info
    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 = new mysql_rw_php;
    29. //connect Master
    30. $DB->connect($db_rw[dbhost], $db_rw[dbuser], $db_rw[dbpw], $db_rw[dbname]);
    32. //Method 1: connect one server
    33. $DB->connect_ro($db_ro[0][dbhost], $db_ro[0][dbuser], $db_ro[0][dbpw]);
    35. //Method 2: connect one server from a list by rand
    36. $DB->set_ro_list($db_ro);
    38. //send to rw
    39. $sql = "insert into a set a='test'";
    40. $DB->query($sql);
    42. //send to ro
    43. $sql = "select * from a";
    44. $qr = $DB->query($sql);
    45. while($row = $DB->fetch_array($qr)){
    46. echo $row[a];
    47. }
    48. ?>
    复制代码
    相关标签： mysql Proxy读写分离配置与php mysql读写分离类

    上一篇： PHP生成随机密码的4种方法及性能对比

    下一篇： 浅谈 秒间隔 核心架构设计

    推荐阅读