Amoeba搞定mysql主从读写分离

时间 2019-12-15

原文原文链接

一个简单完整的 Mysql 主从复制，读写分离的示意图。java

1. 首先搭建 Mysql 主从架构，实现将 mater 数据自动复制到 slavemysql

MySQL 复制的工做方式很简单，一台服务器做为主机，一台或多台服务器做为从机。主机会把数据库的变化记录到日志。一旦这些变化被记录到日志，就会马上（或者以设定的时间间隔）被送到从机。sql

使用MySQL 复制提供扩展大型网站的能力，这些大型网站的数据库主要是读操做(SELECTs)。从机用於复制主机的銷秏是不多的（一般每一个从机1%的开销），在大型网站中每一个主机部署30 个从机也是常见的。数据库

异步复制与同步复制服务器

异步复制：MySQL自己支持单向的、异步的复制。异步复制意味着在把数据从一台机器拷贝到另外一台机器时有一个延时 – 最重要的是这意味着当应用系统的事务提交已经确认时数据并不能在同一时刻拷贝/应用到从机。一般这个延时是由网络带宽、资源可用性和系统负载决定的。然而，使用正确的组件而且调优，复制能作到接近瞬时完成。网络

同步复制：同步复制能够定义为数据在同一时刻被提交到一台或多台机器，一般这是经过众所周知的“两阶段提交”作到的。虽然这确实给你在多系统中保持一致性，但也因为增长了额外的消息交换而形成性能降低。架构

使用MyISAM或者InnoDB存储引擎的MySQL自己并不支持同步复制，然而有些技术，例如分布式复制块设备（简称DRBD），能够在下层的文件系统提供同步复制，容许第二个MySQL服务器在主服务器丢失的状况下接管（使用第二服务器的复本）。要了解更多信息，请参见：http://www.drbd.org/异步

异步复制方案：分布式

1. Mysql 数据库安装性能

安装过程省略：详细参见：http://pengranxiang.iteye.com/admin/blogs/1138059

服务器 Master ：192.168.14.131

Mysql 安装目录： /home/mysql/mysql （使用源码安装，独立目录）

服务器 Slave ：192.168.14.132

Mysql 安装目录：/home/mysql/mysql

2. 修改配置

为了避免影响原来的配置文件： /etc/my.cnf

建立新的配置文件，

cp /etc/my.cnf /home/mysql/mysql/conf/master.cnf

cp /etc/my.cnf /home/mysql/mysql/conf/slave.cnf

修改 master.cnf，增长下面的设置，

（官方说明：为了使用事务的InnoDB在复制中最大的持久性和一致性，你应该指定innodb_flush_log_at_trx_commit=1,sync_binlog=1选项。）

Cnf代码

log-bin=mysql-bin #slave会基于此log-bin来作replication
server-id=1 #master的标示
innodb_flush_log_at_trx_commit=1
sync_binlog=1

修改 slave.cnf

Cnf代码

[mysqld]
server-id=2 #slave的标示

3. 启动服务

Cnf代码

# Master
# 若是 Mysql 已启动，先关掉。
/home/mysql/mysql/bin/mysqladmin -u root -p shutdown
# 使用修改过的 master.cnf 启动 mysql
/home/mysql/mysql/bin/mysqld_safe --defaults-file=/home/mysql/mysql/conf/master.cnf &

Java代码

# Slave
# 若是 Mysql 已启动，先关掉。
/home/mysql/mysql/bin/mysqladmin -u root -p shutdown
# 使用修改过的 slave.cnf 启动 mysql
/home/mysql/mysql/bin/mysqld_safe --defaults-file=/home/mysql/mysql/conf/slave.cnf &

4. 在 Master 上建立一个专门用于复制的帐号 repl_user

5. 启动主从复制功能

须要查看 Master 中的 Master status

mysql> show master status;

而后再 Slave 中，启动复制

上面窗口是链接 Master ，下面窗口链接 Slave

6. 测试复制

在 Master 中插入一条数据，而后在 Slave 中查询。能够验证。

2 简单的读写分离实现

读写分离能够直接在客户端实现，也能够经过代理服务器实现。

代理服务器通常能够选择：

官方的：mysql proxy 地址：http://dev.mysql.com/downloads/mysql-proxy/#downloads

国产开源项目：amoeba

Amoeba开发者博客: http://amoeba.meidusa.com

Amoeba开源项目地址: http://www.sourceforge.net/projects/amoeba
amoeba 中文文档下载地址：http://amoeba.meidusa.com/amoeba.pdf

这里只演示最简单的方案： JDBC 直接实现读写分离。

Java代码

package prx.dao;
import java.sql.Connection;
import java.sql.ResultSet;
import java.util.Properties;
import com.mysql.jdbc.ReplicationDriver;
public class Test {
public static void main(String[] args) throws Exception {
ReplicationDriver driver = new ReplicationDriver();
Properties props = new Properties();
// We want this for failover on the slaves
props.put("autoReconnect", "true");
// We want to load balance between the slaves
props.put("roundRobinLoadBalance", "true");
props.put("user", "foo");
props.put("password", "bar");
//
// Looks like a normal MySQL JDBC url, with a
// comma-separated list of hosts, the first
// being the 'master', the rest being any number
// of slaves that the driver will load balance against
//
Connection conn = driver.connect(
"jdbc:mysql://master,slave1,slave2,slave3/test", props);
//
// Perform read/write work on the master
// by setting the read-only flag to "false"
//
// 经过 conn 的 readOnly 是否为 true 来判断，要取 connection 链接的数据库是主数据库，仍是从数据库
// false 为主数据库的链接
// true 为从数据库的链接
conn.setReadOnly(false);
conn.setAutoCommit(false);
conn.createStatement().executeUpdate("UPDATE some_table ....");
conn.commit();
//
// Now, do a query from a slave, the driver automatically picks one
// from the list
//
conn.setReadOnly(true);
ResultSet rs = conn.createStatement().executeQuery(
"SELECT a,b FROM alt_table");
}
}