欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  IT编程

数据库的高可用

程序员文章站 2022-03-23 09:21:48
数据库的高可用1. 什么是数据库的高可用当其中有一台数据库出现宕机之后,用户依然可以正确的访问数据库,而不受任何影响(实现了故障迁移),主要数据库能够正常的工作,则重新启动数据库之后则可以实现自动的数据的同步.2. 项目部署之后问题?1.当数据库宕机之后,可能会导致数据丢失,必须通过某些策略,保证数据的有效性.2.如果后端的数据库宕机,则通过某些技术手段可以实现高可用(实现自动的故障迁移)3. 数据库数据同步3.1 数据库同步的流程图3.2 数据库备份3.2.1 数据库冷备份定期将数据...

数据库的高可用

1. 什么是数据库的高可用

当其中有一台数据库出现宕机之后,用户依然可以正确的访问数据库,而不受任何影响(实现了故障迁移),主要数据库能够正常的工作,则重新启动数据库之后则可以实现自动的数据的同步.

2. 项目部署之后问题?

1.当数据库宕机之后,可能会导致数据丢失,必须通过某些策略,保证数据的有效性.
2.如果后端的数据库宕机,则通过某些技术手段可以实现高可用(实现自动的故障迁移)

3. 数据库数据同步

3.1 数据库同步的流程图

数据库的高可用

3.2 数据库备份

3.2.1 数据库冷备份

定期将数据库内容进行转储. 弊端:可能丢失数据,公司也会采用冷备份的方式以防万一.
数据库的高可用

3.2.2 数据库热备份

  • 特点: 可以保证数据的实时备份
    数据库的高可用
  • 工作原理说明:
    1.数据库主库将更新的数据信息写入到二进制日志文件(Binary log)中.
    2.数据库从库通过IO线程去主库中获取二进制文件修改内容,之后写入到中继日志(Relay log)中.
    3.数据库从库中的Sql线程读取中继日志中的信息,实现数据的同步.
    同时为了降低组件的耦合性,采用异步的方式处理.

4. 准备第二台Linux系统

4.1 运行虚拟机并修改名称

数据库的高可用

4.2 修改虚拟机IP地址

规定: 主机IP地址 192.168.126.129 从机 192.168.126.130
1).进入修改IP地址目录
命令: cd /etc/sysconfig/network-scripts/
数据库的高可用
2). 修改配置文件信息
数据库的高可用
3). 重置网卡
数据库的高可用

5.在slave中安装数据库

参考Linux项目环境搭建

5.2 利用sqlYog工具链接从库

数据库的高可用

5.3 实现数据库的导入导出

注意:在实现数据库主从之前,最好让主库和从库的数据库中的数据一致.

5.4 数据库主从配置

  • 开启数据库二进制文件
    说明:默认条件下,数据库二进制文件是关闭的,如果需要开启,则必须手动配置,之后重启数据库.
    修改配置文件命令: vim /etc/my.cnf
    数据库的高可用
  • 修改之后,重启数据库
    数据库的高可用

5.5 从库开启二进制文件

和主库开启二进制方式是一致的,唯一的不同是配置文件(my.cnf)中的server-id 的值

6. 查询主库状态

  • 在数据库中执行如下指令
    命令: show master status;
    数据库的高可用
  • 主从数据库挂载
    如果需要实现数据库的主从同步,应该从库向主库进行挂载
    数据库的高可用
  • 挂载报错说明
    1.先查询日志信息
    2.修改数据库配置之后重启
    3.停止主从服务 STOP SLAVE;
    4.重新挂载数据库

7. 数据库读写分离-负载均衡机制

7.1 读写分离说明

说明:当数据库执行写操作时,应该操作主库,如果用户进行读操作时应该读从库.

实现该机制需要准备一个代理数据库服务器.
数据库的高可用

7.2 Mycat 数据库分库分表中间件

  • 在主机中安装并解压Mycat

数据库的高可用

  • server.xml
    注意:数据库代理的默认端口号 8066端口
<?xml version="1.0" encoding="UTF-8"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the "License"); 
	- you may not use this file except in compliance with the License. - You 
	may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 
	- - Unless required by applicable law or agreed to in writing, software - 
	distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT 
	WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the 
	License for the specific language governing permissions and - limitations 
	under the License. -->
<!DOCTYPE mycat:server SYSTEM "server.dtd">
<mycat:server xmlns:mycat="http://io.mycat/">
	<system>
        <property name="nonePasswordLogin">0</property> <!-- 0为需要密码登陆、1为不需要密码登陆 ,默认为0-->
	<property name="useHandshakeV10">1</property>
	<property name="useSqlStat">0</property>  <!-- 1为开启实时统计、0为关闭 -->
	<property name="useGlobleTableCheck">0</property>  <!-- 1为开启全加班一致性检测、0为关闭 -->

		<property name="sequnceHandlerType">2</property>
      <!--  <property name="useCompression">1</property>--> <!--1为开启mysql压缩协议-->
        <!--  <property name="fakeMySQLVersion">5.6.20</property>--> <!--设置模拟的MySQL版本号-->
	<!-- <property name="processorBufferChunk">40960</property> -->
	<!-- 
	<property name="processors">1</property> 
	<property name="processorExecutor">32</property> 
	 -->
        <!--默认为type 0: DirectByteBufferPool | type 1 ByteBufferArena | type 2 NettyBufferPool -->
		<property name="processorBufferPoolType">0</property>
		<!--默认是65535 64K 用于sql解析时最大文本长度 -->
		<!--<property name="maxStringLiteralLength">65535</property>-->
		<!--<property name="sequnceHandlerType">0</property>-->
		<!--<property name="backSocketNoDelay">1</property>-->
		<!--<property name="frontSocketNoDelay">1</property>-->
		<!--<property name="processorExecutor">16</property>-->
		<!--
			<property name="serverPort">8066</property> <property name="managerPort">9066</property> 
			<property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property> 
			<property name="frontWriteQueueSize">4096</property> <property name="processors">32</property> -->
		<!--分布式事务开关，0为不过滤分布式事务，1为过滤分布式事务（如果分布式事务内只涉及全局表，则不过滤），2为不过滤分布式事务,但是记录分布式事务日志-->
		<property name="handleDistributedTransactions">0</property>
		
			<!--
			off heap for merge/order/group/limit      1开启   0关闭
		-->
		<property name="useOffHeapForMerge">1</property>

		<!--
			单位为m
		-->
        <property name="memoryPageSize">64k</property>

		<!--
			单位为k
		-->
		<property name="spillsFileBufferSize">1k</property>

		<property name="useStreamOutput">0</property>

		<!--
			单位为m
		-->
		<property name="systemReserveMemorySize">384m</property>


		<!--是否采用zookeeper协调切换  -->
		<property name="useZKSwitch">true</property>

		<!-- XA Recovery Log日志路径 -->
		<!--<property name="XARecoveryLogBaseDir">./</property>-->

		<!-- XA Recovery Log日志名称 -->
		<!--<property name="XARecoveryLogBaseName">tmlog</property>-->

	</system>
	
	<!-- 全局SQL防火墙设置 -->
	<!--白名单可以使用通配符%或着*-->
	<!--例如<host host="127.0.0.*" user="root"/>-->
	<!--例如<host host="127.0.*" user="root"/>-->
	<!--例如<host host="127.*" user="root"/>-->
	<!--例如<host host="1*7.*" user="root"/>-->
	<!--这些配置情况下对于127.0.0.1都能以root账户登录-->
	<!--
	<firewall>
	   <whitehost>
	      <host host="1*7.0.0.*" user="root"/>
	   </whitehost>
       <blacklist check="false">
       </blacklist>
	</firewall>
	-->
	<!--用户标签,和数据库配置直接相关-->
	<user name="root">
		<property name="password">root</property>
		<!--与schema.xml中的配置相同 注意数据库的大小写-->
		<property name="schemas">jtdb</property>
	</user>

	<user name="user">
		<property name="password">user</property>
		<property name="schemas">jtdb</property>
		<property name="readOnly">true</property>
	</user>
</mycat:server>
  • schema.xml
    配置说明:该配置配置了读写分离/负载均衡的设置
<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
	
	<!--name属性是自定义的  dataNode表示数据库的节点信息  jtdb表示逻辑库-->
	<schema name="jtdb" checkSQLschema="false" sqlMaxLimit="100" dataNode="jtdb"/>

	<!--定义节点名称/节点主机/数据名称-->
	<dataNode name="jtdb" dataHost="localhost1" database="jtdb" />
		<!--参数介绍-->
		<!--balance 0表示所有的读操作都会发往writeHost主机 -->  
		<!--1表示所有的读操作发往readHost和闲置的主节点中-->
		<!--writeType=0 所有的写操作都发往第一个writeHost主机-->	
		<!--writeType=1 所有的写操作随机发往writeHost中-->
		<!--dbType 表示数据库类型 mysql/oracle-->
		<!--dbDriver="native"  固定参数 不变-->
		<!--switchType=-1 表示不自动切换, 主机宕机后不会自动切换从节点-->
		<!--switchType=1  表示会自动切换(默认值)如果第一个主节点宕机后,Mycat会进行3次心跳检测,如果3次都没有响应,则会自动切换到第二个主节点-->
		<!--并且会更新/conf/dnindex.properties文件的主节点信息 localhost1=0 表示第一个节点.该文件不要随意修改否则会出现大问题-->
	<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
			  writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
		<!--心跳检测策略 -->	  
		<heartbeat>select 1</heartbeat>

		<!--配置第一台主机主要进行写库操作,在默认的条件下Mycat主要操作第一台主机在第一台主机中已经实现了读写分离.因为默认写操作会发往137的数据库.读的操作默认发往141.如果从节点比较忙,则主节点分担部分压力.
		-->
		<writeHost host="hostM1" url="192.168.126.129:3306" user="root" password="root">
			<!--读数据库1-->
			<readHost host="hostS1" url="192.168.126.130:3306" user="root" password="root" />
			<!--读数据库2-->
			<readHost host="hostS2" url="192.168.126.129:3306" user="root" password="root" />
			
		</writeHost>

			<!--定义第二台主机 由于数据库内部已经实现了双机热备.-->
			<!--Mycat实现高可用.当第一个主机137宕机后.mycat会自动发出心跳检测.检测3次.-->
			<!--如果主机137没有给Mycat响应则判断主机死亡.则回启东第二台主机继续为用户提供服务.-->
			<!--如果137主机恢复之后则处于等待状态.如果141宕机则137再次持续为用户提供服务.-->
			<!--前提:实现双机热备.-->
		
		 <writeHost host="hostM2" url="192.168.126.130:3306" user="root" password="root"> 
			<!--读数据库1-->
			 <readHost host="hostS1" url="192.168.126.130:3306" user="root" password="root" /> 
			<!--读数据库2-->
			 <readHost host="hostS2" url="192.168.126.129:3306" user="root" password="root" />
		</writeHost>
		
	</dataHost>
</mycat:schema>
  • 上传配置文件
    1),删除原有配置文件信息
    命令:rm -rf schema.xml server.xml
    2). 上传新的配置文件
  • 启动Mycat服务器
    启动Mycat: ./mycat start
    数据库的高可用
  • 启动效果
    数据库的高可用

7.3 修改yml文件配置数据库的高可用

7.4 数据库的双机热备

  • 把从库设置成主库,方法和**6.**一致
    注意事项:搭建前保证数据库的数据一致(更新操作)
  • 实现主从挂载
/*我之前是主库   现在是从库*/
CHANGE MASTER TO 
MASTER_HOST="192.168.126.130",
MASTER_PORT=3306,
MASTER_user="root",
MASTER_PASSWORD="root",
MASTER_LOG_FILE="mysql-bin.000001",
MASTER_LOG_POS=482;

/* 启动主从服务*/
start  slave	

show SLAVE status;

最后重启Mycat服务器和测试.

本文地址：https://blog.csdn.net/weixin_47081743/article/details/107367748

相关标签： 分布式 分布式

上一篇： 面试了字节、阿里等大厂，今年面试到底问什么？（Java岗）

下一篇： 【C语言】【数据结构】二叉树、二叉排序树各种算法

推荐阅读