Linux Shell十四 Mysql主从同步

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群版 2核4GB 100GB
推荐场景:
搭建个人博客
云数据库 RDS MySQL,高可用版 2核4GB 50GB
简介:

环境介绍:

本脚本测试环境是基于CentOS 6.5 x86_x64的源码安装的Mysql,Mysql版本为mysql-5.1.63,并且均为全新安装,Mysql服务均启动。

Master  192.168.1.3   主机名:master

Slave   192.168.1.4   主机名:slave

Selinux及Iptables均关闭清空。主从两台机器已经做过ssh双机互信(ssh双机互信可参见 《SSH双机互信及错误解决大全》 Mysql的编译安装可参加《搭建Discuz论坛的两种方式 》脚本文件在附件当中!)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
#!/bin/bash
#Target: Auto Make And Check Mysql Master-Slave
#Date: 2015-05-17
#Author: Jacken
#QQ 654001593
#QQ Group 170544180
#Version: 1.0
#
#Note:Have To Exec 1 On Master,Then Exec 2 On SLAVE_DIR,On Correspond Machine To Select "Show Status"
#Only Allow Define Variable
shopt  -s -o nounset
#
#####################################################################
#####################################################################
##########Define Varabile
#Define Master And Slave Database Ipaddress.
MASTER_IP=192.168.1.3
SLAVE_IP=192.168.1.4
#
#Define Master Super User Name And Password.
MASTER_USER=root
MASTER_PASSWD=master123
#
#Define Slave Super User Name And Password.
SLAVE_USER=root
SLAVE_PASSWD=slave123
#
#Define Master-to-Slave Grant  User & Password & Host
GRANT_USER=grantuser
GRANT_PASSWD=grantpasswd
GRANT_HOST=%
#
#Sync Database
RSDB=*.*
#
#Define Mysql install Directory
MASTER_DIR= /usr/local/mysql
SLAVE_DIR= /usr/local/mysql
#
#Define Device Name. 
DEV=eth0
#
#Get Ipaddress For Exec Scripts Machine
GETIP=$( ifconfig  $DEV|  sed  -n  '/inet addr:/p' | awk  '{print $2}' awk  -F:  '{print $2}' )
#####################################################################
#####################################################################
#
#Only For Super User To Exec
if  [ $UID - ne  0 ]; then
     echo  -e  '\e[31mSorry,This Script Must Be Super User To Exec!\e[0m'
     exit  2
fi
#
#
#####################################################################
#####################################################################
#
#Define Master database Operations.
MYSQL_MIN= "$MASTER_DIR/bin/mysql -u$MASTER_USER -p$MASTER_PASSWD -e"
#
function  MASTER_DO {
#Backup And Judge My.cnf
if  [ -f  /etc/my .cnf ]; then
     cp  /etc/my .cnf  /etc/my .cnf$$
else
     cp  $MASTER_DIR /share/mysql/my-medium .cnf   /etc/my .cnf 
fi
#Grant Slave Database Access Master Database.
$MASTER_DIR /bin/mysql  -u$MASTER_USER -p$MASTER_PASSWD -e  "grant all on $RSDB to '$SLAVE_USER'@'$SLAVE_IP' identified by '$SLAVE_PASSWD';" 
#Grant Master-Slave Sync User.
$MYSQL_MIN  "grant replication slave on $RSDB to \"$GRANT_USER\"@\"$GRANT_HOST\" identified by \"$GRANT_PASSWD\";"
$MYSQL_MIN  "flush privileges;"
}
#
#
#####################################################################
#####################################################################
#
#Define Slave database Operations.
#
function  SLAVE_DO(){
MYSQL_SIN= "$SLAVE_DIR/bin/mysql -u$SLAVE_USER -p$SLAVE_PASSWD -e"
#Get Master Database status.
MASTER_INFO=`$SLAVE_DIR /bin/mysql  -h$MASTER_IP -u$SLAVE_USER -p$SLAVE_PASSWD -e  "show master status;" | sed  -n  '/mysql/p' `
#
#Get Log_File
LOG_FILE=` echo  $MASTER_INFO| awk   '{print $1}' `
#Get Log_Pos 
LOG_POS=` echo  $MASTER_INFO| awk  '{print $2}' `
#
#Get Slave Database Status
SYNC_INFO=`$MYSQL_SIN  "show slave status \G;" | grep  Runnning >  /dev/null  2>&1` 
#
#Judge Yes Or No
SLAVE_IO_STATUS=` echo  $SYNC_INFO| sed  -n  '/IO/p' | awk  -F:  '{print $2}' `
SLAVE_SQL_STATUS=` echo  $SYNC_INFO| sed  -n  '/SQL/p' | awk  -F:  '{print $2}' `
#Grant Master User To Access Slave Database.
`$MYSQL_SIN  "grant all privileges on $RSDB to \"$MASTER_USER\"@\"$MASTER_IP\" identified by \"$MASTER_PASSWD\";" `
#
#Backup And Judge /etc/My.cnf
if  [ -f  /etc/my .cnf ]; then
     cp  /etc/my .cnf  /etc/my .cnf$$
else
     cp  $MASTER_DIR /share/mysql/my-medium .cnf   /etc/my .cnf 
fi
#
#Modify Slave Server-id
sed  -i  '/^server-id/s/1/2/'  /etc/my .cnf
#
#Add Master Information On Slave
$MYSQL_SIN  "change master to master_host='$MASTER_IP',master_user='$GRANT_USER',master_password='$GRANT_PASSWD',master_log_file='$LOG_FILE',master_log_pos=$LOG_POS;" 
$MYSQL_SIN  "slave start;"
}
#
#
#####################################################################
#####################################################################
#
#Judge Master-Slave Status On Slave To Exec!
function  SYNC_STATUS_S {
MYSQL_SIN= "$SLAVE_DIR/bin/mysql -u$SLAVE_USER -p$SLAVE_PASSWD -e"
#Get Sync Information
SYNC_INFO=`$MYSQL_SIN  'show slave status \G' | grep  Running`
#
#Judge Yes Or No
SLAVE_IO_STATUS=` echo  $SYNC_INFO| awk   '{print $2}' `
SLAVE_SQL_STATUS=` echo  $SYNC_INFO| awk  '{print $4}' `
#
#Reply Master-Slave Status Information.
if  [[  "$SLAVE_IO_STATUS"  ==  'Yes'  &&  "$SLAVE_SQL_STATUS"  ==  'Yes'  ]]; then
     echo  -e  '\e[32mThe Database Sync Is Successfuly!\e[0m'
else
     echo  -e  '\e[31mThe Database Sync Is Failure!\e[0m'
     echo  -e  '\e[31mPlease Check!Exit....\e[0m'
     exit  2
fi
}
#Judge Master-Slave Status On Master To Exec!
function  SYNC_STATUS_M {
MYSQL_MIN= "$MASTER_DIR/bin/mysql -h$SLAVE_IP -u$MASTER_USER -p$MASTER_PASSWD -e"
#
#Get Sync Information
SYNC_INFO=`$MYSQL_MIN  'show slave status \G' | grep  Running`
#
#Judge Yes Or No
SLAVE_IO_STATUS=` echo  $SYNC_INFO| awk   '{print $2}' `
SLAVE_SQL_STATUS=` echo  $SYNC_INFO| awk  '{print $4}' `
#Reply Master-Slave Status Information.
if  [[  "$SLAVE_IO_STATUS"  ==  'Yes'  &&  "$SLAVE_SQL_STATUS"  ==  'Yes'  ]]; then
     echo  -e  '\e[32mThe Database Sync Is Successfuly!\e[0m'
else
     echo  -e  '\e[31mThe Database Sync Is Failure!\e[0m'
     echo  -e  '\e[31mPlease Check!Exit....\e[0m'
     exit  2
fi
}
#
#####################################################################
#####################################################################
#
#Judge Master Database Machine!
function  JUDGE_MASTER_ID() {
if  [ !  "$GETIP"   ==   "$MASTER_IP"  ]; then
     echo  -e  '\e[31mYour Choice Error,This Option Only Select On Master Machine!\e[0m'
     exit  2
fi
}
#        
#####################################################################
#####################################################################
#
#Judge Master Database Machine!
function  JUDGE_SLAVE_ID() {
if  [ !  "$GETIP"   ==   "$SLAVE_IP"  ]; then
     echo  -e  '\e[31mYour Choice Error,This Option Only Select On Slave Machine!\e[0m'
     exit  2
fi
}
#        
#####################################################################
#####################################################################
#####################################################################
#
PS3= "Please Input Number:"
select  in  "Configure Master Database(On Master)"  "Configure Slave Database(On Slave)"  "Show Master-Slave Status(On Master)"  "Show Master-Slave(On Slave)"  "Exit"
do
CHOOSE=$REPLY
case  $CHOOSE  in
#####################################################################
1)
JUDGE_MASTER_ID
MASTER_DO
     if  [ $? - eq  0 ]; then
         echo  -e  '\e[32mConfigure Master Database Successfully!\e[0m'
     else
         echo  -e  '\e[31mConfigure Master Database Failure!\e[0m'
     fi
;;
#####################################################################
2)
JUDGE_SLAVE_ID
SLAVE_DO
     if  [ $? - eq  0 ]; then
         echo  -e  '\e[32mConfigure Slave Database Successfully!\e[0m'
     else
         echo  -e  '\e[31mConfigure Slave Database Failure!\e[0m'
     fi
;;
#####################################################################
3)
JUDGE_MASTER_ID
SYNC_STATUS_M
;;
#####################################################################
4)
JUDGE_SLAVE_ID
SYNC_STATUS_S
;;
#####################################################################
5)
echo  -e  '\e[32mByeBye.\e[0m'
exit
;;
#####################################################################
*)
echo  -e  '\e[31mInput Error,Please Input Again!\e[0m'
esac
done

脚本效果图:

要先在Master上执行 1,然后再在Slave上执行2,其它的顺序就无所谓了(其实脚本可以在一台机器上运行,就是在脚本中通过ssh调用另一端的Mysql,还有如果主从失败如何自动修复?以后有时间再写Version 2吧!~)

wKioL1VYPRzSvsMuAAHnsu5xLnw201.jpg

wKiom1VYO6fQVQ8sAAHw_Y4sB_w419.jpg

wKioL1VYPSPhNllMAACngEEDnnY374.jpg

wKiom1VYO6vzEUXNAAEH2etsJoY578.jpg

Done!


本文转自Jacken_yang 51CTO博客,原文链接:http://blog.51cto.com/linuxnote/1652016,如需转载请自行联系原作者

相关实践学习
基于CentOS快速搭建LAMP环境
本教程介绍如何搭建LAMP环境,其中LAMP分别代表Linux、Apache、MySQL和PHP。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
7天前
|
Oracle 关系型数据库 MySQL
linux安装及卸载mysql
在Linux上安装MySQL客户端涉及添加RPM源,运行`yum install mysql-community-client.x86_64 -y`。忘记密码时,编辑`/etc/my.cnf`,添加`skip-grant-tables`,重启MySQL,然后登录修改密码。卸载MySQL需停服,用`rpm -ev`逐个卸载相关组件,删除文件夹,并验证是否卸载干净。重新安装客户端可使用`rpm -ivh`命令。
55 8
|
10天前
|
Shell Linux C语言
|
10天前
|
消息中间件 关系型数据库 MySQL
实时计算 Flink版操作报错合集之整库同步mysql到starRock提交任务异常,该如何处理
在使用实时计算Flink版过程中,可能会遇到各种错误,了解这些错误的原因及解决方法对于高效排错至关重要。针对具体问题,查看Flink的日志是关键,它们通常会提供更详细的错误信息和堆栈跟踪,有助于定位问题。此外,Flink社区文档和官方论坛也是寻求帮助的好去处。以下是一些常见的操作报错及其可能的原因与解决策略。
|
10天前
|
SQL 关系型数据库 MySQL
实时计算 Flink版产品使用问题之要将MySQL同步到Doris,并设置整库同步,只变更库名、表名和表结构都不变,该如何设置
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
10天前
|
关系型数据库 MySQL 数据库
实时计算 Flink版产品使用问题之如何排除某个列进行同步MySQL数据
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
8天前
|
分布式计算 DataWorks 关系型数据库
MaxCompute操作报错合集之配置mysql数据源querysql模式,同步到MC时遇到报错,该怎么处理
MaxCompute是阿里云提供的大规模离线数据处理服务,用于大数据分析、挖掘和报表生成等场景。在使用MaxCompute进行数据处理时,可能会遇到各种操作报错。以下是一些常见的MaxCompute操作报错及其可能的原因与解决措施的合集。
|
9天前
|
DataWorks NoSQL 关系型数据库
DataWorks产品使用合集之如何从Tablestore同步数据到MySQL
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
10天前
|
SQL Oracle 关系型数据库
实时计算 Flink版产品使用问题之在从MySQL同步数据到Doris时,delete语句无法同步,是什么原因
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
10天前
|
SQL 关系型数据库 MySQL
实时计算 Flink版产品使用问题之如何进行MySQL到MySQL的动态同步
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
10天前
|
消息中间件 关系型数据库 MySQL
实时计算 Flink版产品使用问题之从MySQL数据库中捕获变更数据并进行实时处理如何按天分表同步CDC数据
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。