首页 > 其他分享 >双主双从读写分离

双主双从读写分离

时间：2024-08-22 10:56:29浏览次数：12  
标签：slave 读写 分离 mycat 双主双 MASTER mysql db01 id

目录

介绍

准备

搭建

主库配置

从库配置

两台主库相互复制 

双主双从测试

双主双从读写分离

schema.xml配置

server.xml配置

测试

介绍

一个主机 Master1 用于处理所有写请求，它的从机 Slave1 和另一台主机 Master2 还有它的从 机 Slave2 负责所有读请求。当 Master1 主机宕机后，Master2 主机负责写请求，Master1 、 Master2 互为备机。架构图如下:

准备

我们需要准备5台服务器，具体的服务器及软件安装情况如下：

主机名IP地址配置预装软件角色系统
mycat192.168.226.1002核2G-20G磁盘MyCat、MySQLMyCat中间件服务器Centos7-2009-mini
master1192.168.226.1012核2G-20G磁盘MySQLM1Centos7-2009-mini
master2192.168.226.1022核2G-20G磁盘MySQLM2Centos7-2009-mini
slave1192.168.226.1032核2G-20G磁盘MySQLS1Centos7-2009-mini
slave2192.168.226.1042核2G-20G磁盘MySQLS2Centos7-2009-mini

五台主机关闭防火墙和selinux，进行时间同步并安装mysql，设置root密码为1234 

#!/bin/bash
echo "=====系统环境初始化脚本====="
sleep 3
echo "——>>> 关闭防火墙与SELinux <<<——"
sleep 3
systemctl stop firewalld
systemctl disable firewalld &> /dev/null
setenforce 0
sed -i '/SELINUX/{s/enforcing/disabled/}' /etc/selinux/config
 
echo "——>>> 创建阿里仓库 <<<——"
sleep 3
rm -rf /etc/yum.repos.d/*
curl -o /etc/yum.repos.d/CentOS-Base.repo https://mirrors.aliyun.com/repo/Centos-7.repo 
yum -y install wget
wget -O /etc/yum.repos.d/epel.repo http://mirrors.aliyun.com/repo/epel-7.repo  
 
 
echo "——>>> 设置时区并同步时间 <<<——"
sleep 3
timedatectl set-timezone Asia/Shanghai
yum -y install chrony
systemctl start chronyd
systemctl enable chronyd
reboot
sudo yum remove mysql-server -y && sudo yum autoremove -y
sudo yum remove *mysql* -y
sudo rm -rf /var/lib/mysql/ 
sudo rm -rf /etc/mysql/ 
 
yum install -y yum-utils > /dev/null
yum install -y https://dev.mysql.com/get/mysql80-community-release-el7-11.noarch.rpm > /dev/null
yum-config-manager --enable mysql80-community > /dev/null
yum-config-manager --disable mysql57-community > /dev/null
yum install -y mysql-server
systemctl start mysqld && systemctl enable mysqld
mysqladmin -p"`awk '/temporary password/{p=$NF}END{print p}' /var/log/mysqld.log`" password 'TianPFh@123'
mysql -p'TianPFh@123' -e "UNINSTALL COMPONENT 'file://component_validate_password'"
mysqladmin -p'TianPFh@123' password '1234'

搭建

 

主库配置

 

Master1(192.168.226.101)

 

在配置文件 /etc/my.cnf 追加下述配置

# mysql 服务ID，保证整个集群环境中唯一，取值范围：1 – 2^32-1，默认为1
server-id=10
# 指定同步的数据库
binlog-do-db=db01
binlog-do-db=db02
binlog-do-db=db03
# 在作为从数据库的时候，有写入操作也要更新二进制日志文件
log-slave-updates

重启mysql

systemctl restart mysqld

登录创建账户并授权

# 创建it用户，并设置密码，该用户可在任意主机连接该MySQL服务
CREATE USER 'it'@'%' IDENTIFIED WITH mysql_native_password BY 'admin';
# 为 'it'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'it'@'%';

# 查看第一个主库的二进制日志坐标
show master status ;

 

Master2(192.168.226.102)

 

在配置文件 /etc/my.cnf 追加下述配置

# mysql 服务ID，保证整个集群环境中唯一，取值范围：1 – 2^32-1，默认为1
server-id=11
# 指定同步的数据库
binlog-do-db=db01
binlog-do-db=db02
binlog-do-db=db03
# 在作为从数据库的时候，有写入操作也要更新二进制日志文件
log-slave-updates

重启mysql

systemctl restart mysqld

登录创建账户并授权

# 创建it用户，并设置密码，该用户可在任意主机连接该MySQL服务
CREATE USER 'it'@'%' IDENTIFIED WITH mysql_native_password BY 'admin';
# 为 'it'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'it'@'%';

# 查看第一个主库的二进制日志坐标
show master status ;

 

 

从库配置

 

 

Slave1(192.168.226.103)

 

在配置文件 /etc/my.cnf 追加下述配置

# mysql 服务ID，保证整个集群环境中唯一，取值范围：1 – 2^32-1，默认为1
server-id=12

重启mysql

systemctl restart mysqld

从库关联主库 

需要注意slave1对应的是master1，slave2对应的是master2。

CHANGE MASTER TO MASTER_HOST='192.168.226.101', MASTER_USER='it',
MASTER_PASSWORD='admin', MASTER_LOG_FILE='binlog.000003',
MASTER_LOG_POS=1345;

启动并查看状态

start slave;
show slave status \G;

 创建账户并授权

# 创建it用户，并设置密码，该用户可在任意主机连接该MySQL服务
CREATE USER 'it'@'%' IDENTIFIED WITH mysql_native_password BY 'admin';
# 为 'it'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'it'@'%';

Slave1(192.168.226.104)

 

 在配置文件 /etc/my.cnf 追加下述配置

# mysql 服务ID，保证整个集群环境中唯一，取值范围：1 – 2^32-1，默认为1
server-id=12

重启mysql

systemctl restart mysqld

从库关联主库

需要注意slave1对应的是master1，slave2对应的是master2。

CHANGE MASTER TO MASTER_HOST='192.168.226.102', MASTER_USER='it',
MASTER_PASSWORD='admin', MASTER_LOG_FILE='binlog.000002',
MASTER_LOG_POS=874;

启动并查看状态

start slave;
show slave status \G;

创建账户并授权 

# 创建it用户，并设置密码，该用户可在任意主机连接该MySQL服务
CREATE USER 'it'@'%' IDENTIFIED WITH mysql_native_password BY 'admin';
# 为 'it'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'it'@'%';

 

两台主库相互复制 

 

在master1执行

CHANGE MASTER TO MASTER_HOST='192.168.226.102', MASTER_USER='it',
MASTER_PASSWORD='admin', MASTER_LOG_FILE='binlog.000002',
MASTER_LOG_POS=656;

启动并查看状态

start slave;
show slave status \G;

 

在master2执行 

CHANGE MASTER TO MASTER_HOST='192.168.226.101', MASTER_USER='it',
MASTER_PASSWORD='admin', MASTER_LOG_FILE='binlog.000003',
MASTER_LOG_POS=1345;

启动并查看状态

start slave;
show slave status \G;

 

当show slave status \G;查看的master1，master2，slave1，slave2的Slave_IO_Running:为Yes，
Slave_SQL_Running:为Yes，即代表完成配置。

双主双从测试

因为在配置文件里，我们在两个master配置文件里指定了只有特定的db01，db02，db03库才会复制，因此执行下述sql创建库（该库名不是指定的），是不会进行同步的。

CREATE DATABASE your_database_name;

下面在master1中创建一个库db01，看其他三个库能否同步，正常情况下都可以同步。

CREATE DATABASE db01;

 然后再到master2中对这个库进行一些操作，看其他三个库能否同步，正常情况下都能同步。

USE db01;

CREATE TABLE employees (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    position VARCHAR(50),
    salary DECIMAL(10, 2)
);

INSERT INTO employees (name, position, salary) VALUES
    ('John Doe', 'Software Engineer', 75000.00),
    ('Jane Smith', 'Data Analyst', 65000.00),
    ('Emily Johnson', 'Product Manager', 80000.00);

如果上述测试都满足了，则双主双从即完成。

 

双主双从读写分离

在192.168.226.100主机安装mycat，详细步骤见：MySQ分库分表与MyCat安装配置-CSDN博客

 

schema.xml配置

将下述配置替换原文件里的内容即可。

<?xml version="1.0"?>  
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">  
<mycat:schema xmlns:mycat="http://io.mycat/">  
  
    <schema name="IT_RW2" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn1"></schema>  
  
    <dataNode name="dn1" dataHost="dhost1" database="db01" />  
  
    <dataHost name="dhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100">  
        <heartbeat>select user()</heartbeat> 
 		
        <writeHost host="master1" url="jdbc:mysql://192.168.226.101:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="it" password="admin">  
			<readHost host="slave1" url="jdbc:mysql://192.168.226.103:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="it" password="admin" />
			</writeHost>
			
        <writeHost host="master2" url="jdbc:mysql://192.168.226.102:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="it" password="admin">  
			<readHost host="slave2" url="jdbc:mysql://192.168.226.104:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="it" password="admin" />
			</writeHost>
    </dataHost>  
	
</mycat:schema>

个别属性说明：

balance="1"

  • 代表全部的 readHost 与 stand by writeHost 参与 select 语句的负载均衡，简 单的说，当双主双从模式(M1->S1，M2->S2，并且 M1 与 M2 互为主备)，正常情况下， M2,S1,S2 都参与 select 语句的负载均衡 ;

writeType

  • 0 : 写操作都转发到第1台writeHost, writeHost1挂了, 会切换到writeHost2上;
  • 1 : 所有的写操作都随机地发送到配置的writeHost上 ;

switchType

  • -1 : 不自动切换
  • 1 : 自动切换

 

server.xml配置

只需要修改下述模块位置的代码即可

	<user name="root" defaultAccount="true">
		<property name="password">123456</property>
		<property name="schemas">IT_RW2</property>
		
		<!-- 表级 DML 权限设置 -->
		<!-- 		
		<privileges check="false">
			<schema name="TESTDB" dml="0110" >
				<table name="tb01" dml="0000"></table>
				<table name="tb02" dml="1111"></table>
			</schema>
		</privileges>		
		 -->
	</user>

	<user name="user">
		<property name="password">123456</property>
		<property name="schemas">IT_RW2</property>
		<property name="readOnly">true</property>
	</user>

重启mycat

/usr/local/mycat/bin/mycat stop
/usr/local/mycat/bin/mycat start

 

测试

登录mycat查询

[root@mycat ~]# mysql -h 192.168.226.100 -P8066 -p123456
mysql: [Warning] Using a password on the command line interface can be insecure.
Welcome to the MySQL monitor.  Commands end with ; or \g.
Your MySQL connection id is 25
Server version: 5.6.29-mycat-1.6.7.3-release-20210913163959 MyCat Server (OpenCloudDB)

Copyright (c) 2000, 2024, Oracle and/or its affiliates.

Oracle is a registered trademark of Oracle Corporation and/or its
affiliates. Other names may be trademarks of their respective
owners.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

mysql> show databases;
+----------+
| DATABASE |
+----------+
| IT_RW2   |
+----------+
1 row in set (0.00 sec)

mysql> use IT_RW2;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A

Database changed
mysql> show tables;
+----------------+
| Tables_in_db01 |
+----------------+
| employees      |
+----------------+
1 row in set (0.00 sec)

mysql> select * from employees;
+------+---------------+-------------------+----------+
| id   | name          | position          | salary   |
+------+---------------+-------------------+----------+
|    1 | John Doe      | Software Engineer | 75000.00 |
|    2 | Jane Smith    | Data Analyst      | 65000.00 |
|    3 | Emily Johnson | Product Manager   | 80000.00 |
+------+---------------+-------------------+----------+
3 rows in set (0.06 sec)

注：

如果遇到查询表提示没有权限这类问题，如

mysql> show tables;;
ERROR 1044 (HY000): Access denied for user 'it'@'%' to database 'db01'

就去检查是否在两个从库中创建了这个用户并授权，然后看schema.xml配置账户密码有无错误，如果还是提示这个报错就在两个从库中执行这个sql语句，然后重启mycat再次尝试即可。再插入时遇到这类问题，也是同样的步骤给两个master执行这个sql即可。

GRANT ALL PRIVILEGES ON db01.* TO 'it'@'%';
FLUSH PRIVILEGES;

 

 

在mycat中插入数据，检查四个库是否同步，正常情况下都会同步。

INSERT INTO employees (id, name, position, salary) 
VALUES (4, 'Michael Brown', 'UX Designer', 70000.00);

 

 

在slave1和slave2分别修改刚插入的这个数据名，正常情况下修改从库，是不会同步到其他库的，可以以此来验证。

在slave1执行sql

use db01;
UPDATE employees
SET name = '张三'
WHERE id = 4;

在slave2执行sql

use db01;
UPDATE employees
SET name = '李四'
WHERE id = 4;

修改好后，在slave1查看这个时张三，在slave2中查看是李四，但是在两个master主库中查看是原名Michael Brown ，然后在mycat中多次执行查看数据，这三个名字都会看到才是正常的，多次读取的内容来自于slave1的，slave2的，master2的，但是不会是master1这个主库的。

 

接下来测试见master1的mysql服务关闭模拟故障，看是能切换到master2，能否进行插入和查询操作。

在master1执行关闭mysql服务

systemctl stop mysqld

 在mycat主机里进入mycat查看，并插入一条数据验证

INSERT INTO employees (id, name, position, salary) 
VALUES (5, '王五', 'Marketing Specialist', 72000.00);

select * from employees;

正确情况下是sql语句会执行成功，并且可以同步到slave2的库中，由于master1关闭了，slave1是不会同步数据的。

标签：slave,读写,分离,mycat,双主双,MASTER,mysql,db01,id
From： https://blog.csdn.net/Lzcsfg/article/details/141402848

相关文章

  • 前后端分离Nginx配置
    #usernobody;worker_processesauto;events{worker_connections1024;}http{includemime.types;default_typeapplication/octet-stream;#log_formatmain'$remote_addr-$remote_user[$time_local]"$request"......
  • JS 读写剪贴板
    document.execCommandAPI复制操作复制时，先选中文本，然后调用document.execCommand('copy'):constinputElement=document.querySelector("#input");inputElement.select();document.execCommand("copy");注意：复制操作最好由用户触发，如果脚本自主执行，可能某些浏览器会报......
  • Java毕业设计作品（98）：基于thymeleaf前后端分离 体育赛事购票系统设计与实现
      博主介绍：黄菊华老师《Vue.js入门与商城开发实战》《微信小程序商城开发》图书作者，CSDN博客专家，在线教育专家，CSDN钻石讲师；专注大学生毕业设计教育和辅导。所有项目都配有从入门到精通的基础知识视频课程，学习后应对毕业设计答辩。项目配有对应开发文档、开题报告、任务书......
  • 基于NPOI封装支持多级表头灵活读写的《Soul.XLS》库
    一、先上效果图二、上代码dotnetaddpackageSoul.XLS--version1.1.0//构造一个多级表头varcolumns=newExcelColumnCollection("学生信息"){newExcelColumn("学生信息"){Items=new[]{newExcelColumn("个人信息")......
  • Java毕业设计作品（87）：基于thymeleaf前后端分离 校园学习资料共享平台系统设计与实现
      博主介绍：黄菊华老师《Vue.js入门与商城开发实战》《微信小程序商城开发》图书作者，CSDN博客专家，在线教育专家，CSDN钻石讲师；专注大学生毕业设计教育和辅导。所有项目都配有从入门到精通的基础知识视频课程，学习后应对毕业设计答辩。项目配有对应开发文档、开题报告、任务书......
  • 【实用】【一眼就会】【直接可用】文件上传 附件上传 前后端分离 分布式 多文件上传
    思路：1、先保存主要信息，存到数据库。2、查询这条数据的id、uid3、上传附件功能：根据id、uid、文件。请求：附件API接口。4、后端接口中：先判断登录状态，5、创建对应的文件夹并存入文件，文件夹名以id名命名。6、把附件名重命名，以uuid命名。7、把所有的文件路径放到集合里，传入id......
  • 分离通道、合并通道
    学OpenCV================================================颜色模型之间可以互相转换================================================1#include<iostream>23#include<opencv2/opencv.hpp>4#include<opencv2/core/utils/logger.hpp>56#inclu......
  • 两线程读写数组
    #include<stdio.h>#include<stdlib.h>#include<pthread.h>#include<unistd.h>#defineARRAY_SIZE10intshared_array[ARRAY_SIZE];pthread_mutex_tmutex;void*write_data(void*arg){intthread_id=*(int*)arg;......
  • 部署Nginx负载均衡+动静分离的群集
    目录一、Nginx应用二、正向代理与反向代理1.1正向代理1.2反向代理三、负载均衡1.轮询（RoundRobin）2.最小连接数3.IP  hash:4.加权轮询5.最少事件算法6.一致性hash一、Nginx应用Nginx是一款非常优秀的HTTP服务器软件支持高达50000个并发连接数的响应拥有强......
  • 双向链表读写文件
    双向链表读写文件#include<stdio.h>#include<stdlib.h>structNode{chardata;structNode*prev;structNode*next;};structNode*readFile(constchar*filename){FILE*file=fopen(filename,"r");if(file==NULL......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99