postgresql四种逻辑复制的状态

准备

CreateCheckpoint,或者bgwriter启动时,或者创建logicalreplicationslot时都会调用LogStandbySnapshot 记录一个XLOG_RUNNING_XACTS类型的日志。日志中记录了所有提交的事务的xid(HistoricSnapshot)

启动(SNAPBUILD_BUILDING_SNAPSHOT)

当接收端读到 XLOG_RUNNING_XACTS 时,调用SnapBuildProcessRunningXacts开始记录所有看到的日志,但此时只知道提交的事务,不知道进行中的事务。在没有完整事务状态的情况下,接收端是不能开始apply日志的。这时日志中记录的 nextxid(1) 就是这之后再开启事务时的最小事务号。
请添加图片描述

组装事务状态(SNAPBUILD_FULL_SNAPSHOT)

当接收端再收到 XLOG_RUNNING_XACTS 时,如果发现nextxid(1)之前的日志都提交了,就证明当前从日志收集过的事务,已经是全部在运行的事务了,没有不知道的事务,此时事务状态是完整的,但因为之前收到的非事务的 log 都人为丢弃了,不能对这些事务 apply log,因为事务不完整,这时nextxid(2)记录的就是之后再开启事务的时的最小事务号 。
这时每次 apply 前要判断,要 apply 的这个事务的xid是否在nextxid(2)之前,如果是之前的就不apply,之后的才apply(SnapBuildProcessChange)。
第一次apply的时候会记录一个完整的HistoricSnapshot作为basesnapshot

请添加图片描述

事务状态已完整(SNAPBUILD_CONSISTENT)

当接收端再收到 XLOG_RUNNING_XACTS 时,如果发现nextxid(2)之前的日志都提交了,说明以后收到的 log一定可以 apply,不用再做上面的判断了。
第一次到这个状态时会写一个.snap文件
请添加图片描述

新的事务提交日志(SnapBuildCommitTxn)

在每次处理事务提交日志时,它会感知所有修改系统表的事务,把它们加入新snapshot中(SnapBuildAddCommittedTxn),并把这个新的 snapshot 挂到所有事务的reorderbuffer中(SnapBuildDistributeNewCatalogSnapshot)。当其它事务commit时(DecodeCommit),检查reorder_buffer(ReorderBufferCommit),就会 apply 这个 snapshot (TeardownHistoricSnapshot + SetupHistoricSnapshot)

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

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

相关文章

C# 匿名方法和Lambda表达式

一.匿名方法 1.匿名方法的演变 匿名方法是为了简化委托的实现,方便调用委托方法而出现的,同时,匿名方法也是学好lambda表达式的基础。在委托调用的方法中,如果方法只被调用一次,这个时候我们就没有必要创建具名方法&…

HCIP OSPF的优化总结

OSPF优化 OSPF优化主要目的就是为了减少LSA的更新量,而可以实现者这效果有两种方法 1、路由汇总,可以减少骨干区域的LSA更新量; 2、做OSPF特殊区域,可以减少非骨干区域的更新量。 OSPF的汇总分为两种 1、域间路由汇总 区域间…

专访伊士曼中国区高管赵志伟:以创新应对新能源汽车后市场变化

受访人:伊士曼高性能膜事业部中国区商务总监赵志伟 新能源汽车发展至规模化阶段,以贴膜、保养维修为主的后市场产业迎来快速崛起,新能源消费者在汽车贴膜、改装和养护领域也表现出比燃油车更高频的需求度。 作为一家全球特种材料公司&#x…

【设计模式——学习笔记】23种设计模式——外观模式Facade(原理讲解+应用场景介绍+案例介绍+Java代码实现)

文章目录 案例引入介绍基本介绍类图出场角色 案例实现案例一类图代码实现 案例二类图代码实现 外观模式在Mybatis源码中的应用总结文章说明 案例引入 在家庭影院中,要享受一场电影,需要如下步骤: 直接用遥控器:统筹各设备开关开…

WPF实战学习笔记27-全局通知

新建消息事件 添加文件:Mytodo.Common.Events.MessageModel.cs using Prism.Events; using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading.Tasks; using System.Windows.Diagnostics;namespace Mytod…

蓝海卓越计费管理系统远程命令执行

活着,就要时刻准备承受磨难! 漏洞描述 蓝海卓越计费管理系统存在命令调试页面,导致攻击者可以远程命令执行 漏洞复现 访问 debug.php页面 远程调试命令执行 /debug.php漏洞证明 文笔生疏,措辞浅薄,望各位大佬不吝…

P1427 小鱼的数字游戏

题目描述 小鱼最近被要求参加一个数字游戏,要求它把看到的一串数字 a i a_i ai​(长度不一定,以 0 0 0 结束),记住了然后反着念出来(表示结束的数字 0 0 0 就不要念出来了)。这对小鱼的那点…

iOS--通知、代理、单例模式总结

通知 概要 观察者和被观察者都无需知晓对方,只需要通过标记在NSNotificationCenter中找到监听该通知所对应的类,从而调用该类的方法。并且在NSNotificationCenter中,观察者可以只订阅某一特定的通知,并对齐做出相应操作&#xf…

最后的组合:K8s 1.24 基于 Hekiti 实现 GlusterFS 动态存储管理实践

前言 知识点 定级:入门级GlusterFS 和 Heketi 简介GlusterFS 安装部署Heketi 安装部署Kubernetes 命令行对接 GlusterFS 实战服务器配置(架构 1:1 复刻小规模生产环境,配置略有不同) 主机名IPCPU内存系统盘数据盘用途ks-master-0192.168.9.912450100…

【Java面试丨消息中间件】Kafka

一、kafka是如何保证消息不丢失 1. 介绍 使用kafka在消息的收发过程都有可能会出现消息丢失 (1)生产者发送消息到broker丢失 (2)消息在broker中存储丢失 (3)消费者从broker接收消息丢失 2. 生产者发送消…

在其他jdk语言中调用java

JVM中运行的各种语言底层互通,先天上就具备混合编程的优势。Java在JVM中的老大地位不可撼动,所以诸如Groovy,Kotlin,Scala,Clojure等都可以无痛调用。 文章目录 在Groovy中调用Java在Kotlin中调用java在scala中调用jav…

小程序picker 在苹果手机不兼容 bug,按month时在iPhone 显示不正确及自动定位时间问题

如下图&#xff1a;点击弹出时间列表&#xff1a;日历控件点击选择显示1年1月 解决: 加上起始时间字段 <picker mode"date" value"{{date}}" start"1970-09-01" end"2030-09-01"></picker> 问题二&#xff1a; 还是&a…

【MySQL】事务与隔离级别详解

【MySQL】事务 事务的概念为什么要有事务引擎对事务的支持事务的提交方式事务的操作准备正常事务操作&#xff1a;启动、回滚、提交非正常事务总结 事务的隔离级别隔离性隔离级别隔离级别的查看设置隔离级别会话级别全局级别 隔离级别的具体体现读未提交 Read Uncommitted读提交…

[OpenStack] GPU透传

GPU透传本质就是PCI设备透传&#xff0c;不算是什么新技术。之前按照网上方法都没啥问题&#xff0c;但是这次测试NVIDIA A100遇到坑了。 首先是禁用nouveau 把intel_iommuon rdblacklistnouveau写入/etc/default/grub的cmdline&#xff0c;然后grub2-mkconfig -o /etc/grub2.c…

数学建模学习(6):数学建模数据预处理专题

1 数据预处理是什么&#xff1f; 在数学建模赛题中&#xff0c;官方给所有参赛选手的数据可能受到主 观或客观条件的影响有一定的问题&#xff0c;如果不进行数据的处理而直 接使用的话可能对最终的结果造成一定的影响&#xff0c;因此为了保证数 据的真实性和建模结果的可靠…

一、1、Hadoop的安装与环境配置

安装JDK&#xff1a; 首先检查Java是否已经安装&#xff1a; java -version 如果没有安装&#xff0c;点击链接https://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html 并选择相应系统以及位数下载&#xff08;本文选择jdk-8u381-linux-x64…

Python Web开发技巧VI

“# noqa”什么意思 # noqa 是一个特殊的注释&#xff0c;用于告诉Python的某些代码质量检查工具&#xff08;例如&#xff1a;flake8、pylint等&#xff09;忽略当前行的某些规则检查。noqa 是"No Quality Assurance"&#xff08;不进行质量保证&#xff09;的缩写…

回归预测 | MATLAB实现PSO-GPR粒子群优化高斯过程回归多输入单输出回归预测

回归预测 | MATLAB实现PSO-GPR粒子群优化高斯过程回归多输入单输出回归预测 目录 回归预测 | MATLAB实现PSO-GPR粒子群优化高斯过程回归多输入单输出回归预测预测效果基本介绍程序设计参考资料 预测效果 基本介绍 Matlab基于PSO-GPR基于粒子群算法优化高斯过程回归的数据回归预…

建设银行秋招指南,备考技巧和考试内容详解

建设银行秋招简介 银行作为非常吃香的岗位&#xff0c;每年都有不少同学通过投递简历&#xff0c;进入笔试&#xff0c;再到面试成功&#xff0c;成功到银行就职&#xff0c;也有相当一部分同学因为信息差&#xff0c;符合条件却没有报名。无法进入银行工作。 建设银行的秋招…

QT【day4】

chat_QT服务器端&#xff1a; //.h #ifndef WIDGET_H #define WIDGET_H#include <QWidget> #include<QTcpServer> //服务器类 #include<QTcpSocket> //客户端类 #include<QMessageBox> //对话框类 #include<QList> //链表容器 #inc…