MySQL的半同步模式

news2024/11/14 20:35:25

MySQL 的半同步复制

MySQL 的半同步复制(Semi-Synchronous Replication, SSR)是一种增强的复制机制,旨在减少主服务器(Master)发生故障时的数据丢失风险,并在一定程度上提高复制的可靠性。半同步复制结合了异步复制和全同步复制的优点,既提高了系统的可用性也增强了数据的一致性。
在这里插入图片描述

半同步复制的工作原理

在传统的异步复制中,主服务器将事务提交到二进制日志(bin-log)后,会立即向客户端返回成功响应,而不管从服务器(Slave)是否已经接收到该事务。这种方式虽然提供了较高的系统吞吐量,但在主服务器突然宕机的情况下,尚未被从服务器接收的事务可能会丢失。

在全同步复制中,主服务器只有在至少一个从服务器确认接收到事务后才会返回成功响应。这种方法虽然保证了数据的一致性,但由于等待从服务器确认的时间可能会造成性能下降。

半同步复制则试图在这两者之间找到平衡。在这种模式下,主服务器在提交事务前会等待至少一个从服务器确认接收到了该事务的二进制日志事件。一旦得到确认,主服务器就会向客户端返回成功响应,并继续处理下一个事务。这样做的好处是,在大多数情况下,可以保证至少有一个从服务器拥有最新的数据,从而减少了数据丢失的风险。

1.用户线程写入完成后master中的dump会把日志推送到slave端
2.slave中的io线程接收后保存到relaylog中继日志
3.保存完成后slave向master端返回ack
4.在未接受到slave的ack时master端时不做提交的,一直处于等待当收到ack后提交到存储引擎
5.在5.6版本中用到的时after_commit模式,after_commit模式时先提交在等待ack返回后输出ok

配置半同步复制

要配置 MySQL 的半同步复制,您需要对主服务器和从服务器进行一些特定的配置。以下是基本的配置步骤:

主服务器配置
  1. 安装半同步插件:确保您的 MySQL 版本支持半同步插件。对于 MySQL 5.7 及更高版本,半同步复制插件通常是默认包含的。如果您的 MySQL 版本不包含此插件,您需要手动安装。

  2. 配置主服务器:编辑 MySQL 的配置文件(通常是 my.cnfmy.ini),添加半同步复制相关的配置项。

[mysqld]
datadir=/data/mysql
socket=/data/mysql/mysql.sock
server-id=1
log-bin=mysql-bin
gtid_mode=ON
enforce-gtid-consistency=ON
rpl_semi_sync_master_enabled=1 
symbolic-links=0

rpl_semi_sync_master_enabled=1启用半同步功能
3.安装半同步插件

INSTALL PLUGIN rpl_semi_sync_master SONAME 'semisync_master.so';

4.查看插件情况

mysql> SELECT PLUGIN_NAME, PLUGIN_STATUS
-> FROM INFORMATION_SCHEMA.PLUGINS
-> WHERE PLUGIN_NAME LIKE '%semi%';
+----------------------+---------------+
| PLUGIN_NAME | PLUGIN_STATUS |
+----------------------+---------------+
| rpl_semi_sync_master | ACTIVE |
+----------------------+---------------+
1 row in set (0.01 sec)

5.打开半同步功能

SET GLOBAL rpl_semi_sync_master_enabled = 1;
从服务器配置
  1. 安装半同步插件:安装半同步复制插件。
INSTALL PLUGIN rpl_semi_sync_slave SONAME 'semisync_slave.so';
  1. 配置从服务器:同样编辑 MySQL 的配置文件,添加半同步复制相关的配置项。
[mysqld]
datadir=/data/mysql
socket=/data/mysql/mysql.sock
server-id=1
log-bin=mysql-bin
gtid_mode=ON
enforce-gtid-consistency=ON
rpl_semi_sync_master_enabled=1 #开启半同步功能
symbolic-links=0
  • rpl_semi_sync_slave_enabled: 启用半同步复制。
  1. 重启 MySQL 服务:重启 IO线程,半同步服务才能生效。
 STOP SLAVE IO_THREAD; 
 START SLAVE IO_THREAD; 
设置复制关系

完成上述配置后,您需要按照常规的主从复制配置步骤来建立主从复制关系。包括创建复制用户、获取主服务器的二进制日志文件名和位置、初始化从服务器数据、配置从服务器指向主服务器等。

测试半同步复制

  • 检查状态:您可以使用 SHOW VARIABLES LIKE '%semi_sync%'; 来检查半同步复制的相关变量是否已被正确设置。
  • 监控状态:通过 SHOW STATUS LIKE '%semi_sync%'; 查看半同步复制的运行状态。

注意事项

  • 性能影响:半同步复制会增加主服务器的延迟,因为主服务器需要等待从服务器的确认才能继续处理下一个事务。不过,由于只需要等待至少一个从服务器的确认,所以性能影响相对较小。
  • 配置灵活性:您可以选择等待一个以上的从服务器确认。这可以通过修改 rpl_semi_sync_master_wait_for_slave_count 变量来实现。
  • 故障转移:半同步复制本身并不提供自动故障转移的功能。您需要另外配置故障检测和自动切换机制,如使用 MySQL Group ReplicationPercona XtraDB Cluster 等解决方案。

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

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

相关文章

零基础5分钟上手亚马逊云科技-高可用负载均衡器

简介: 欢迎来到小李哥全新亚马逊云科技AWS云计算知识学习系列,适用于任何无云计算或者亚马逊云科技技术背景的开发者,通过这篇文章大家零基础5分钟就能完全学会亚马逊云科技一个经典的服务开发架构方案。 我会每天介绍一个基于亚马逊云科技…

怎么将文档翻译成英语?5个方法一键将文档翻译成所需语言

夏日的尾声,处暑的凉风轻轻拂过,不仅带来了季节的更迭,也悄然拉开了国际交流的新序幕。 那份精心雕琢的处暑宣传文案,字字珠玑,情感饱满。但别急,想要这份佳作跨越语言的长河,触及更广阔的国际…

中资优配:信用债市场遭遇卖盘压力

近期,诺言债遭受卖盘压力,连跌多日,引发商场关注。 近两日,诺言债商场出现回调,工业债、城投债与二级本钱债价格均出现跌落。到8月27日收盘,“24兴业银行二级本钱债01”上行7.5个基点至2.355%,…

佰朔资本:股指预计保持震荡格局 关注化学制药、石油化工等板块

2024年1—7月规上工业企业赢利平稳增加,较前值略有上升。工业企业赢利能否企稳的要害在于有用需求,其时以价换量特征依然显着,供应快于需求使得工业企业库存继续被动冲高。在内需方面,大规模设备更新、消费品以旧换新政策有助于继…

uboot环境变量擦除之烧录工具擦除flash mtd0分区

有时会uboot环境变量修改了没有生效,需要擦除整个mtd分区 Erasing at 0x100000 – 100% complete. (1M) uboot给flash的中分区

正方体挖出几小块后的体积

如图,有一个边长为20厘米的大正方体,分别在它的角上、棱上、面上各挖掉一个大小相同的小立方体后,表面积变为2454平方厘米,那么挖掉的小立方体的边长是多少厘米?() A 2 B 2.5 C 3【正确答案】 D 3.5 这道题和上一期《立体空间想象…

算法学习-基础数据结构

基础数据结构 一.栈 1.普通栈 套路:从前往后遍历 需要考虑相邻元素 有消除操作 栈。 2.单调栈 二.队列 1.普通队列 2.优先队列 三.Trie 使用场景:可以求某个字符串在众多字符串中出现的次数,以某个字符串为前缀出现的次数 Trie中…

设计一个最小栈

问题 请你设计一个 最小栈 。它提供 push ,pop ,top 操作,并能在常数时间内检索到最小元素的栈。 实现 MinStack 类: MinStack() 初始化堆栈对象。void push(int val) 将元素val推入堆栈。void pop() 删除堆栈顶部的元素。int top() 获取堆…

昂科烧录器支持MindMotion灵动微电子的微控制器MM32F5333D7P

芯片烧录行业领导者-昂科技术近日发布最新的烧录软件更新及新增支持的芯片型号列表,其中MindMotion灵动微电子的32位微控制器MM32F5333D7P已经被昂科的通用烧录平台AP8000所支持。 MM32F5333D7P微控制器搭载了由安谋科技授权的Armv8-M架构“星辰”STAR-MC1处理器&a…

Redux的中间件原理分析

Redux的中间件原理分析 redux的中间件对于使用过redux的各位都不会感到陌生,通过应用上我们需要的所有要应用在redux流程上的中间件,我们可以加强dispatch的功能。最近抽了点时间把之前整理分析过的中间件有关的东西放在这里分享分享。本文只对中间件涉…

在线客服系统源码 完全开源可二开 带完整的安装代码包以及搭建部署教程

系统概述 在线客服系统是一种基于互联网技术的客户服务解决方案,通过即时通讯工具,如文本聊天、语音通话、视频交流等方式,实现企业与客户之间的实时互动。它打破了传统客服模式的时空限制,使客户能够在任何时间、任何地点获得快…

Java基础(4)- IDEA

目录 一、Module 1.创建module 2.关闭modue 3.导入module 4.src灰色 二、Package 1.创建package 2.删除package 3.package取名规范 三、类 1.创建类 2.快捷语法 3.HelloWorld 四、IDEA基本设置说明 1.字体 2.提示的快捷键 五、常用快捷键 一、Module 1.创建mod…

Python大数据之Hadoop学习——day05_hive基本操作

一.SQL,Hive和MapReduce的关系 用户在hive上编写sql语句,hive把sql语句转为mapreduce程序去执行 二.Hive的架构映射流程 三.MetaStore元数据管理三种模式 metastore服务配置有3种: 内嵌模式、本地模式、远程模式(推荐) 内嵌模式…

【一文读懂】基于Havenask向量检索+大模型,构建可靠的智能问答服务

Havenask是阿里巴巴智能引擎事业部自研的开源高性能搜索引擎,深度支持了包括淘宝、天猫、菜鸟、高德、饿了么在内的几乎整个阿里的搜索业务。本文针对性介绍了Havenask作为一款高性能的召回搜索引擎,应用在向量检索和LLM智能问答场景的解决方案和核心优势…

泰山派小手机---ubuntu 环境的搭建

问题: 本来我的 泰山派的 ubuntu 虚拟机环境已经搭建好了,但是由于一直到捣鼓 neovim ,把虚拟机 内核搞崩溃,所以从新安装一下 虚拟机。 过程: 1 首先是 安装虚拟机。 下载镜像。 https://mirrors.ustc.edu.cn/ubu…

密码强度验证——js基础积累

//密码强度等级 getPwdLevel:function (pwd,minLength8) {var level 0;if (pwd.length < minLength) return level;if (/\d/.test(pwd)) level; //数字if (/[a-z]/.test(pwd)) level; //小写if (/[A-Z]/.test(pwd)) level; //大写if (/\W/.test(pwd)) level; //特殊字符ret…

安卓好软-----手机端提取apk的小工具 方便简单 无需root权限

apk提取工具 工具小巧。可以提取手机上面当前安装的apk和系统应用apk。而且无需root权限即可正常使用。 效果非常不错。比其他工具提取系统app方便好使。 下载&#xff1a;https://download.csdn.net/download/mg668/89683199?spm1001.2014.3001.5503

副业赚钱新玩法:大模型也能月入过万?

在这个多元化的时代&#xff0c;副业已经成为了越来越多人的选择。无论是为了实现个人兴趣&#xff0c;还是为了增加收入来源&#xff0c;副业都为我们提供了无限可能。而随着人工智能技术的飞速发展&#xff0c;利用大模型来开展副业也成为了一种新兴的方式。今天&#xff0c;…

日常避坑指南:如何正确使用 aiohttp 上传文件,避免文件被提前关闭

在日常开发中,我们经常会遇到需要上传文件到服务器的场景。如果你选择使用 aiohttp 进行异步请求,上传文件的方式需要特别注意,否则可能会遇到一些令人头疼的问题——比如文件被提前关闭,导致上传失败。这篇文章将为你详细解析这个问题,并提供有效的解决方案,帮助你在开发…

Mysql基础练习题 181.找到收入比经理高的员工 (力扣)

181.找到收入比经理高的员工 建表插入数据&#xff1a; Create table If Not Exists Employee (id int, name varchar(255), salary int, managerId varchar(10)); Truncate table Employee insert into Employee (id, name, salary, managerId) values (1, Joe, 70000, 3); …