C#_MySql 主从复制

1、业务发展驱动数据发展

　　随着网站业务的不断发展，用户量的不断增长，数据量成倍地增加，数据库的访问量也呈线性地增加。特别是在用户访问高峰期间，并发访问量忽然增大，数据库的负载压力也会增大，若是架构方案不够健壮，那么数据库服务器颇有可能在高并发访问负载压力下宕机，形成数据访问服务的失效，从而致使网站的业务中断，给公司和用户形成双重损失。那么，有木有一种方案可以解决此问题，使得数据库再也不由于负载压力太高而成为网站的瓶颈呢？答案确定是有的。

　　目前，大部分的主流关系型数据库都提供了主从热备功能，经过配置两台（或多台）数据库的主从关系，能够将一台数据库服务器的数据更新同步到另外一台服务器上。网站能够利用数据库的这一功能，实现数据库的读写分离，从而改善数据库的负载压力。

　　利用数据库的读写分离，Web服务器在写数据的时候，访问主数据库（Master），主数据库经过主从复制机制将数据更新同步到从数据库（Slave），这样当Web服务器读数据的时候，就能够经过从数据库得到数据。这一方案使得在大量读操做的Web应用能够轻松地读取数据，而主数据库也只会承受少许的写入操做，还能够实现数据热备份，可谓是一箭双雕的方案。

2、MySQL数据复制原理

　　刚刚咱们了解了关系型数据库的读写分离可以实现数据库的主从架构，那么主从架构中最重要的数据复制又是怎么一回事呢？MySQL做为最流行的关系型数据库之一，经过了解MySQL的数据复制流程，会使得咱们对主从复制的认知会有必定的帮助。

　　从上图来看，总体上有以下三个步凑：

　　（1）Master将改变记录到二进制日志(binary log)中（这些记录叫作二进制日志事件，binary log events）；

　　（2）Slave将Master的二进制日志事件(binary log events)拷贝到它的中继日志(relay log)；

PS：从图中能够看出，Slave服务器中有一个I/O线程(I/O Thread)在不停地监听Master的二进制日志(Binary Log)是否有更新：若是没有它会睡眠等待Master产生新的日志事件；若是有新的日志事件(Log Events)，则会将其拷贝至Slave服务器中的中继日志(Relay Log)。

　　（3）Slave重作中继日志(Relay Log)中的事件，将Master上的改变反映到它本身的数据库中。

PS：从图中能够看出，Slave服务器中有一个SQL线程(SQL Thread)从中继日志读取事件，并重作其中的事件从而更新Slave的数据，使其与Master中的数据一致。只要该线程与I/O线程保持一致，中继日志一般会位于OS的缓存中，因此中继日志的开销很小。

3、MySQL主从复制实战

3.1 实验环境总览与准备工做

　　（1）实验环境

　　①服务器环境：本次咱们主要借助VMware Workstation搭建一个三台Windows Server 2003组成的MySQL服务器集群，其中一台做为Master服务器（IP：192.168.80.10），其他两台均做为Slave服务器（IP：192.168.80.11,192.168.80.12）。

　　②客户机环境：本次咱们在Windows 7宿主机（IP：192.168.80.1）编写一个C#控制台程序，对MySQL服务器进行基本的CRUD访问测试。

　　（2）准备工做

　　　　下载MySQL文件：http://dev.mysql.com/downloads/mysql/5.5.html#downloads

　　　　这里咱们选择5.5版本，为了节省时间，直接选择了Archive免安装版本。又因为虚拟机中的Windows Server 2003是32位，因此选择了32-bit的Archive版本进行使用。

　　　　下载完成后，将三个压缩包分别拷贝至Master（IP：192.168.80.10）、Slave1（IP：192.168.80.11）及Slave2（IP：192.168.80.12）中。

3.2 配置MySQL主服务器

　　（1）将MySQL文件拷贝到Master服务器，并解压到一个指定文件夹。这里我放在了：C:\MySQLServer\mysql-5.5.40-win32

　　（2）新建一个配置文件，取名为：my-master.ini，添加如下内容：

 1 [client]  2 port=3306  3 default-character-set=utf8  4  5 [mysqld]  6 port=3306  7  8 #character_set_server=utf8 必定要这样写;  9 character_set_server=utf8 10 11 #解压目录 12 basedir=C:\MySQLServer\mysql-5.5.40-win32 13 14 #解压目录下data目录,必须为data目录 15 datadir=C:\MySQLServer\mysql-5.5.40-win32\data 16 17 #sql_mode=NO_ENGINE_SUBSTITUTION,STRICT_TRANS_TABLES 这个有问题，在建立完新用户登陆时报错 18 sql_mode=NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION 19 20 #主服务器的配置 21 #01.开启二进制日志 22 log-bin=master-bin 23 #02.使用二进制日志的索引文件 24 log-bin-index=master.bin.index 25 #03.为服务器添加惟一的编号 26 server-id=1

　　（3）将my-master.ini传送到Master服务器中mysql所在的文件夹中，并在命令行中将其注册为Windows服务：（这里要转到mysql的bin文件夹中进行操做，由于没有设置环境变量）

　　（4）启动mysql服务，并设为自启动类型；

　　（5）使用root帐号登录mysql，建立一个具备复制权限的用户；（此时root是没有密码的，直接回车便可）

　　（6）在Slave1或Slave2上经过远程登陆Master上的mysql测试新建用户是否能够登陆；

3.3 配置MySQL从服务器

　　（1）同Master服务器，将MySQL文件拷贝解压到指定文件夹下；

　　（2）新建一个配置文件，取名为：my-slave.ini，添加如下内容：

[client] port=3306 default-character-set=utf8 [mysqld] port=3306 #character_set_server=utf8 必定要这样写; character_set_server=utf8 #解压目录 basedir=C:\MySQLServer\mysql-5.5.40-win32 #解压目录下data目录,必须为data目录 datadir=C:\MySQLServer\mysql-5.5.40-win32\data #sql_mode=NO_ENGINE_SUBSTITUTION,STRICT_TRANS_TABLES 这个有问题，在建立完新用户登陆时报错 sql_mode=NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION #从服务器的配置 #01.为服务器添加惟一的编号 server-id=2 #02.开启中继日志 relay-log=slave-relay-log-bin #03.使用中继日志的索引文件 relay-log-index=slave-relay-log-bin.index

PS：这里server-id要确保惟一，咱们这里Master（192.168.80.10）的server-id=1，那么Slave1（192.168.80.11）就设置其server-id=2，Slave2（192.168.80.12）则设置其server-id=3。

　　（3）将my-slave.ini传送到Slave1和Slave2服务器中mysql所在的文件夹中，并在命令行中将其注册为Windows服务：（这里要转到mysql的bin文件夹中进行操做，由于没有设置环境变量）

　　（4）分别启动两台Slave的mysql服务，步凑同master所述；固然，也能够在cmd中输入命令：net start MySQL

　　（5）分别使用两台Slave的root帐号登录mysql，经过指定的语句配置主从关系设置；

　　（6） 为了方便后面的测试，这里咱们在Master上经过root进入mysql，建立一个测试用的数据库和数据表；

　　（7）还要建立一个用户，这个用户具备对全部数据库的增删查改的权限，以便用来进行测试；

3.4 编写C#程序测试主从复制结构

　　（1）下载mysql for .net开发包，添加对mysql.data.dll的引用

　　（2）在控制台程序中写代码访问Master服务器，并查看程序运行结果；

　　①数据库链接部分：

<?xml version="1.0" encoding="utf-8" ?> <configuration> <connectionStrings> <add name="mysqlmaster" connectionString="server=192.168.80.10;database=dbtest;uid=sa;password=123456"/> </connectionStrings> </configuration>

　　②程序代码部分：在程序中首先显示user表内容（这时表是空的），而后会添加5条user信息，其中会修改第3条user信息的name为Edison Chou，最后会删除第5条user信息；

        static void Main(string[] args) { string connStr = ConfigurationManager.ConnectionStrings["mysqlmaster"] .ConnectionString; // 01.Query  ShowUserData(connStr); // 02.Add a user to table for (int i = 0; i < 5; i++) { AddUserData(connStr, "TestUser" + (i + 1).ToString()); } ShowUserData(connStr); // 03.Update a user on table UpdateUserData(connStr, 3, "EdisonChou"); ShowUserData(connStr); // 04.Delete a user from table DeleteUserData(connStr, 5); ShowUserData(connStr); Console.ReadKey(); } #region 01.Func:ShowUserData private static void ShowUserData(string connStr) { using (MySqlConnection con = new MySqlConnection(connStr)) { con.Open(); using (MySqlCommand cmd = con.CreateCommand()) { cmd.CommandText = "select * from user"; using (MySqlDataReader reader = cmd.ExecuteReader()) { if (reader.HasRows) { Console.WriteLine("------------table:user------------"); while (reader.Read()) { Console.WriteLine(reader[0] + "-" + reader[1]); } Console.WriteLine("------------table:user------------"); } } } } } #endregion #region 02.Func:AddUserData private static void AddUserData(string connStr, string userName) { using (MySqlConnection con = new MySqlConnection(connStr)) { con.Open(); using (MySqlCommand cmd = con.CreateCommand()) { cmd.CommandText = "insert into user(name) values('" + userName + "')"; int result = cmd.ExecuteNonQuery(); if (result > 0) { Console.WriteLine("Add User Successfully."); } } } } #endregion #region 03.Func:UpdateUserData private static void UpdateUserData(string connStr, int userId, string userName) { using (MySqlConnection con = new MySqlConnection(connStr)) { con.Open(); using (MySqlCommand cmd = con.CreateCommand()) { cmd.CommandText = "update user set name='" + userName + "' where id=" + userId; int result = cmd.ExecuteNonQuery(); if (result > 0) { Console.WriteLine("Update User Successfully."); } } } } #endregion #region 04.Func:DeleteUserData private static void DeleteUserData(string connStr, int userId) { using (MySqlConnection con = new MySqlConnection(connStr)) { con.Open(); using (MySqlCommand cmd = con.CreateCommand()) { cmd.CommandText = "delete from user where id=" + userId; int result = cmd.ExecuteNonQuery(); if (result > 0) { Console.WriteLine("Delete User Successfully."); } } } } #endregion

View Code

　　③程序运行结果：

　　（3）在Slave1（192.168.80.11）和Slave2（192.168.80.12）上查看user表是否自动进行了数据同步；

　　①首先在Master上查看user表还剩哪些信息？

　　②其次在Slave1上查看user表是否进行了同步：

　　③最后在Slave2上查看user表是否进行了同步：

　　（4）初步尝试读写分离：一主一从模式的一个最简单的实现方式

　　①在Slave1上新建一个只具备读（select）权限的用户，这里取名为reader：

　　　　create user reader;

　　　　grant select on *.* to reader identified by '123456';

　　②新增一个mysqlslave的数据库链接字符串：

    <connectionStrings> <add name="mysqlmaster" connectionString="server=192.168.80.10;database=dbtest;uid=sa;password=123456"/> <add name="mysqlslave" connectionString="server=192.168.80.11;database=dbtest;uid=reader;password=123456"/> </connectionStrings>

　　③新增一个枚举DbCommandType来记录读操做和写操做：

    public enum DbCommandType { Read, Write }

　　④修改读取数据表的代码判断是读操做仍是写操做：

     private static void ShowUserData(DbCommandType commandType) { string connStr = null; if (commandType == DbCommandType.Write) { connStr = ConfigurationManager.ConnectionStrings["mysqlmaster"] .ConnectionString; } else { connStr = ConfigurationManager.ConnectionStrings["mysqlslave"] .ConnectionString; } using (MySqlConnection con = new MySqlConnection(connStr)) { con.Open(); using (MySqlCommand cmd = con.CreateCommand()) { cmd.CommandText = "select * from user"; using (MySqlDataReader reader = cmd.ExecuteReader()) { if (reader.HasRows) { Console.WriteLine("------------table:user------------"); while (reader.Read()) { Console.WriteLine(reader[0] + "-" + reader[1]); } Console.WriteLine("------------table:user------------"); } } } } }

View Code

PS：关于MySQL的读写分离实现，主要有如下几种方式：

一种是基于MySQL-Proxy作调度服务器模式，另外一种是借助阿里巴巴开源项目Amoeba(变形虫)项目实现（这种方式貌似用的比较多），另外呢就是本身写一个相似于哈希算法的程序库来选择目标数据库；

学习小结

　　这次咱们主要简单地学习了主从复制的一些相关概念，了解了MySQL在Windows下搭建主从复制架构的过程，最后经过改变程序方式使得一主一从模式下实现读写分离（虽然是很简单很粗陋的实现）。后续有空时，我会尝试在Linux下借助阿里巴巴开源项目Amoeba搭建真正的MySQL读写分离模式，到时也会将搭建的过程分享出来。虽然，我没有相关的真实实践经验，也有不少人跟我说“你这是在纸上谈兵”，我也知道“纸上得来终觉浅，绝知此事要躬行”，但在没毕业以前，我仍是会作一些相关的初步了解性质的实践学习，也许之后到了公司，就会有真正的战场在等着我了。固然，若是你以为我写这篇博客花了点心思，那就麻烦点个赞，谢谢啦！

参考资料

　　（1）李智慧，《大型网站技术架构-核心原理与案例分析》：http://item.jd.com/11322972.html

　　（2）guisu，《高性能Mysql主从架构的复制原理及配置详解》：http://blog.csdn.net/hguisu/article/details/7325124

　　（3）Ghost，《高性能的MySQL主从复制架构》：http://www.uml.org.cn/sjjm/201211061.asp

　　（4）飞鸿无痕，《Amoeba搞定MySQL读写分离》：http://blog.chinaunix.net/uid-20639775-id-154600.html （此文讲解了如何借助Amoeba构建MySQL主从复制读写分离，值得阅读）

附件下载

　　（1）mysql-5.5.40（Archive版本）：http://pan.baidu.com/s/1c0u6X80

　　（2）相关配置文件（master与slave）：http://pan.baidu.com/s/1dDENI73

　　（3）C#测试程序DEMO：http://pan.baidu.com/s/1kT42gAz