一.概述

 在企業應用中，成熟的業務通常資料量都比較大
 單臺mysql在安全性、高可用性和高并發方面都無法滿足實際需求
 配置多臺主從資料庫服務器以實作讀寫分離

二.主從復制原理

1.mysql復制型別

• 基于陳述句的復制（sql)
• 基于行的復制(記錄）
• 混合型別的復制

2.mysql主從復制的作業程序

• 兩個日志檔案

• 三個執行緒

• 三個執行緒如何作業

   master：二進制日志檔案
   dump執行緒
  
   slave:中繼日志檔案
   io執行緒
   sql執行緒
  

• 主從復制主要是通過日志檔案進行恢復
  master上的dump執行緒，把資料同步到二進制日志中

• slave上的io執行緒，請求與master的二進制檔案資料同步，從而進行同步到自己的中繼日志中

• slave上的sql執行緒，把自己中繼日志中的檔案，同步到slave資料庫中

三.Mysql讀寫分離

1.讀寫分離原理

• 只在從服務器上寫，只在從服務器上讀
• 主資料庫處理事務性查詢，從資料庫處理select查詢
• 資料庫復制用于將事務性查詢的變更同步到集群中的從資料庫

2.讀寫分離方案

• 基于程式代碼實作

• 基于中間代理層實作

• Mysql-Proxy

• Amoeba

   Amoeba(中間代理層）：
   控制著mysql集群中讀和寫的分配
   間接對接客戶端
  

3.讀寫分離存在的意義

 資料庫的“寫”操作比較耗時的
 資料庫的“讀”比較快
 讀寫分離解決的是：資料庫的寫入，影響了查詢的效率

4.什么時候要讀寫分離

     資料庫不一定要讀寫分離，
     如果程式使用資料庫比較多，更新少，查詢多的情況下會考慮使用
   利用資料庫主從復制，讀寫分離
   可分擔資料庫壓力，提高性能

四.Mysql主從復制和讀寫分離實驗

案例拓撲圖：

思路：

 讀操作直接訪問從服務器
 起到降低負載，負載均衡作用

• 第一步：客戶端client訪問代理服務器amoeba

• 第二步：代理服務器分配讀寫任務給后端集群

• master負責寫

• slave負責讀

• 第三步：主服務器將增刪改查寫入自己的二進制日志

• 第四步：從服務器將主服務器的二進制日志同步到自己中繼日志

• 第五步：從服務器將中繼日志資料同步到自己資料庫中

• 將所有主機的防火墻和安全機制關閉

 systemctl stop firewalld
systemctl disable firewalld
 setenforce 0

1.搭建Mysql主從復制

1）Mysql主從服務器時間同步

• Master服務器：192.168.133.20

yum -y install ntp

vim /etc/ntp.conf

server 127.127.133.0							#設定本地是時鐘源，注意修改網段
fudge 127.127.133.0 stratum 8					#設定時間層級為8（限制在15內）

service ntpd start

末行添加：

• slave1服務器：192.168.133.30
• slave2服務器：192.168.133.40

yum -y install ntp ntpdate

service ntpd start

/usr/sbin/ntpdate 192.168.163.11  #進行時間同步，指向Master服務器IP

crontab -e
*/30 * * * * /usr/sbin/ntpdate 192.168.133.20

2)主服務器的mysql配置

Master服務器：192.168.133.20

vim /etc/my.cnf
server-id = 1
log-bin=master-bin      #添加，主服務器開啟二進制日志
log-slave-updates=true  #添加，允許從服務器更新二進制日志

systemctl restart mysqld

mysql -u root -p
#給從服務器授權
grant replication slave on *.* to 'myslave'@'192.168.133.%' identified by '123456';
flush privileges;

show master status;
#File 列顯示日志名，Fosition 列顯示偏移量

3）從服務器的mysql配置

slave1服務器:192.168.133.30
slave2服務器：192.168.133.40

vim /etc/my.cnf
#修改，注意id與Master的不同，兩個Slave的id也要不同
server-id = 2
#添加，開啟中繼日志，從主服務器上同步日志檔案記錄到本地
relay-log=relay-log-bin
#添加，定義中繼日志檔案的位置和名稱
relay-log-index=slave-relay-bin.index

systemctl restart mysqld

• 兩臺都要操作：
  

mysql -u root -p
#配置同步，注意 master_log_file 和 master_log_pos 的值要與Master查詢的一致，
change master to master_host='192.168.133.20' , master_user='myslave',master_password='123456',master_log_file='master-bin.000001',master_log_pos=604;

start slave;					#啟動同步，如有報錯執行 reset slave;
show slave status\G				#查看 Slave 狀態
//確保 IO 和 SQL 執行緒都是 Yes，代表同步正常，
Slave_IO_Running: Yes			#負責與主機的io通信
Slave_SQL_Running: Yes			#負責自己的slave mysql行程

• slave_Io_running:no的可能性：
• 網路不通
• my.cnf配置有問題
• 密碼、file檔案名、pos偏移量不對
• 防火墻沒有關閉

4）驗證主從復制效果

主服務器上進行執行 create database test;

2.搭建Mysql讀寫分離

1）Amoeba服務器配置

Amoeba服務器：192.168.133.10

安裝java環境

因為 Amoeba 基于是 jdk1.5 開發的，所以官方推薦使用 jdk1.5 或 1.6 版本，高版本不建議使用，
將jdk-6u14-linux-x64.bin 和 amoeba-mysql-binary-2.2.0.tar.gz.0 上傳到/opt目錄下，

cd /opt/
cp jdk-6u14-linux-x64.bin /usr/local/

cd /usr/local/
chmod +x jdk-6u14-linux-x64.bin
./jdk-6u14-linux-x64.bin
按空格到最后一行
按yes，按enter

mv jdk1.6.0_14/ /usr/local/jdk1.6

vim /etc/profile
export JAVA_HOME=/usr/local/jdk1.6
export CLASSPATH=$CLASSPATH:$JAVA_HOME/lib:$JAVA_HOME/jre/lib
export PATH=$JAVA_HOME/lib:$JAVA_HOME/jre/bin/:$PATH:$HOME/bin
export AMOEBA_HOME=/usr/local/amoeba
export PATH=$PATH:$AMOEBA_HOME/bin

source /etc/profile
java -version

安裝Amoeba軟體

mkdir /usr/local/amoeba
tar zxvf /opt/amoeba-mysql-binary-2.2.0.tar.gz -C /usr/local/amoeba/
chmod -R 755 /usr/local/amoeba/
/usr/local/amoeba/bin/amoeba
//如顯示amoeba start|stop 說明安裝成功

2）主從服務器的mysql上授權

• Master服務器:192.168.133.20
• Slave服務器：192.168.133.30
• Slave服務器：192.168.133.40

先在Master、Slave1、Slave2 的mysql上開放權限給 Amoeba 訪問

grant all on *.* to 'test'@'192.168.133.%' identified by 'abc123';

3）配置Amoeba讀寫分離，兩個slave負載均衡

Amoeba服務器：192.168.133.10

①修改amoeba組態檔

cd /usr/local/amoeba/conf/

cp amoeba.xml amoeba.xml.bak
vim amoeba.xml           #修改amoeba組態檔
#---------30修改------------------------------
<property name="user">amoeba</property>
#---------32修改------------------------------
<property name="password">123456</property>
#---------115修改-----------------------------
<property name="defaultPool">master</property>
#---------117去掉注釋–------------------------
<property name="writePool">master</property>
<property name="readPool">slaves</property>

②修改資料庫組態檔

cp dbServers.xml dbServers.xml.bak

vim dbServers.xml
#---------23注釋掉--------------------------------------
作用：默認進入test庫 以防mysql中沒有test庫時，會報錯
<!-- mysql schema
<property name="schema">test</property>
-->
#---------26修改-----------------------------------------
<!-- mysql user -->
<property name="user">test</property>
#---------28-30去掉注釋----------------------------------
<property name="password">abc123</property>
#---------45修改，設定主服務器的名Master------------------
<dbServer name="master"  parent="abstractServer">
#---------48修改，設定主服務器的地址----------------------
<property name="ipAddress">192.168.163.11</property>
#---------52修改，設定從服務器的名slave1-----------------
<dbServer name="slave1"  parent="abstractServer">
#---------55修改，設定從服務器1的地址---------------------
<property name="ipAddress">192.168.163.12</property>
#---------58復制上面6行粘貼，設定從服務器2的名slave2和地址---
<dbServer name="slave2"  parent="abstractServer">
<property name="ipAddress">192.168.163.13</property>
#---------修改后的65或66修改-------------------------------------
<dbServer name="slaves" virtual="true">
#---------71修改----------------------------------------
<property name="poolNames">slave1,slave2</property>

/usr/local/amoeba/bin/amoeba start&	 #啟動Amoeba軟體，按ctrl+c 回傳
netstat -anpt | grep java		   	 #查看8066埠是否開啟，默認埠為TCP 8066

4)測驗讀寫分離

客戶端：192.168.133.50
在客戶端服務器上進行測驗：

yum install -y mysql mysql-server

mysql -u amoeba -p123456 -h 192.168.163.10 -P8066

• 通過amoeba服務器代理訪問mysql ，在通過客戶端連接mysql后寫入的資料只有主服務會記錄，然后同步給從服務器在主服務器上

use test;
create table test (id int(10),name varchar(10),address varchar(20));

• 兩臺從服務器：

stop slave;			#關閉同步
use test;

在slave1:

insert into test values('1','slave1','this_is_slave1');

在slaves2上：

insert into test values('2','slave2','this_is_slave2');

在主服務器上：

insert into test values('3','master','this_is_master');

在客戶端服務器上

use test;
select * from test;		//客戶端會分別向slave1和slave2讀取資料，顯示的只有在兩個從服務器上添加的資料，沒有在主服務器上添加的資料

insert into test values('4','client','this_is_client');		//只有主服務器上有此資料

將兩個服務器上執行 stat slave，可實作同步在主服務器上添加的資料：

start slave;