Mysql 基于 Amoeba 的读写分离

sxyzy · 发表于 2018-10-10 08:19:13

　　首先说明一下amoeba 跟 MySQL proxy在读写分离的使用上面的区别：
　　在MySQL proxy 6.0版本上面如果想要读写分离并且读集群、写集群机器比较多情况下，用mysql proxy 需要相当大的工作量，目前mysql proxy没有现成的 lua脚本。mysql proxy根本没有配置文件， lua脚本就是它的全部，当然lua是相当方便的。那么同样这种东西需要编写大量的脚本才能完成一个复杂的配置。而Amoeba只需要进行相关的配置就可以满足需求。

　　假设有这样的使用场景，有三个数据库节点分别命名为Master、Slave1、Slave2如下：
　　Amoeba: Amoeba
　　Master： Master （可读写）
　　Slaves：Slave1 、Slave2 （2个平等的数据库。只读/负载均衡）
　　在主从数据库的复制的部分，任然需要使用数据库自己的复制机制。 Amoeba 不提供复制功能。
　　1. 起动数据库的主从复制功能。
　　a. 修改配置文件
　　master.cnf
　　Cnf代码

　　server-id = 1 #主数据库标志
　　# 增加日志文件，用于验证读写分离
　　log = /home/mysql/mysql/log/mysql.log

　　slave1.cnf
　　Cnf代码

　　server-id = 2
　　# 增加日志文件，用于验证读写分离
　　log = /home/mysql/mysql/log/mysql.log

　　slave2.cnf
　　Cnf代码

　　server-id = 3
　　# 增加日志文件，用于验证读写分离
　　log = /home/mysql/mysql/log/mysql.log

　　b. Master 中创建两个只读权限的用户。用户名均为：repl_user 密码均为：copy 分别开放给 slave1， slave2
　　Sql代码

　　mysql> grant replication slave on *.* to repl_user@192.168.14.132 identified by 'copy';
　　mysql> grant replication slave on *.* to repl_user@192.168.14.133 identified by 'copy';

　　c. 查看 Master 信息
　　Sql代码

　　mysql> show master status;
　　+------------------+----------+--------------+------------------+
　　| File | Position | Binlog_Do_DB | Binlog_Ignore_DB |
　　+------------------+----------+--------------+------------------+
　　| mysql-bin.000017 | 2009 | | |
　　+------------------+----------+--------------+------------------+
　　1 row in set (0.00 sec)

　　d. Slave1 ，Slave2 中启动 Master - Slave 复制功能。
　　分别执行以下命令
　　Sql代码

　　mysql> slave stop;
　　Query OK, 0 rows affected (0.02 sec)
　　mysql> change master to
　　-> master_host='192.168.14.131',
　　-> master_user='repl_user',
　　-> master_password='copy',
　　-> master_log_file='mysql-bin.000017',
　　-> master_log_pos=2009;
　　Query OK, 0 rows affected (0.03 sec)
　　mysql> start slave;
　　Query OK, 0 rows affected (0.00 sec)

　　2. Amoeba 读写分离的配置
　　a. Master ， Slave1 ，Slave2 中开放权限给 Amoeba 访问。
　　在 Master ， Slave1 ， Slave2 中分别执行
　　Sql代码

　　mysql> grant all on test.* to test_user@192.168.14.129 indentified by '1234';

　　Amoeba 访问三个数据库的账号密码相同。
　　b. 修改 Amoeba 的配置文件
　　配置文件详细说明请查看官方文档：http://docs.hexnova.com/amoeba/rw-splitting.html
　　dbServer.xml
　　Xml代码

　　
　　
　　
　　
　　
　　
　　
　　${defaultManager}
　　64
　　128
　　
　　3306
　　
　　test
　　
　　test_user
　　
　　1234
　　
　　
　　500
　　500
　　10
　　600000
　　600000
　　true
　　true
　　
　　
　　
　　
　　
　　
　　192.168.14.131
　　
　　
　　
　　
　　
　　192.168.14.132
　　
　　
　　
　　
　　
　　192.168.14.133
　　
　　
　　
　　
　　
　　
　　1
　　
　　slave1,slave2

　　amoeba.xml
　　Xml代码

　　
　　
　　
　　
　　
　　
　　
　　8066
　　
　　
　　${clientConnectioneManager}
　　
　　
　　128
　　64
　　
　　
　　
　　
　　
　　root
　　root
　　
　　
　　${amoeba.home}/conf/access_list.conf
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　
　　127.0.0.1
　　true
　　${clientConnectioneManager}
　　
　　
　　
　　
　　
　　
　　20
　　
　　30
　　
　　30
　　
　　500
　　
　　60
　　
　　
　　
　　
　　
　　com.meidusa.amoeba.net.ConnectionManager
　　
　　
　　
　　com.meidusa.amoeba.net.AuthingableConnectionManager
　　
　　
　　
　　
　　
　　${amoeba.home}/conf/dbServers.xml
　　
　　
　　
　　
　　${amoeba.home}/conf/rule.xml
　　${amoeba.home}/conf/ruleFunctionMap.xml
　　
　　
　　${amoeba.home}/conf/functionMap.xml
　　1500
　　
　　master
　　
　　master
　　
　　slaves
　　true

　　rule.xml
　　Java代码

　　不需要数据库分片时，不用配置。但是不能没有 tableRule 元素，否则报错。随便写个空规则就行了。
　　3. 测试读写分离
　　a. 在 Master ， Slave1 ， Slave2 中分别查看日志文件： mysql.log
　　Shell代码

　　tail -f ./log/mysql.log

　　b. 启动 Amoeba，使用 Mysql GUI Tools 连接 Amoeba

　　执行以上几个命令。查看日志内容。
　　Master mysql.log
　　Shell代码

　　[mysql@prx1 mysql]$ tail -f log/mysql.log
　　370 Query SET SESSION sql_mode=''
　　370 Query SET NAMES utf8
　　370 Query SHOW FULL TABLES
　　370 Query SHOW COLUMNS FROM `t_message`
　　370 Query SHOW COLUMNS FROM `t_user`
　　370 Query SHOW PROCEDURE STATUS
　　370 Query SHOW FUNCTION STATUS
　　110813 15:21:11 370 Query SHOW VARIABLES LIKE 'character_set_server'
　　370 Query SHOW FULL COLUMNS FROM `test`.`t_message`
　　110813 15:21:12 370 Query SHOW CREATE TABLE `test`.`t_message`
　　110813 15:22:40 374 Connect test_user@192.168.14.129 on test
　　375 Connect test_user@192.168.14.129 on test
　　376 Connect test_user@192.168.14.129 on test
　　110813 15:23:40 370 Query insert into t_message values(1, 'c1')
　　110813 15:24:07 377 Connect test_user@192.168.14.129 on test
　　378 Connect test_user@192.168.14.129 on test
　　379 Connect test_user@192.168.14.129 on test
　　110813 15:24:15 370 Query insert into t_user values(8, 'n8', 'p8')
　　110813 15:24:24 370 Query SHOW FULL COLUMNS FROM `test`.`t_user`
　　370 Query SHOW CREATE TABLE `test`.`t_user`
　　110813 15:24:35 370 Query SHOW FULL COLUMNS FROM `test`.`t_message`
　　370 Query SHOW CREATE TABLE `test`.`t_message`

　　Slave1 mysql.log
　　Shell代码

　　[mysql@prx2 mysql]$ tail -f log/mysql.log
　　317 Connect test_user@192.168.14.129 on test
　　318 Connect test_user@192.168.14.129 on test
　　110813 15:35:30 315 Query SELECT @@sql_mode
　　110813 15:35:32 315 Query SELECT @@sql_mode
　　110813 15:35:44 315 Query SELECT @@SQL_MODE
　　110813 15:35:46 315 Query SELECT @@SQL_MODE
　　110813 15:37:18 319 Connect test_user@192.168.14.129 on test
　　320 Connect test_user@192.168.14.129 on test
　　110813 15:37:19 321 Connect test_user@192.168.14.129 on test
　　110813 15:37:26 246 Quit
　　110813 15:38:21 315 Query SELECT @@SQL_MODE
　　110813 15:38:22 42 Query BEGIN
　　42 Query insert into t_message values(1, 'c1')
　　42 Query COMMIT /* implicit, from Xid_log_event */
　　110813 15:38:50 322 Connect test_user@192.168.14.129 on test
　　323 Connect test_user@192.168.14.129 on test
　　324 Connect test_user@192.168.14.129 on test
　　110813 15:38:58 42 Query BEGIN
　　42 Query insert into t_user values(8, 'n8', 'p8')
　　42 Query COMMIT /* implicit, from Xid_log_event */
　　110813 15:39:08 315 Query SELECT @@SQL_MODE
　　110813 15:39:19 315 Query SELECT @@SQL_MODE
　　110813 15:44:08 325 Connect test_user@192.168.14.129 on test
　　326 Connect test_user@192.168.14.129 on test
　　327 Connect test_user@192.168.14.129 on test

　　Slave2 mysql.log
　　Shell代码

　　[mysql@prx3 mysql]$ tail -f log/mysql.log
　　110813 15:35:08 305 Connect test_user@192.168.14.129 on test
　　306 Connect test_user@192.168.14.129 on test
　　307 Connect test_user@192.168.14.129 on test
　　110813 15:35:31 304 Query SELECT @@sql_mode
　　304 Query SELECT @@sql_mode
　　110813 15:35:44 304 Query SELECT @@SQL_MODE
　　110813 15:35:46 304 Query SELECT * FROM t_message t
　　110813 15:37:18 308 Connect test_user@192.168.14.129 on test
　　309 Connect test_user@192.168.14.129 on test
　　310 Connect test_user@192.168.14.129 on test
　　110813 15:38:21 8 Query BEGIN
　　8 Query insert into t_message values(1, 'c1')
　　8 Query COMMIT /* implicit, from Xid_log_event */
　　110813 15:38:50 311 Connect test_user@192.168.14.129 on test
　　312 Connect test_user@192.168.14.129 on test
　　313 Connect test_user@192.168.14.129 on test
　　110813 15:38:58 304 Query SELECT @@SQL_MODE
　　8 Query BEGIN
　　8 Query insert into t_user values(8, 'n8', 'p8')
　　8 Query COMMIT /* implicit, from Xid_log_event */
　　110813 15:39:08 304 Query select * from t_user
　　110813 15:39:19 304 Query select * from t_message
　　110813 15:44:08 314 Connect test_user@192.168.14.129 on test
　　315 Connect test_user@192.168.14.129 on test
　　316 Connect test_user@192.168.14.129 on test

　　从日志中可以看出。
　　在 Master mysql.log 中，只执行了 insert into 命令。
　　在 Slave1 中，只是复制了 insert into 命令，是主从复制的结果
　　在 Slave2 中，复制了 insert into 命令，同时还执行了 select 命令。
　　说明，主从分离已经成功。
　　转自:http://www.iteye.com/topic/1113437

账号		自动登录	找回密码
密码			立即注册

wirelessnetview好用的无线分析工具

亿图图示专家(EDraw Max) V7.9 中文破解版

zabbix3.4.1安装部署+微信推送信息+大屏显

Red Hat OpenShift I: Containers & Kubern

2025 年，C++ 还能“硬核”多久？

RH199 RHCSA Rapid Track

Red Hat RHCE 8 (EX294) Cert Guide

[经验分享] Mysql 基于 Amoeba 的读写分离

浏览过的版块

扫码加入运维网微信交流群

[经验分享] Mysql 基于 Amoeba 的 读写分离

浏览过的版块

[经验分享] Mysql 基于 Amoeba 的读写分离