MySQL之双主双从读写分离

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

准备

我们需要准备 4 台服务器,具体的服务器及软件安装情况如下:
编号
IP
预装软件
角色
1
192.168.2.3
MyCat MySQL
MyCat 中间件服务器、M1
2
192.168.2.4
MySQL
S1
3
192.168.2.5
MySQL
M2
4
192.168.2.6
MySQL
S2
关闭以上所有服务器的防火墙:
systemctl stop firewalld
systemctl disable firewalld

搭建双主从

主库配置

1.Master1(192.168.2.3) 

 修改配置文件 /etc/my.cnf

#mysql 服务ID,保证整个集群环境中唯一,取值范围:1 – 2^32-1,默认为1
server-id=1
#指定同步的数据库
binlog-do-db=db01
binlog-do-db=db02
binlog-do-db=db03
# 在作为从数据库的时候,有写入操作也要更新二进制日志文件
log-slave-updates
重启 MySQL 服务器
systemctl restart mysqld
创建账户并授权
#创建mytest用户,并设置密码,该用户可在任意主机连接该MySQL服务
CREATE USER 'mytest'@'%' IDENTIFIED WITH mysql_native_password BY 'Root@123456';
#为 'mytest'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'mytest'@'%';
通过指令,查看两台主库的二进制日志坐标
show master status ;

2.Master2(192.168.2.5)

修改配置文件 /etc/my.cnf  

#mysql 服务ID,保证整个集群环境中唯一,取值范围:1 – 2^32-1,默认为1
server-id=3
#指定同步的数据库
binlog-do-db=db01
binlog-do-db=db02
binlog-do-db=db03
# 在作为从数据库的时候,有写入操作也要更新二进制日志文件
log-slave-updates
重启 MySQL 服务器
systemctl restart mysqld
创建账户并授权
#创建mytest用户,并设置密码,该用户可在任意主机连接该MySQL服务
CREATE USER 'mytest'@'%' IDENTIFIED WITH mysql_native_password BY 'Root@123456';
#为 'mytest'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'mytest'@'%';
通过指令,查看两台主库的二进制日志坐标
show master status ;

从库配置

1.Slave1(192.168.2.4)

 修改配置文件 /etc/my.cnf

#mysql 服务ID,保证整个集群环境中唯一,取值范围:1 – 232-1,默认为1
server-id=2
重新启动 MySQL 服务器
systemctl restart mysqld
创建账户并授权
#创建mytest用户,并设置密码,该用户可在任意主机连接该MySQL服务
CREATE USER 'mytest'@'%' IDENTIFIED WITH mysql_native_password BY 'Root@123456';
#为 'mytest'@'%' 用户分配主从复制权限
GRANT REPLICATION SLAVE ON *.* TO 'mytest'@'%';

通过指令,查看两台主库的二进制日志坐标

show master status ;

2.Slave2(192.168.2.6)

修改配置文件 /etc/my.cnf

#mysql 服务ID,保证整个集群环境中唯一,取值范围:1 – 232-1,默认为1
server-id=4

 重新启动MySQL服务器

systemctl restart mysqld

从库关联主库

需要注意slave1对应的是master1slave2对应的是master2 

slave1(192.168.2.4)上执行 

CHANGE MASTER TO MASTER_HOST='192.168.2.3', MASTER_USER='mytest',
MASTER_PASSWORD='Root@123456', MASTER_LOG_FILE='binlog.000010',
MASTER_LOG_POS=157;
slave2(192.168.2.6) 上执行
CHANGE MASTER TO MASTER_HOST='192.168.2.5', MASTER_USER='mytest',
MASTER_PASSWORD='Root@123456', MASTER_LOG_FILE='binlog.000005',
MASTER_LOG_POS=585;
启动两台从库主从复制,查看从库状态
start slave;
show slave status \G;

 

两台主库相互复制

 Master1(192.168.2.3)上执行

CHANGE MASTER TO MASTER_HOST='192.168.2.5', MASTER_USER='mytest',
MASTER_PASSWORD='Root@123456', MASTER_LOG_FILE='binlog.000005',
MASTER_LOG_POS=585;
Master2(192.168.2.5) 上执行
CHANGE MASTER TO MASTER_HOST='192.168.2.3', MASTER_USER='mytest',
MASTER_PASSWORD='Root@123456', MASTER_LOG_FILE='binlog.000010',
MASTER_LOG_POS=453;
启动两台从库主从复制,查看从库状态
start slave;
show slave status \G;

 经过上述的配置之后,双主双从的复制结构就已经搭建完成了。 接下来,我们可以来测试验证一下。

测试

分别在两台主库 Master1 Master2 上执行 DDL DML 语句,查看涉及到的数据库服务器的数据同步情况。
create database db01;
use db01;
create table tb_user(
id int(11) not null primary key ,
name varchar(50) not null,
sex varchar(1)
)engine=innodb default charset=utf8mb4;

insert into tb_user(id,name,sex) values(1,'Tom','1');
insert into tb_user(id,name,sex) values(2,'Trigger','0');
insert into tb_user(id,name,sex) values(3,'Dawn','1');
insert into tb_user(id,name,sex) values(4,'Jack Ma','1');
insert into tb_user(id,name,sex) values(5,'Coco','0');
insert into tb_user(id,name,sex) values(6,'Jerry','1');
  • Master1中执行DMLDDL操作,看看数据是否可以同步到另外的三台数据库中。
  • Master2中执行DMLDDL操作,看看数据是否可以同步到另外的三台数据库中。

双主双从读写分离 

完成了上述双主双从的结构搭建之后,接下来,我们再来看看如何完成这种双主双从的读写分离。

配置

MyCat 控制后台数据库的读写分离和负载均衡由 schema.xml 文件 datahost 标签的 balance 属性控制,通过writeType switchType 来完成失败自动切换的。

schema.xml

配置逻辑库:
<schema name="TEST_RW2" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn7">
</schema>
配置数据节点:
<dataNode name="dn7" dataHost="dhost7" database="db01" />
配置节点主机:
<dataHost name="dhost7" 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.2.3:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="root" password="newPwd520@" >
			<readHost host="slave1" url="jdbc:mysql://192.168.2.4:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="root" password="newPwd520@" />
		</writeHost>
		<writeHost host="master2" url="jdbc:mysql://192.168.2.5:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="root" password="newPwd520@" >
			<readHost host="slave2" url="jdbc:mysql://192.168.2.6:3306?useSSL=false&amp;serverTimezone=Asia/Shanghai&amp;characterEncoding=utf8" user="root" password="newPwd520@" />
		</writeHost>
	</dataHost>
属性说明:
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 : 自动切换

user.xml

配置 root 用户也可以访问到逻辑库 TEST _RW2
<user name="root" defaultAccount="true">
<property name="password">123456</property>
<property name="schemas">TEST_RW2</property>
<!-- 表级 DML 权限设置 -->
<!--
<privileges check="true">
<schema name="DB01" dml="0110" >
<table name="TB_ORDER" dml="1110"></table>
</schema>
</privileges>
-->
</user>

重启MyCat

bin/mycat restart

测试

登录 MyCat ,测试查询及更新操作,判定是否能够进行读写分离,以及读写分离的策略是否正确。
当主库挂掉一个之后,是否能够自动切换。
先在mycat插入数据
insert into tb_user(id,name,sex) values(4,'Jack Ma','1');

插入数据成功

在全部mysql也插入数据成功

 

然后停掉master1

systemctl stop mysqld

 再次在mycat插入数据

insert into tb_user(id,name,sex) values(5,'Coco','0');

还是成功

除了master,其他mysql也插入数据成功

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1089924.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

代码随想录算法训练营第二十一天丨 二叉树part08

235. 二叉搜索树的最近公共祖先 思路 昨天做过的二叉树&#xff1a;公共祖先问题 (opens new window)题目&#xff0c;知道利用回溯从底向上搜索&#xff0c;遇到一个节点的左子树里有p&#xff0c;右子树里有q&#xff0c;那么当前节点就是最近公共祖先。 那么本题是二叉搜…

SpringBoot使用的时间与空间计量单位

SpringBoot支持JDK8提供的时间与空间计量单位 //时间单位DurationUnit(ChronoUnit.MINUTES)private Duration serverTimeOut;//存储空间单位DataSizeUnit(DataUnit.MEGABYTES)private DataSize dataSize; 在springboot中的具体使用&#xff1a; Component Data ConfigurationPr…

工程企业管理软件源码-综合型项目管理软件

工程项目管理软件&#xff08;工程项目管理系统&#xff09;对建设工程项目管理组织建设、项目策划决策、规划设计、施工建设到竣工交付、总结评估、运维运营&#xff0c;全过程、全方位的对项目进行综合管理 工程项目各模块及其功能点清单 一、系统管理 1、数据字典&am…

H3C R6900 G5 RAID配置

1.开机按ESC进入BIOS 2.选择高级 阵列卡进行配置 3.选择configure 4.创建阵列 5.根据业务选择raid级别 6.选择硬盘 7.成功 8.返回主页面 9.确认 10.查看创建好的阵列

MySQL创建数据库、创建表操作和用户权限

1、创建数据库school&#xff0c;字符集为utf8 2、在school数据库中创建Student和Score表 3、授权用户tom&#xff0c;密码Mysql123&#xff0c;能够从任何地方登录并管理数据库school 4、使用mysql客户端登录服务器&#xff0c;重置root密码

【小黑嵌入式系统第一课】嵌入式系统的概述(一)

文章目录 一、嵌入式系统基本概念计算机发展的三大阶段CPU——计算机的核心什么是嵌入式系统嵌入式系统的分类 二、嵌入式系统的特点三、嵌入式系统发展无操作系统阶段简单操作系统阶段实时操作系统阶段面向Internet阶段 四、嵌入式系统的应用工业控制 工业设备通信设备信息家电…

Leetcode226.翻转二叉树

本专栏内容为&#xff1a;leetcode刷题专栏&#xff0c;记录了leetcode热门题目以及重难点题目的详细记录 &#x1f493;博主csdn个人主页&#xff1a;小小unicorn ⏩专栏分类&#xff1a;Leetcode &#x1f69a;代码仓库&#xff1a;小小unicorn的代码仓库&#x1f69a; &…

虚幻引擎5:增强输入的使用方法

一、基本配置 1.创建一个输入映射上下文&#xff08;映射表&#xff09; 2.创建自己需要的操作映射或者轴映射 3.创建完成之后进入这个映射&#xff0c;来设置类型&#xff0c;共有4个类型 1.Digital:是旧版操作映射类型&#xff0c;一般是按下抬起来使用&#xff0c;像跳跃…

虚拟机安装Docker

安装Docker Docker 分为 CE 和 EE 两大版本。CE 即社区版&#xff08;免费&#xff0c;支持周期 7 个月&#xff09;&#xff0c;EE 即企业版&#xff0c;强调安全&#xff0c;付费使用&#xff0c;支持周期 24 个月。 Docker CE 分为 stable test 和 nightly 三个更新频道。…

【LeetCode高频SQL50题-基础版】打卡第7天:第36~40题

文章目录 【LeetCode高频SQL50题-基础版】打卡第7天&#xff1a;第36~40题⛅前言按分类统计薪水&#x1f512;题目&#x1f511;题解 上级经理已离职的公司员工&#x1f512;题目&#x1f511;题解 换座位&#x1f512;题目&#x1f511;题解 电影评分&#x1f512;题目&#x…

buuctf week2-web-ez_sql

闭合之后尝试判断字段数&#xff0c;存在WAF&#xff0c;使用大小写绕过&#xff08;后面的sql语句也需要进行大小写绕过&#xff09; ?id1 Order by 5-- 测出有5列 ?id1 Order by 6-- 查一下数据库名、版本、用户等信息 ?id1Union Select database(),version(),user(),4,…

ACP.复盘方法

复盘要怎么做的有水准&#xff0c;让领导满意&#xff0c;方式方法很重要。今天给你们安利5种复盘方法&#xff0c;保准你省事&#xff0c;领导还满意。 一、KPT复盘法 7月份年中一直在做和复盘相关的事&#xff0c;像公司的OKR复盘、年中战略规划&#xff0c;不过日常很多生…

Unity应用开发——开启无限创造之旅

Unity是一款令人叹为观止的跨平台游戏开发引擎&#xff0c;它打开了创作者们的无限创造之门。Unity不仅仅限于游戏开发&#xff0c;它还在虚拟现实、增强现实、模拟训练等多个领域取得了巨大成功。在经过充满激情和创意的Unity应用开发课程之后&#xff0c;世达教育迎来了这段精…

十七、【渐变工具组】

文章目录 渐变工具油漆桶工具 渐变工具 渐变样式有5种&#xff0c;分别是线性渐变&#xff0c;径向渐变&#xff0c;角度渐变&#xff0c;对称渐变&#xff0c;菱形渐变 另外渐变工具的颜色可以进行编辑&#xff0c;需要先打开渐变编辑工具&#xff1a; 如何使用渐变编辑工…

grafana api创建dashboard 记录

文章目录 json model导入申请api key创建dashboard删除dashboard json model导入 直接在ui通过json model 导入&#xff0c;开发自己用还好&#xff0c;但对非开发人员不太友好&#xff0c;故考虑通过api后台自动创建 api doc : https://grafana.com/docs/grafana/v9.3/devel…

【重拾C语言】十、递归程序设计

目录 前言 十、递归程序设计 10.1 计算n&#xff01;——递归程序设计 10.2 程序设计实例 10.2.1 汉诺塔 10.2.2 齿轮 10.2.3 组合 10.3 计算算术表达式的值——间接递归 10.4 递归程序执行过程 前言 递归程序设计是一种编程技术&#xff0c;其中一个函数通过调用自身…

Navicat For MySQL使用指南

勾选填充零后的效果&#xff0c;就是不够的位数用零来补齐&#xff01;

Eclipse插件安装版本不兼容问题解决方案——Papyrus插件为例

项目场景: Eclipse Papyrus安装后,没有新建Papyrus工程选项,也没有新建Papyrus Model的选项。 打开Papyrus Model会报错 问题描述 同样的,安装其他插件也是。可能某个插件之前安装是好用的,结果Eclipse的版本更新了,就再也安装不好用了 原因分析: 根本原因是因为包之…

交通 | python网络爬虫:“多线程并行 + 多线程异步协程

推文作者&#xff1a;Amiee 编者按&#xff1a; 常规爬虫都是爬完一个网页接着爬下一个网页&#xff0c;不适应数据量大的网页&#xff0c;本文介绍了多线程处理同时爬取多个网页的内容&#xff0c;提升爬虫效率。 1.引言​ 一般而言&#xff0c;常规爬虫都是爬完一个网页接着…

【MySql】7- 实践篇(五)

文章目录 1. 加锁规则1.1 案例一&#xff1a;等值查询间隙锁1.2 案例二&#xff1a;非唯一索引等值锁1.3 案例三&#xff1a;主键索引范围锁1.4 案例四&#xff1a;非唯一索引范围锁1.5 案例五&#xff1a;唯一索引范围锁 bug1.6 案例六&#xff1a;非唯一索引上存在"等值…