mysql主从_mysql主从复制数据不一致怎么办
itomcoil 2025-09-11 21:05 5 浏览
1、本章面试题
什么是mysql主从,主从有什么好处
什么是读写分离,有什么好处,使用mycat如何实现
2、知识点
2.1、课程回顾
dubbo ORM->MVC->RPC->SOA
provider consumer registry monitor
负载均衡,容错,降低(倍权,半权)
2.2、本章重点
mysql 主从好处,原理,实现过程
mycat 简介,主要作用,读写分离配置
3、具体内容
3.1 mysql主从配置
3.1.1 好处
负载均衡 :业务量增大时,I/O读写频率变高,单机可能无法满足需求,使用主从,让从服务器分担读压力,实现负载均衡
数据备份 : 传统的备份,都是本地备份,但是存在弊端,无法防止服务器本身出问题,配置主从,可以把本地数据备份到其他服务器
提高可用性 : 一旦主服务器出现问题,可以直接使用从服务器进行更新或者查询
3.1.2 原理
1,主服务器(master)进行写操作时,会把所有的更新语句以二进制日志(binary log)的形式存储
2,从服务器(slave)中有一个i/o线程,会读取主服务器上的二进制日志文件到中继文件中(relay log)
3, 从服务器(slave)中另外一个sql线程,会读写中继文件中的语句,执行并持久化到从服务器的数据库文件中,从而实现了主从复制的功能
3.1.3 实现
配置规划: 创建两台虚拟机
mysql-master1 192.168.23.51 主服务器(master)
mysql-slave1 192.168.23.52 从服务器(slave)
参考linux课件中的虚拟机克隆,克隆出一台23的机子,安装mysql
1)克隆两台虚拟机,成功安装mysql
安装mysql:
查看已经安装mysql组件:(centos6.9 需要卸载原来的mysql组件)
yum list installed | grep mysql
卸载:
yum -y remove mysql-libs.x86_64
如果wget没有安装
yum -y install wget
下载yum源
wget http://repo.mysql.com/mysql-community-release-el6-5.noarch.rpm
安装yum源
rpm -ivh mysql-community-release-el6-5.noarch.rpm
查看yum源中mysql有效版本
yum repolist all | grep mysql
使用下载yum源安装
yum install mysql-community-server -y
查看mysql服务是否启动
service mysqld status
启动mysql服务
service mysqld start
mysql设置密码和远程连接配置
登录mysql
mysql -uroot -p 回车,让输入密码,默认密码为空,再次回车,就可以登录
mysql -uroot -p 回车, 让输入密码,默认密码为空,再次回车,就可以登录
mysql>show databases; 查看所有数据库
mysql>use mysql; 选择使用mysql库
mysql>show tables; 显示所有表
mysql>update user set password=password('tiger') where user='root'; 更新root的密码为tiger
mysql>flush privileges; 刷新权限
mysql> exit; 退出
mysql -uroot -ptiger 再次登录
使用navicat连接时,报错:
mysql>update user set host='%' where host='127.0.0.1'; 修改本地访问为% %代表统配符,可以远程访问
mysql>flush privileges; 刷新权限
已经安装好的m1克隆一台s1
使用上面讲过的克隆方法,再克隆一个s1
vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改ipadd
wq保存退出
vim /etc/hostname 修改主机名称 mysqls1
reboot;
使用xshell连接,测试mysql是否能成功启动
service mysqld status 查看状态
mysql -uroot -ptiger 登录
使用navicat测试
2) 主从配置
master:
主服务器上修改配置文件,添加日志操作
vim /etc/my.cnf
修改第12行 binary.log 日志文件名称可以随便起
log_bin=binary_log
添加一行当前服务器唯一识别
server-id=23
重启服务,让修改生效
service mysqld restart
登录mysql
mysql -uroot -ptiger
查看master状态
show master status;
slave:
vim /etc/my.cnf
添加一行
server-id=24
重启服务,让修改生效
service mysqld restart
登录mysql
mysql -uroot -ptiger
关闭slave(第一次操作不需要,但是以后如果修改该服务器为其他服务的从节点时,需要先停止slave服务)
stop slave;
配置当前服务器为master服务器的从机
change master to master_host='192.168.23.23',master_user='root',master_password='tiger',master_log_file='binary_log.000001',master_log_pos=120;
启动slave
start slave;
查看slave的状态
show slave status \G;
没有错最好(两台机子都全新安装mysql),克隆时,会报下面错误:
Fatal error: The slave I/O thread stops because master and slave have equal MySQL server UUIDs; these UUIDs must be different for replication to work.
原因因为克隆机子,两边的sever-uuid完全一致,所以错误
cat /var/lib/mysql/auto.cnf
解决办法:
从机上先停掉服务
service mysqld stop;
删除server-uuid配置文件
rm -rf /var/lib/mysql/auto.cnf
再次启动服务:
service mysqld start;
再次查看,不同,就解决问题:
cat /var/lib/mysql/auto.cnf
登录mysql
mysql -uroot -ptiger
启动slave
start slave;
查看slave的状态
show slave status \G;
主从都可以执行:
show processlist \G;
3) 测试
使用navicat在m1主机上创建库,查看s1上是否有库
在m1创建表, 在s1查看是否存在:
create table tb_testa(
tid int primary key auto_increment,
name varchar(20) not null,
sex int
);
在m1执行添加语句,在s1查看效果:
insert into tb_testa values(null,'zhangsan',1);
insert into tb_testa values(null,'lisi',2);
查看文件位置是否变化:
master:
show master status;
slave:
show slave status \G;
3.2 mycat 双主双从,读写分离
3.2.1,集群规划:
3.2.2,克隆出m2和s2 做双主双从配置
关闭szqy07-mysql-m1 作为克隆的原始服务器 克隆出szqy07-mysql-m2和szqy07-mysql-s2
直接关闭m1
poweroff
使用前面学的知识,克隆
m2:
vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改ip addr 为25
vim /etc/hostname
修改主机名称为 mysqlm2
rm -rf /var/lib/mysql/auto.cng
reboot 重启
s2:
vim /etc/sysconfig/network-scripts/ifcfg-ens33
修改ip addr 为26
vim /etc/hostname
修改主机名称为 mysqls2
rm -rf /var/lib/mysql/auto.cng
reboot 重启
使用xshell进行连接,配置主从
先配置m2和s2的主从
m2:
vim /etc/my.cnf
日志文件已经修改,修改server-id=25
重启mysql服务:
service mysqld restart
登录mysql:
mysql -uroot -ptiger
显示master状态:
show master status;
s2:
vim /etc/my.cnf
日志文件可以删除,修改server-id=26
重启mysql服务:
service mysqld restart
登录mysql:
mysql -uroot -ptiger
先停止原有的slave服务
stop slave
配置主服务器
change master to master_host='192.168.23.25',master_user='root',master_password='tiger',master_log_file='binary_log.000004',master_log_pos=120;
启动slave
start slave;
显示slave状态:
show slave status \G;
测试:
使用navicat连接,测试m2删除库,创建库,创建表,插入语句,s2是否有变化
配置m1和m2互为主从:
m1:
登录mysql
mysql -uroot -ptiger
显示master状态
show master status;
先停止原有的slave服务
stop slave
配置主服务器
change master to master_host='192.168.23.25',master_user='root',master_password='tiger',master_log_file='binary_log.000004',master_log_pos=1120;
启动slave
start slave;
显示slave状态:
show slave status \G;
m2:
登录mysql
mysql -uroot -ptiger
显示master状态
show master status;
先停止原有的slave服务
stop slave
配置主服务器
change master to master_host='192.168.23.23',master_user='root',master_password='tiger',master_log_file='binary_log.000002',master_log_pos=120;
启动slave
start slave;
显示slave状态:
show slave status \G;
m1和m2都需要加配置:
m1执行更新时,m2和s1都会变化,因为m2和s1都是它的从机,想让s2随着m2的数据变化而变化,就需要在m2加入下面配置
vim /etc/my.cnf 加入下面配置
log-slave-updates
m2执行更新时,m1和s2都会变化,因为m1和s2都是它的从机,想让s1随着m2的数据变化而变化,就需要在m1加入下面配置
vim /etc/my.cnf 加入下面配置
log-slave-updates
重启m1和m2的mysqld服务
service mysqld restart
m1,m2,s1,s2都执行
登录mysql
mysql -uroot -ptiger
显示slave状态:
show slave status \G;
测试:
m1和m2,执行任意更新操作时,其他3台都会发生变化
m1创建库 test_dbc 其他3台都有
m2创建表 ,其他3台都有
create table tb_testc(
tid int primary key auto_increment,
name varchar(20),
sex int
)
3.2.3,什么是mycat,有什么特点
官网: http://www.mycat.io/
Mycat数据库分库分表活跃的、性能好的开源数据库中间件,基于阿里开源的Cobar产品而研发,Cobar的稳定性、可靠性、优秀的架构和性能以及众多成熟的使用案例使得MYCAT一开始就拥有一个很好的起点,站在巨人的肩膀上,我们能看到更远。
一个彻底开源的,面向企业应用开发的大数据库集群
支持事务、ACID、可以替代MySQL的加强版数据库
一个可以视为MySQL集群的企业级数据库,用来替代昂贵的Oracle集群
一个融合内存缓存技术、NoSQL技术、HDFS大数据的新型SQL Server
结合传统数据库和新型分布式数据仓库的新一代企业级数据库产品
一个新颖的数据库中间件产品
Mycat 原理:
Mycat 的原理中最重要的一个动词是“拦截”,它拦截了用户发送过来的 SQL 语句,首先对 SQL 语句做了 一些特定的分析:如分片分析、路由分析、读写分离分析、缓存分析等,然后将此 SQL 发往后端的真实数据库, 并将返回的结果做适当的处理,最终再返回给用户。
3.2.5,什么是读写分离,有什么好处
读写分离就是数据的更新(insert udpate delete 等等)和查询(select等)让不同的数据库服务器执行。
数据库读写分离对于大型系统或者访问量(并发量)很高的互联网应用来说,是必不可少的一个重要功能。 从数据库的角度来说,对于大多数应用来说,从集中到分布,最基本的一个需求不是数据存储的瓶颈,而是在于计算的瓶颈,即SQL查询的瓶颈,我们知道,正常情况下,Insert SQL就是几十个毫秒的时间内写入完成,而系统中的大多数Select SQL则要几秒到几分钟才能有结果,很多复杂的SQL,其消耗服务器CPU的能力超强,不亚于死循环的威力。在没有读写分离的系统上,很可能高峰时段的一些复杂SQL查询就导致数据库服务器CPU爆表,系统陷入瘫痪,严重情况下可能导致数据库崩溃。
3.2.4 ,克隆出mycat,下载安装配置mycat,实现读写分离,自动故障切换和读的负载均衡
使用xftp上传到虚拟机里面
ls 查看
tar -xzf
Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz -C /usr 解压
ls /usr
cd /usr/mycat 进入目录
pwd 查看当前目录
配置环境变量:
vim /etc/profile 在文件JAVA_HOME下加上
export MYCAT_HOME=/usr/mycat
export PATH=$JAVA_HOME/bin:$PATH:$MYCAT_HOME/bin
wq保存退出
source /etc/profile 让配置生效
echo $MYCAT_HOME 测试
server.xml 几乎保存了所有 mycat 需要的系统配置信息,配置登录mycat的用户名,密码,端口号和逻辑数据库名称
cd /usr/mycat 进入mycat目录
vim conf/server.xml
复制33行到31下(yy p) 去除9066 留下8066 配置mycat访问的端口号
注意观察81行后的配置,可以看到使用的用户,密码和逻辑数据库名称
Schema.xml 作为 MyCat 中重要的配置文件之一,管理着 MyCat 的逻辑库、表、分片规则、DataNode 以 及 DataSource。
<dataNode> dataNode 标签定义了 MyCat 中的数据节点,也就是我们通常说所的数据分片。一个 dataNode 标签就是 一个独立的数据分片。
<dataHost>作为 Schema.xml 中最后的一个标签,该标签在 mycat 逻辑库中也是作为最底层的标签存在,直接定义了具 体的数据库实例、读写分离配置和心跳语句。
balance 属性
负载均衡类型,目前的取值有 3 种:
1. balance="0", 不开启读写分离机制,所有读操作都发送到当前可用的 writeHost 上。
2. balance="1",全部的 readHost 与 stand by writeHost 参与 select 语句的负载均衡,简单的说,当双 主双从模式(M1->S1,M2->S2,并且 M1 与 M2 互为主备),正常情况下,M2,S1,S2 都参与 select 语句的负载 均衡。
3. balance="2",所有读操作都随机的在 writeHost、readhost 上分发。
4. balance="3",所有读请求随机的分发到 wiriterHost 对应的 readhost 执行,writerHost 不负担读压力, 注意 balance=3 只在 1.4 及其以后版本有,1.3 没有。
writeType 属性
负载均衡类型,目前的取值有 3 种:
1. writeType="0", 所有写操作发送到配置的第一个 writeHost,第一个挂了切到还生存的第二个 writeHost,
重新启动后已切换后的为准,切换记录在配置文件中:dnindex.properties .
2. writeType="1",所有写操作都随机的发送到配置的 writeHost,1.5 以后废弃不推荐。
switchType 属性
-1 表示不自动切换 1 默认值,自动切换
2 基于 MySQL 主从同步的状态决定是否切换 心跳语句为 show slave status
3 基于 MySQL galary cluster 的切换机制(适合集群)(1.4.1) 心跳语句为 show status like ‘wsrep%’
测试:
读写分离
没有启动mycat之前 创建表:
create table tb_test1(
id int,
username varchar(20)
);
vim conf/log4j2.xml 修改mycat日志文件 conf/log4j2.xml 为debug,为了方便查看日志
启动mycat 使用navicat测试连接:
mycat start 启动( 因为配置了环境变量,在任何都可以执行)
mycat status 查看启动状态,看到running (pid)
在navicat连接的mycat上执行下面语句:
m1是写的服务器,所有的更新操作,都是在m1上执行
执行10条插入语句,使用下面语句查看在哪个服务器执行
insert into tb_test1 values(1,'zhangsan1');
insert into tb_test1 values(2,'zhangsan2');
insert into tb_test1 values(3,'zhangsan3');
insert into tb_test1 values(4,'zhangsan4');
insert into tb_test1 values(5,'zhangsan5');
insert into tb_test1 values(6,'zhangsan6');
insert into tb_test1 values(7,'zhangsan7');
insert into tb_test1 values(8,'zhangsan8');
insert into tb_test1 values(9,'zhangsan9');
insert into tb_test1 values(10,'zhangsan10');
grep --color=auto insert logs/wrapper.log
所有的insert 语句都是在192.168.23.23上执行
m2,s1,s2都读的服务器,所有的select查询操作,在这3台执行
在mycat上执行查询语
select * from tb_test1; -- 全部数据 可定是 m2执行的 192.168.23.25
select * from tb_test1; -- 如果缺少5,6,7 在s2执行
select * from tb_test1; -- 如果缺少8,9,10 在s1执行
所有的读操作都是在m2 s1和s2上执行
负载均衡
m2,s1,s2 轮流执行select语句 从上面就可以看到效果 单台300 项目一共支持 900并发
自动故障切换
m1挂掉后,心跳语句会判断m1是否正常,发现不正常后,会自动切换到第2个存活的writehost 节点作为写节点m2,如果是写节点m1挂了,该写节点下的读节点s1也不参与读
service mysqld stop 停止192.168.23.23的mysql
在mycat上执行插入语句
insert into tb_test1 values(11,'zhangsan11');
insert into tb_test1 values(12,'zhangsan12');
grep --color=auto insert logs/wrapper.log
发现写操作在192.168.23.25的mysql执行
select * from tb_test1; -- 每次都在s2上执行了
如果m1恢复正常 刚才m2执行的插入的数据m1上也会有,m2仍然是写节点,并且m1 s1以后会参与读操作
service mysqld start 启动服务192.168.23.23
参与读操作m1 s1和s2
insert into tb_test1 values(13,'zhangsan13');
insert into tb_test1 values(14,'zhangsan14');
grep --color=auto insert logs/wrapper.log
发现写操作还是192.168.23.25
select * from tb_test1; -- 全部数据 可定是 m1执行的 192.168.23.23
select * from tb_test1; -- 如果缺少5,6,7 在s2执行
select * from tb_test1; -- 如果缺少8,9,10 在s1执行
4、本章总结
4.1 总结本章知识点
4.2 面试题答案
4.3 预习下一章重点
相关推荐
- python数据分析中你必须知道的陷阱和技巧
-
数据分析是一门既有趣又有挑战的技能,它可以帮助我们从海量的数据中提取有价值的信息,为决策提供支持。但是,数据分析也不是一件轻松的事情,它需要我们掌握一定的编程、统计、可视化等知识,同时也要注意避免一些...
- python常见五大坑及避坑指南_python解决什么问题
-
python是一门非常流行和强大的编程语言,但是也有一些容易让初学者或者不熟悉的人掉入的坑。这里列举了一些python常见五大坑,以及如何避免或者解决它们。缩进问题。python使用缩进来表示代码块,...
- 收藏!2022年国家职业资格考试时间表公布
-
人社部14日公布2022年度专业技术人员职业资格考试工作计划,包括中小学生教师资格、会计师、精算师、建造师等各项考试日期。其中,证券期货基金业从业人员资格各次考试地点不同,具体安排以相关行业协会考试公...
- 苹果mac系统必须安装python3_macbook安装python3.7
-
苹果mac系统必须安装python3苹果mac系统口碑很好,但不能像linux系统一样同时提供python2和python3环境,对程序员来说是非常不友善的。资深程序员都知道,Python3才是P...
- 通过python实现猴子吃桃问题_python小猴子吃桃的问题
-
1、问题描述:猴子第一天摘下若干个桃子,当即吃了一半,还不过瘾,又多吃了一个,第二天早上又将剩下的桃子吃掉一半,又多吃了一个。以后每天早上都吃了前一天剩下的一半零一个。到第10天早上想再吃时,就只剩...
- python 中的第一个 hello world 程序输出
-
程序运行:print("helloworld")我使用的是Python程序3.7.0版本介绍下print概念print字面意思打印,将文本输出内容打印出来输入:print(&...
- 持久化 Python 会话:实现数据持久化和可重用性
-
Midjourney生成R语言会话持久化熟悉或常用R语言进行数据分析/数据挖掘/数据建模的数据工作者可能对R语言的会话保存和会话恢复印象比较深刻,它可以将当前session会话持久化保存,以便分...
- 如何将Python算法模型注册成Spark UDF函数实现全景模型部署
-
背景Background对于算法业务团队来说,将训练好的模型部署成服务的业务场景是非常常见的。通常会应用于三个场景:部署到流式程序里,比如风控需要通过流式处理来实时监控。部署到批任务中部署成API服...
- Python 字典l转换成 JSON_python转化字典
-
本文需要5分钟。如果对您有用可以点赞评论关注.Python字典到JSONJSON(JavaScriptObjectNotation)是一种轻量级的数据交换格式,它基于ECMAScrip...
- [python] 基于PyOD库实现数据异常检测
-
PyOD是一个全面且易于使用的Python库,专门用于检测多变量数据中的异常点或离群点。异常点是指那些与大多数数据点显著不同的数据,它们可能表示错误、噪声或潜在的有趣现象。无论是处理小规模项目还是大型...
- 总结90条写Python程序的建议_python写程序的步骤
-
1.首先 建议1、理解Pythonic概念—-详见Python中的《Python之禅》 建议2、编写Pythonic代码 (1)避免不规范代码,比如只用大小写区分变量、使用容易...
- ptrade系列第六天:持久化处理2_持久化的三种状态
-
前一次跟大家分享了利用pickle进行策略数据的持久化。但是这种方式有个问题,就是保存下来的数据无法很直观的看到,比较不方便,所以今天给大家带来另一种方式,将数据通过json保存。importjso...
- Python数据持久化:JSON_python的json用法
-
编程派微信号:codingpy上周更新的《ThinkPython2e》第14章讲述了几种数据持久化的方式,包括dbm、pickle等,但是考虑到篇幅和读者等因素,并没有将各种方式都列全。本文将介绍...
- 干货 | 如何利用Python处理JSON格式的数据,建议收藏
-
作者:俊欣来源:关于数据分析与可视化JSON数据格式在我们的日常工作中经常会接触到,无论是做爬虫开发还是一般的数据分析处理,今天,小编就来分享一下当数据接口是JSON格式时,如何进行数据处理进行详...
- Python中Pyyaml模块的使用_python模块介绍
-
一、YAML是什么YAML是专门用来写配置文件的语言,远比JSON格式方便。YAML语言的设计目标,就是方便人类读写。YAML是一种比XML和JSON更轻的文件格式,也更简单更强大,它可以通过缩进来表...
- 一周热门
- 最近发表
- 标签列表
-
- ps图案在哪里 (33)
- super().__init__ (33)
- python 获取日期 (34)
- 0xa (36)
- super().__init__()详解 (33)
- python安装包在哪里找 (33)
- linux查看python版本信息 (35)
- python怎么改成中文 (35)
- php文件怎么在浏览器运行 (33)
- eval在python中的意思 (33)
- python安装opencv库 (35)
- python div (34)
- sticky css (33)
- python中random.randint()函数 (34)
- python去掉字符串中的指定字符 (33)
- python入门经典100题 (34)
- anaconda安装路径 (34)
- yield和return的区别 (33)
- 1到10的阶乘之和是多少 (35)
- python安装sklearn库 (33)
- dom和bom区别 (33)
- js 替换指定位置的字符 (33)
- python判断元素是否存在 (33)
- sorted key (33)
- shutil.copy() (33)