reorderbuffer.c 源码深度解析:PostgreSQL 逻辑复制的"事务重组引擎

PostgreSQL 的逻辑复制链路:

PostgreSQL 18 流式逻辑复制发布端深度解析:从 logical_decoding_work_mem 到 stream_commit 的完整链路

配套源码:~/cwork/postgresql(基于 PG 18 主干)

从内核开发者视角,在 PostgreSQL 18 逻辑复制中新增一个 GUC 参数

配套源码:~/cwork/postgresql(基于 PG 18 主干)

PostgreSQL 逻辑复制 Apply Parallel Worker 参数调优实战

配套源码:~/cwork/postgresql(基于 PG 18 主干)配套前文:Apply Parallel Worker 运行机制解析

PostgreSQL 逻辑复制 Apply Parallel Worker 运行机制深度解析

源码基线:PostgreSQL 18(src/backend/replication/logical/{applyparallelworker,worker,launcher}.c)

TWPA 概要设计文档

文档版本:v1.0适配版本:PostgreSQL 18源码基线:src/backend/replication/logical/{worker,applyparallelworker,launcher}.c、src/include/replication/{logicalworker,worker_internal}.h

逻辑复制并行 Apply 用户接口文档

文档版本:v1.0适配版本:PostgreSQL 18(含社区已合入的并行 Apply 增强补丁)源码基线:src/backend/replication/logical/{worker,applyparallelworker,launcher,tablesync}.c

TWPA 依赖冲突检测设计文档

文档版本:v1.0适配版本:PostgreSQL 18源码基线:src/backend/replication/logical/{worker,applyparallelworker}.c、src/include/replication/worker_internal.h

PostgreSQL 逻辑复制性能分析:火焰图实战

本文是一份性能分析入门 + 实战指南。前半段讲清楚火焰图和 perf 是什么、怎么用;后半段用 PostgreSQL 逻辑复制的 4 个真实问题,演示怎么用火焰图定位瓶颈。读完你会获得一个完整的"实战方法论"。

PostgreSQL Background Worker 全解：从 `RegisterBackgroundWorker` 到逻辑复制 4 类 worker 的全生命周期

本文是「PostgreSQL 源码系列」并发篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 18 逻辑复制的并行解码与并行 Apply：源码全景

本文是「PostgreSQL 源码系列」的逻辑复制 worker 模型篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制性能与速率测试：从一个公开的"没有"讲起

本文是「PostgreSQL 源码系列」的逻辑复制性能篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制集群搭建指北：基于 Docker 的 publisher + subscriber 一键拉起

本文是「PostgreSQL 逻辑复制系列」的第 N 篇，重点不在原理拆解，而在「用一条 docker compose up -d 把 publisher/subscriber 拉起来」。同系列前文：

PostgreSQL 逻辑复制支持 DDL 之后：DDL 与 DML 的时序难题（重点：分区表）

本文是逻辑复制系列的深度专题。

PostgreSQL 逻辑复制的 ReorderBuffer 与事务机制：从一行 WAL 到一致性变更流的全链路绑定

本文是「PostgreSQL 逻辑复制系列」的第 N 篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制的监控：六张视图 + 一组可执行 SQL，把 publisher/subscriber 的速率与健康度彻底看透

本文是「PostgreSQL 逻辑复制系列」的第 N 篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制 spill 文件深度剖析：从 `xid-*.spill` 到 TPC-C 的增长方程

本文是「PostgreSQL 逻辑复制系列」的 spill 专题。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制 streaming 与 spill：从 reorderbuffer 到 `<subid>-<xid>.changes` 的全程真相

本文是「PostgreSQL 逻辑复制系列」的延伸篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制表的生命周期：从 `pg_replication_slots` 到 `pg_subscription_rel` 的全景图

本文是「PostgreSQL 逻辑复制系列」的第 N 篇。配套源码版本：PostgreSQL 18 dev（~/cwork/postgresql）。同系列前文：

PostgreSQL 逻辑复制：`publish_via_partition_root` 的完整行为分析

本文是分区表 + 逻辑复制系列的第六篇。

PostgreSQL 逻辑复制下分区表的 INSERT：从 publisher 到 leaf 的完整时序

本文是 PostgreSQL 逻辑复制与分区表：从 publisher 到 partition leaf 的全链路 的深度细化篇。

PostgreSQL 逻辑复制：DDL 同步后如何启动 apply worker 同步 DML（分区表专题）

本文是 PostgreSQL 逻辑复制的 Worker 模型 与 PostgreSQL 逻辑复制与分区表：从 publisher 到 partition leaf 的全链路 的姊妹篇。

PostgreSQL 逻辑复制的 Worker 模型：一个 apply worker 撑全场，分区表也一样

本文是 PostgreSQL 逻辑复制与分区表：从 publisher 到 partition leaf 的全链路 的姊妹篇。

PostgreSQL 逻辑复制与分区表：从 publisher 到 partition leaf 的全链路

本文是 PostgreSQL 分区表：从一行 PARTITION BY 到路由热路径的全链路拆解 的姊妹篇。

PostgreSQL 逻辑复制订阅参数全解：从 run_as_owner 到 disable_on_error

CREATE SUBSCRIPTION 那一长串 WITH (...) 参数，每个都对应 pg_subscription 系统表里的一列，背后是 apply worker 一段真实的代码分支。

13 逻辑复制深入

目标：吃透 PG 的 logical replication 全套机制——logical decoding、ReorderBuffer、output plugin、publication/subscription、initial sync、conflict handling、walsummarizer。这是 PG 实现跨大版本、跨表、跨粒度复制的核心能力。

逻辑解码DDL Replay框架设计

当前逻辑复制支持DDL同步功能已适配PG模式，其整体流程如下：

postgresql逻辑复制(DML)

postgresql逻辑复制采用发布者订阅者模式，并且发布者和订阅者之间是多对多的关系。

逻辑复制适配sqlserver模式分区表问题分析

问题原因：逻辑复制同步DDL在sqlserver模式下不支持分区表同步，根本原因为分区表创建依赖于Partition Function 、Partition Scheme，但这两个语句不走PG标准的执行流程（ProcessUtility），无法被捕获。

逻辑复制支持同步系统表概要设计

下面给你一份基于 PG18 的“逻辑复制支持系统表同步”完整设计文档（可直接用于研发/评审）。我会严格结合你前面分析的源码链路来设计，重点保证：

PostgreSQL 逻辑复制支持系统表同步详细设计文档

本设计的目标不是实现完整 DDL 自动复制链路，而是先补齐以下两项基础能力：

逻辑复制同步ddl适配bbf面临的挑战

1.当前产品面向比亚迪现场，现场需要sqlserver模式，当前sqlserver模式下的逻辑复制能力范围边界尚不清楚；（从产品和架构层面出发评估）

支持逻辑复制同步 DDL 适配 SQL Server 方案

Babelfish 是 PostgreSQL 的一个扩展，通过双端口设计支持 SQL Server 协议：

内核执行 Babelfish 上下文需要考虑的问题

SQL Server 和 PG 本身在数据库架构层面 schema 的含义就不一致：

sqlserver模式逻辑复制支持ddl

当前数据库使用babelfish插件（bbf）来支持sqlserver模式，bbf采用双端口的设计：即数据库在启动时会监听多个端口，一般是pg原生的端口和tsql端口，比如5432和1433.

Babelfish DDL 同步已知限制与客户使用建议

本文档汇总 Babelfish 插件在 SQL Server 模式下使用逻辑复制 DDL 自动同步时的已知限制，并按客户使用影响给出分级和建议做法。

逻辑解码ddl replay支持sqlserver模式

当前 PostgreSQL Logical Replication 仅支持 DML 同步。

逻辑复制系统表支持DDL实现问题

逻辑解码会过滤掉系统表，不支持系统表进行逻辑解码；2. pglogical使用的是用户表，并使用usercatalogtable=true;

逻辑复制支持ddl ai配置流程

逻辑复制支持DDL概要设计

PostgreSQL 当前内建逻辑复制主要覆盖表级 DML 复制。logical decoding 的本质是从 WAL 中提取持久化变更，转成更高层可理解的变更流；复制槽保证“按源端发生顺序”向客户端提供变化序列。([PostgreSQL][1])

逻辑复制支持DDLAI提示词

逻辑复制需要支持自动同步DDL。

1. 设计选择

可以，下面我直接给你一版接近 PostgreSQL patch 风格的 LogLogicalDDLMessage() 实现草稿。它的设计核心是：复用 PostgreSQL 现有 generic logical decoding message 的 WAL 记录格式与写入路径。

一、结论（先说清楚）

这个问题非常关键，而且是内核方案必须回答清楚的两个核心风险：

逻辑复制DDL支持详细设计方案

逻辑复制当前仅支持同步DML操作。为了提升用户使用体验和增强逻辑复制功能，需要扩展支持DDL（数据定义语言）的自动同步。

逻辑复制验证步骤

1.使用root用户执行如下编译

逻辑复制解惑

在初次写入数据的时候，ddl写到了系统表，dml先写入日志，然后apply成数据。当前逻辑复制的原理是根据lsn读取wal日志，将wal日志decode成sql，然后发送目标端。

逻辑复制源码分析

逻辑复制与物理复制使用相同的发送框架，都在walsender中进行发送。整体流程大致如下：

逻辑复制支持DDL开发交付计划

[x] 添加用户接口和参数校验；- [x] 新增系统表pgpublicationsync；- [x] 客户端DDL捕获保存

支持ddl评审相关问题

一个DDL需要多个事务，比如在线建分区；2. 性能问题；（发布性能较低，流式发布）3. 用户接口跟产品确认；（用户接口清单，ddl同步范围），table和others的清单列出；

指定列同步对逻辑复制支持DDL的影响

在逻辑复制支持DDL的需求分析中，需要考虑如下场景：

PostgreSQL 15 逻辑复制操作流程详解

本文通过实际操作演示 PostgreSQL 15 逻辑复制的完整流程，重点展示：- WAL（Write-Ahead Logging）日志的生成与解析

PostgreSQL `LogLogicalMessage`

本文面向需要理解 PostgreSQL 逻辑复制/逻辑解码链路的开发人员，解释 LogLogicalMessage 的定位、内部实现、设计初衷和工程使用方式。

逻辑复制支持DDL需求分析

postgresql当前的逻辑复制仅支持复制DML，不支持复制DDL，需要手动在目标端执行DDL。

pglogical支持DDL搭建

使用如下命令初始化数据库：

pglogical.so详解

pglogical.so是pglogical中的数据库扩展（extension），负责管理复制拓扑、节点、replication set、apply worker 等控制逻辑。

pg15逻辑复制支持DDL

如果你的目标是：

逻辑解码支持DDL

逻辑解码需要源端数据库把DDL转换成某一种格式存储，可以是某种数据库语法格式的sql或者其他格式的文本文件，比如json。

polardb逻辑解码

对于同构数据库，由于polardb采用共享存储实现，其会把DDL写入wal，因为只有一份物理数据，采用DDL锁同步DDL；

pglogical详解

pglogical 是 PostgreSQL 的拓展模块, 为 PostgreSQL 数据库提供了逻辑流复制发布和订阅的功能。

ai逻辑解码

基于对PolarDB源码和PostgreSQL LogLogicalMessage 机制的分析，以下是DDL自动传输的实现原理详解：

DDL

数据定义语言（DDL）是SQL（结构化查询语言）的一部分，它用于定义、管理和控制数据库的结构和元素。

逻辑解码

逻辑解码（Logical Decoding）是 PostgreSQL（及其扩展版本）提供的一套机制，用来将 WAL（物理日志）中的数据修改恢复成“逻辑级别”的变更事件：