MySQL的主从复制与读写分离

目录

 

 

一、案例前置知识点分析

MySQL主从复制原理

·MySQL的复制类型

①基于语句的复制

②基于行的复制

③混合类型的复制

·MySQL主从复制的工作过程

 

MySQL读写分离原理

·只在主服务器上写,只在从服务器上读

·主数据库处理事务性查询,从数据库处理SELECT查询

·数据库复制用于将是事务性查询的变更同步到集群中的从数据库

·读写分离方案

①基于程序代码内部实现

②基于中间代理层实现

MySQL-Proxy

Amoeba

 

复制的基本过程如下

①Master将用户对数据库更新的操作以二进制格式保存到Binary Log日志文件中;

②Slave上面的IO进程连接上Master,并请求从指定日志文件的指定位置(或者从最开始的日志)之后的日志内容;

③Master接收到来自Slave的IO进程的请求后,通过负责复制的IO进程根据请求信息读取指定日志指定位置之后的日志信息,返回给Slave的IO进程。返回信息中除了日志所包含的信息之外,还包括本次返回的信息已经到Master端的bin-log文件的名称以及bin-log的位置;

④Slave的IO进程接收到信息后,将接收到的日志内容依次添加到Slave端的relay-log文件的最末端,并将读取到的Master端的bin-log的文件名和位置记录到master-info文件中,以便在下一次读取的时候能够清楚地告诉Master“我需要从某个bin-log的哪个位置开始往后的日志内容,请发给我”;

⑤Slave的Sql进程检测到relay-log中新增加了内容后,会马上解析relay-log的内容成为在Master端真实执行时候的那些可执行的内容,并在自身执行

 

二、案例拓扑图

MySQL的主从复制与读写分离

 

 

 

三、案例实施主从复制

MySQL(主)

 ·配置NTP服务器

yum -y install ntp ntpdate

ntpdate ntp.aliyun.com
date
which ntpdate
crontab -e
*/30 * * * * /usr/sbin/ntpdate ntp.aliyun.com
 vi /etc/ntp.conf
restrict 20.0.0.0 mask 255.255.255.0 nomodify notrap  #17行修改
21-24行删除
server 127.127.1.0            #在删除的位置添加
fudge 127.127.1.0 stratum 8
systemctl start ntpd
systemctl enable ntpd14 systemctl start crond15 systemctl enable crond16 crontab -l   #查看任务计划

·手工编译安装MySQL(之前的博客上有关于MySQL的具体安装步骤)

·配置master主服务器的MySQL

vi /etc/my.cnf

server-id = 1
log_bin=master_bin            #在server-id下面添加两行
log_slave_updates=true
systemctl restart mysqld.service
mysql -u root -p123456
mysql> grant replication slave on *.* to ‘myslave‘@‘20.0.0.%‘ identified by ‘abc123‘;
mysql> show grants for ‘myslave‘@‘20.0.0.%‘;
mysql> flush privileges;
mysql> show master status;         #查完要记住position列的值

 

MySQL2(从)

·配置时间同步

yum -y install ntp ntpdate
ntpdate 20.0.0.10
date
which ntpdate
crontab -e
*/30 * * * * /usr/sbin/ntpdate 20.0.0.10
systemctl start ntpd
systemctl enable ntpd
systemctl start crond
systemctl enable crond11 crontab -l   #查看任务计划

·配置MySQL从服务器

vi /etc/my.cnf
server-id = 2
relay_log=relay-log-bin               #添加日志
relay_log_index=slave-relay-bin.index
systemctl restart mysqld
mysql -uroot -p123456
mysql> change master to master_host=‘20.0.0.10‘,master_user=‘myslave‘,master_password=‘abc123‘,master_log_file=‘master_bin.000002‘,master_log_pos=154;
mysql> start slave;
mysql> show slave status \G;
             ......
             Slave_IO_Running: Yes
             Slave_SQL_Running: Yes
##如果显示NO,①主服务器数据库更新重启一下,再进入数据库,打show master status;记录日志和Position值②再在从服务器上打mysql> change master to master_host=‘20.0.0.10‘,master_user=‘myslave‘,master_password=‘abc123‘,master_log_file=‘master_bin.000002‘,master_log_pos=154;

 

MySQL3(从)

·配置时间同步

yum -y install ntp ntpdate
ntpdate 20.0.0.10
date
which ntpdate
crontab -e
*/30 * * * * /usr/sbin/ntpdate 20.0.0.10
systemctl start ntpd
systemctl enable ntpd
systemctl start crond
systemctl enable crond
crontab -l   #查看任务计划

·配置MySQL从服务器

vi /etc/my.cnf
 server-id = 3
 relay_log=relay-log-bin               #添加日志
 relay_log_index=slave-relay-bin.index
 systemctl restart mysqld
 mysql -uroot -p123456
 mysql> change master to master_host=‘20.0.0.10‘,master_user=‘myslave‘,master_password=‘abc123‘,master_log_file=‘master_bin.000002‘,master_log_pos=154;
 mysql> start slave;
 mysql> show slave status \G;
             ......
              Slave_IO_Running: Yes
              Slave_SQL_Running: Yes
##如果显示NO,①主服务器数据库更新重启一下,再进入数据库,打show master status;记录日志和Position值②再在从服务器上打mysql> change master to master_host=‘20.0.0.10‘,master_user=‘myslave‘,master_password=‘abc123‘,master_log_file=‘master_bin.000002‘,master_log_pos=154;

测试

·MySQL(主)服务器上创建一个数据库

mysql -u root -p123456
mysql> create database abc;
mysql> show databases;

·MySQL2(从)和MySQL3(从)上查看

mysql -u root -p123456
mysql> show databases;

 

四、案例实施读写分离

·在三台MySQL数据库中为amoeba授权

mysql> grant all privileges on *.* to ‘test‘@‘20.0.0.%‘ identified by ‘abc123‘;
mysql> show grants for test@‘20.0.0.%‘;
mysql> flush privileges;

·在amoeba服务器上安装JDK

tar zxf jdk-8u91-linux-x64.tar.gz
mv jdk1.8.0_91/ /usr/local/java
vi /etc/profile
export JAVA_HOME=/usr/local/java     #末尾添加
export JRE_HOME=/usr/local/java/jre
export AMOEBA_HOME=/usr/local/amoeba
export PATH=$PATH:$JAVA_HOME/bin:$AMOEBA_HOME/bin
source /etc/profile
java -version

·在amoeba服务器上安装amoeba

unzip amoeba-mysql-3.0.5-RC-distribution.zip
mv amoeba-mysql-3.0.5-RC /usr/local/amoeba
chmod -R 755 /usr/local/amoeba/
vi /usr/local/amoeba/jvm.properties
#JVM_OPTIONS="-server -Xms256m -Xmx1024m -Xss196k -XX:PermSize=16m -XX:MaxPerSize=96m"                #32行添加
JVM_OPTIONS="-server -Xms1024m -Xmx1024m -Xss256k"
cd /usr/local/amoeba/bin/
launcher
netstat -anpt | grep 8066

·修改amoeba配置文件

vi /usr/local/amoeba/conf/amoeba.xml
<property name="user">test</property>   #28行修改
<property name="password">123456</property>          #30行修改
......
</property>
<property name="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>
<property name="LRUMapSize">1500</property>
<property name="defaultPool">master</property>     #修改
<property name="writePool">master</property>       #修改
<property name="readPool">slaves</property>          #修改
<property name="needParse">true</property>
</queryRouter>
vi /usr/local/amoeba/conf/dbServers.xml
......
<property name="user">test</property>     #26行修改
<property name="password">abc123</property>     #28行修改
 ......
         <dbServer name="master"  parent="abstractServer">    #修改部分参数
                 <factoryConfig>
                         <!-- mysql ip -->
                         <property name="ipAddress">20.0.0.10</property>
                 </factoryConfig>
         </dbServer>
         <dbServer name="slave1"  parent="abstractServer">
                 <factoryConfig>
               <!-- mysql ip -->
                         <property name="ipAddress">20.0.0.20</property>
                 </factoryConfig>
         </dbServer>
         <dbServer name="slave2"  parent="abstractServer">
                 <factoryConfig>
                         <!-- mysql ip -->
                         <property name="ipAddress">20.0.0.30</property>
                 </factoryConfig>
         </dbServer>

        <dbServer name="slaves" virtual="true">
               <poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">
                         <!-- Load balancing strategy: 1=ROUNDROBIN , 2=WEIGHTBASED , 3=HA-->
                         <property name="loadbalance">1</property>
                        <!-- Separated by commas,such as: server1,server2,server1 -->
                         <property name="poolNames">slave1,slave2</property>
               </poolConfig>
        </dbServer>
cd /usr/local/amoeba/bin/
launcher
·在客户机上测试

yum -y install mariadb*
systemctl start mariadb
netstat -anpt | grep 3306   
mysql -utest -p123456 -h 20.0.0.40 -P 8066

·测试

(1)在master新建库和表

mysql> create database test;
mysql> use test;
mysql> create table abc(id int(2) not null primary key, name varchar(48), score char(48));
mysql> show tables;

(2)在两台从服务器上看是否有库及表生成

mysql> show databases;
mysql> use test;
mysql> show tables;
mysql> select * from abc;

(3)在两台从服务器上停止服务

mysql> stop slave;

(4)在主服务上插入内容不会同步(通过amoeba操作)

主服务器:mysql> insert into abc values(2,‘lisi‘,89);

从服务器:mysql> select * from abc;

(5)在从服务器1上直接插入内容

mysql> insert into abc values(3,‘wangwu‘,60);
mysql> select * from abc;

(6)在从服务器2上直接插入内容

mysql> insert into abc values(4,‘bb‘,68);
mysql> select * from abc;

(7)在客户端上测试(第一次向从服务器1读数据,第二次向从服务器2读数据)

MySQL [test]> select * from abc;
MySQL [test]> select * from abc;

(8)在通过客户端连接数据库后写入的数据只有主会记录,然后同步给从-从服务器,从而实现读写分离

MySQL [test]> insert into abc values(5,‘cc‘,90);        #客户机
mysql> select * from abc;                          #主
mysql> select * from abc; #从1 4 mysql> select * from abc; #从2

(9)在客户端上看不到新插入的数据,因为同步没有开启,只有主服务器上可以看到数据

MySQL [test]> select * from abc;
MySQL [test]> select * from abc;

(10)在开启同步后,主服务器上的数据会同步到各从服务器上中,但从服务器上的自己增加的数据不会同步,只有本地保存

#从1
mysql> start slave;
mysql> select * from abc;
#从2
mysql> start slave;
mysql> select * from abc;
客户端:
MySQL [test]> select * from abc;

 

MySQL的主从复制与读写分离

上一篇:centos----------防火墙firewalld和iptables


下一篇:jsp关闭或刷新浏览器(解决浏览器不兼容),请求后台onbeforeunload、onunload