MySQL学习笔记之十：使用mysql-proxy实现MySQL读写分离

MySQL读写分离是指让master处理写操作，让slave处理读操作，非常适用于读操作量比较大的场景，可减轻master的压力。

本文使用mysql-proxy实现mysql的读写分离，mysql-proxy实际上是作为后端mysql主从服务器的代理，它直接接受客户端的请求，对SQL语句进行分析，判断出是读操作还是写操作，然后分发至对应的mysql服务器上。对于多节点slave集群，还可以起到负载均衡的效果。

一、准备实验环境

MySQL的主从复制架构搭建详见http://9124573.blog.51cto.com/9114573/1785454

二、安装配置mysql-proxy

1、这里下载的mysql-proxy版本为mysql-proxy-0.8.5-linux-glibc2.3-x86-64bit.tar.gz

# tar xf mysql-proxy-0.8.5-linux-glibc2.3-x86-64bit.tar.gz -C /usr/local

# cd /usr/local

# ln -sv mysql-proxy-0.8.5-linux-glibc2.3-x86-64bit mysql-proxy

# useradd -r mysql-proxy

[[email protected] ~]# tar xf mysql-proxy-0.8.5-linux-glibc2.3-x86-64bit.tar.gz -C /usr/local/
[[email protected] ~]# ln -s /usr/local/mysql-proxy-0.8.5-linux-glibc2.3-x86-64bit /usr/local/mysql-proxy
[[email protected] ~]# cd /usr/local/mysql-proxy
[[email protected] mysql-proxy]# ls
bin  include  lib  libexec  licenses  share
[[email protected] mysql-proxy]# ls bin
mysql-binlog-dump  mysql-myisam-dump  mysql-proxy
[[email protected] mysql-proxy]# ls share/doc/mysql-proxy/
active-queries.lua       commit-obfuscator.lua  README              tutorial-constants.lua  tutorial-prep-stmts.lua  tutorial-scramble.lua  xtab.lua
active-transactions.lua  commit-obfuscator.msc  ro-balance.lua      tutorial-inject.lua     tutorial-query-time.lua  tutorial-states.lua
admin-sql.lua            COPYING                ro-pooling.lua      tutorial-keepalive.lua  tutorial-resultset.lua   tutorial-tokenize.lua
analyze-query.lua        histogram.lua          rw-splitting.lua    tutorial-monitor.lua    tutorial-rewrite.lua     tutorial-union.lua
auditing.lua             load-multi.lua         tutorial-basic.lua  tutorial-packets.lua    tutorial-routing.lua     tutorial-warnings.lua
[[email protected] mysql-proxy]# useradd -r mysql-proxy

2、为mysql-proxy提供SysV服务脚本

# vim /etc/rc.d/init.d/mysql-proxy

...(内容略）

# chmod +x /etc/rc.d/init.d/mysql-proxy

# chkconfig --add mysql-proxy

[[email protected] ~]# vim /etc/rc.d/init.d/mysql-proxy
...
[[email protected] ~]# chmod +x !$
chmod +x /etc/rc.d/init.d/mysql-proxy
[[email protected] ~]# chkconfig --add mysql-proxy

3、为服务脚本提供配置文件/etc/sysconfig/mysql-proxy，内容如下所示：

# Options for mysql-proxy

ADMIN_USER="admin"   #mysql-proxy的管理账号

ADMIN_PASSWORD="admin"

ADMIN_ADDRESS=""

ADMIN_LUA_SCRIPT="/usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua"   #完成mysql-proxy管理功能的脚本

PROXY_ADDRESS=""

PROXY_USER="mysql-proxy"   #以什么身份运行mysql-proxy

PROXY_OPTIONS="--daemon --log-level=info --log-use-syslog"

其中最后一行，需要按实际场景进行修改，例如：

PROXY_OPTIONS="--daemon --log-level=info --log-use-syslog --plugins=proxy --plugins=admin --proxy-backend-addresses=192.168.30.10:3306 --proxy-read-only-backend-addresses=192.168.30.20:3306 --proxy-lua-script=/usr/local/mysql-proxy/share/doc/mysql-proxy/rw-splitting.lua"

其中的proxy-backend-addresses选项和proxy-read-only-backend-addresses选项均可重复使用多次，以实现指定多个读写服务器或只读服务器;

rw-splitting.lua是实现读写分离功能的脚本文件

[[email protected] ~]# vim /etc/sysconfig/mysql-proxy

# Options for mysql-proxy
ADMIN_USER="admin"
ADMIN_PASSWORD="admin"
ADMIN_ADDRESS=""
ADMIN_LUA_SCRIPT="/usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua"
PROXY_ADDRESS=""
PROXY_USER="mysql-proxy"
PROXY_OPTIONS="--daemon --log-level=info --log-use-syslog --plugins=proxy --plugins=admin --proxy-backend-addresses=192.168.30.10:3306 --proxy-read-only-backend-addresses=192.168.30.20:3306 --proxy-lua-script=/usr/local/mysql-proxy/share/doc/mysql-proxy/rw-splitting.lua"

4、mysql-proxy命令的配置选项

我们也可使用mysql-proxy命令启动服务进程，其配置选项大致可分为帮助选项、管理选项、代理选项及应用程序选项几类：

--help

--help-admin

--help-proxy

--help-all   #以上四个选项均用于获取帮助信息；

--proxy-address=host:port   #代理服务监听的地址和端口

--admin-address=host:port   #管理模块监听的地址和端口，默认为0.0.0.0:4041

--proxy-backend-addresses=host:port   #后端读写mysql服务器的地址和端口；

--proxy-read-only-backend-addresses=host:port   #后端只读mysql服务器的地址和端口；

--proxy-lua-script=file_name   #完成mysql代理功能的Lua脚本；

--daemon   #以守护进程模式启动mysql-proxy；

--keepalive   #在mysql-proxy崩溃时尝试重启之；

--log-file=/path/to/log_file_name   #日志文件名称；

--log-level=level   #日志级别；

--log-use-syslog   #基于syslog记录日志；

--plugins=plugin,..   #在mysql-proxy启动时加载的插件；

--user=user_name   #运行mysql-proxy进程的用户；

--defaults-file=/path/to/conf_file_name   #默认使用的配置文件路径；其配置段使用[mysql-proxy]标识；

--proxy-skip-profiling   #禁用profile；

--pid-file=/path/to/pid_file_name   #进程文件名；

5、创建admin.lua文件，将其保存至/usr/local/mysql-proxy/share/doc/mysql-proxy/目录中（略）

[[email protected] ~]# vim /usr/local/mysql-proxy/share/doc/mysql-proxy/admin.lua
...

6、启动mysql-proxy

service mysql-proxy start

网上都说mysql-proxy默认的代理服务端口是4040，本例中为3306，没有查到原因，有可能是新版本所做的更改；如果想使用其它端口，使用选项--proxy-address修改即可；

[[email protected] ~]# service mysql-proxy start
Starting /usr/local/mysql-proxy/bin/mysql-proxy:           [  OK  ]
[[email protected] ~]# netstat -tanp
...
tcp        0      0 0.0.0.0:4041                0.0.0.0:*                   LISTEN      52446/mysql-proxy   
tcp        0      0 0.0.0.0:3306                0.0.0.0:*                   LISTEN      52446/mysql-proxy

7、管理mysql-proxy

mysql -u admin -h 192.168.30.14 -P 4041 -p
      mysql> select * from backends;   #查看后端mysql服务器状态

[[email protected] ~]# mysql -u admin -h 192.168.30.14 -P 4041 -p
Enter password: 
ERROR 1045 (28000): password doesn‘t match
[[email protected] ~]# mysql -u admin -h 192.168.30.14 -P 4041 -p
Enter password: 
...
mysql> select * from backends;
+-------------+--------------------+-------+------+------+-------------------+
| backend_ndx | address            | state | type | uuid | connected_clients |
+-------------+--------------------+-------+------+------+-------------------+
|           1 | 192.168.30.10:3306 | up    | rw   | NULL |                 0 |
|           2 | 192.168.30.20:3306 | up    | ro   | NULL |                 0 |
+-------------+--------------------+-------+------+------+-------------------+
2 rows in set (0.00 sec)

三、测试

1、在主库上创建一个用户

grant select,insert,create,delete on *.* to [email protected]‘192.168.30.%‘ identified by ‘proxypass‘;

flush privileges;

该操作会同步到从节点，故无需再在从库上创建

2、准备抓包

# tcpdump -i eth0 -nn -XX ip dst host 192.168.30.10 and tcp dst port 3306

# tcpdump -i eth0 -nn -XX ip dst host 192.168.30.20 and tcp dst port 3306

3、连接mysql-proxy，进行读、写等操作

mysql -u proxytest -h 192.168.30.14 -P 3306 -p

经过测试发现：

所有写请求都被分发到主库，所有读请求被分发到从库；

从库不在线时，读请求被发往主库

时间： 2024-10-01 01:40:59

MySQL学习笔记之十：使用mysql-proxy实现MySQL读写分离的相关文章

linux学习笔记-第十九课-LAMP之 mysql （四）

mysql日常操作指令 1 )mysql管理员密码的更改,mysql安装完毕后,管理员root的密码默认为空,需要进行修改 格式 :mysqladmin -u root password '新密码' 示例 : [[email protected] ~]# mysqladmin -u root password '123456' [[email protected] ~]# mysql -u root -p # 这时候就需要使用密码登陆mysql Enter password:          

mysql学习笔记之十六（数据库维护）

数据备份 数据损失原因:存储介质鼓掌,用户操作错误(误删除整个数据库),服务器彻底瘫痪 1.文件复制 需要先停止服务器服务,在停止之前,执行flushtables将所有数据写入到数据文件,停止之后,将数据文件拷贝到其他地方 只适合MyISAM存储引擎,对其他引擎并不合适 2.mysqldump mysqldump将包含数据的表结构和数据内容保存在相应的文本文件.具体执行时,首先检查备份数据的表结构,在相应的文本文件中生成create语句.然后检查数据内容,在相应的文本文件中生成insert in

Java框架spring Boot学习笔记（十六）：操作MySQL数据库

新建一个工程,添加对数据库的支持 下载mysql驱动包 mysql-connector-java-5.1.7-bin.jar,快捷键ctrl+alt+shift+s,添加jar包到工程 编写测试文JdbcTemplateDemo.java 1 package com.jdbc; 2 3 import org.junit.Test; 4 import org.springframework.jdbc.core.JdbcTemplate; 5 import org.springframework.j

Mysql学习笔记（十二）触发器

学习内容: 1.触发器: 什么是触发器?我们什么时候能够使用触发器?   触发器就是用来监听某个表的变化,当这个表发生变化的时候来触发某种操作..比若说两个表是相互关联的,当我们在对其中一个表格进行操作的同时,另一个表内的数据也需要进行某种操作,那么我们就需要建立一个触发器来监听任何一个表发生的变化,当其中一个表的数据发生变化的同时,触发器里的代码块将会对另一个表格进行对数据的某种操作.. 总而言之,触发器一般是使用在表与表之间的,单个的表建立触发器是没有任何的意义的.... 触发器的监听范围:

Mysql学习笔记（十）存储过程与函数 + 知识点补充（having与where的区别）

学习内容:存储程序与函数...这一章学的我是云里雾里的... 1.存储过程...   Mysql存储过程是从mysql 5.0开始增加的一个新功能.存储过程的优点其实有很多,不过我觉得存储过程最重要的优点就是实现了SQL代码的封装,那么我们为什么需要封装SQL语句呢?原因就是当我们在面对一个庞大的数据库的时候,当我们使用外部程序去访问数据库的时候...我们总不能在外部程序中内嵌很多的SQL语句吧...那样执行的效率不高,并且也不容易维护...因此存储过程将我们的操作进行封装,当我们需要对其进行操

一千行MySQL学习笔记（十二）

/* 用户和权限管理 */ ----------- 用户信息表:mysql.user -- 刷新权限FLUSH PRIVILEGES -- 增加用户CREATE USER 用户名 IDENTIFIED BY [PASSWORD] 密码(字符串)- 必须拥有mysql数据库的全局CREATE USER权限,或拥有INSERT权限.- 只能创建用户,不能赋予权限.- 用户名,注意引号:如 'user_name'@'192.168.1.1'- 密码也需引号,纯数字密码也要加引号- 要在纯文本中指定密码

mysql学习笔记之十（mysql运算符）

mysql提供的运算符包含算术运算符,比较运算符,逻辑运算符和位运算符. 算数运算符 包含:+ - * / % 1.获取各种算数运算后的结果 select 6+4 '加法', 6-4 '减法', 6*4 '乘法', 6/4 '除法', 6 div 4 '除法', 6%4 '求模', 6 mod 4 '求模'; +--+--+--+--–+--+--+--+ | 加法 | 减法 | 乘法 | 除法 | 除法 | 求模 | 求模 | +--+--+--+--–+--+--+--+ | 10 | 2

mysql学习笔记之十四（安全性机制）

root和普通用户 权限机制 mysql系统数据库 show databases; use mysql; show tables; +---------------------------+ | Tables_in_mysql | +---------------------------+ | columns_priv | | db | | func | | help_category | | help_keyword | | help_relation | | help_topic | | h

mysql学习笔记之十二（存储过程和函数）

存储过程和函数,一种数据库对象,用来实现将一组关于表操作的SQL语句代码当做一个整体来执行,也是与数据库对象表关联最紧密的数据库对象.在数据库系统中,当调用存储过程和函数时,则会执行这些对象中所设置的sql语句组从而实现相应的功能. 一.存储过程和函数的相关概念 针对表的一个完整操作往往不是单条sql语句就可以实现,而是需要一组sql语句来实现. 例: 为了购买商品的订单处理: (1)在生成订单之前,首先需要查看商品库存中是否有相应的商品 (2)如果库存中存在相应的商品,按着需要预定商品以便不将