Message (logical replication)

说明

Byte1('M') 将消息标识为逻辑解码消息。 Int32 (TransactionId) 事务的 Xid（仅在流式传输的事务中出现）。此字段从协议版本 2 起可用。 Int8 标志：0 表示没有标志；1 表示该逻辑解码消息是事务性的。 Int64 (XLogRecPtr) 逻辑解码消息的 LSN。 String 逻辑解码消息的前缀。 Int32 内容的长度。 Byte n 逻辑解码消息的内容。

层次

逻辑复制载荷，与前后端消息封装分开。

首个字段

Byte1('M')

用法

Message

协议上下文

本节说明各逻辑复制消息的详细格式。这些消息由复制槽 SQL 接口返回，或由 walsender 发送。由 walsender 发送时，它们被封装在复制协议的 WAL 消息中（参见第 54.4 节），消息流程通常与物理复制相同。Stream Start、Stream Stop、Stream Commit 和 Stream Abort 从协议版本 2 起可用。Begin Prepare、Prepare、Commit Prepared、Rollback Prepared 和 Stream Prepare 从协议版本 3 起可用。以下消息部分为上述消息所共用。

相关条目

• 流复制协议
• 逻辑解码插件

文档与源码

• PostgreSQL 18 English manual

版本比较

PostgreSQL 13 → 14: 新增收录。

以下差异保留原始字段名与英文源描述。

--- PostgreSQL 13
+++ PostgreSQL 14
@@ -1 +1,33 @@
-该版未收录
+{
+  "fields": [
+    {
+      "description": "Identifies the message as a logical decoding message.",
+      "format": "Byte1('M')"
+    },
+    {
+      "description": "Xid of the transaction (only present for streamed transactions). This field is available since protocol version 2.",
+      "format": "Int32"
+    },
+    {
+      "description": "Flags; Either 0 for no flags or 1 if the logical decoding message is transactional.",
+      "format": "Int8"
+    },
+    {
+      "description": "The LSN of the logical decoding message.",
+      "format": "Int64"
+    },
+    {
+      "description": "The prefix of the logical decoding message.",
+      "format": "String"
+    },
+    {
+      "description": "Length of the content.",
+      "format": "Int32"
+    },
+    {
+      "description": "The content of the logical decoding message.",
+      "format": "Byte n"
+    }
+  ],
+  "layer": "logical replication"
+}

比较已记录的接口与属性，排除来源指纹和构建元数据。某个样本中没有记录，不能据此判断实际引入或移除的版本。

相关条目

• Begin (logical replication)
• Begin Prepare (logical replication)
• Commit (logical replication)
• Commit Prepared (logical replication)
• Delete (logical replication)
• Insert (logical replication)
• Origin (logical replication)
• Prepare (logical replication)
• Relation (logical replication)
• Rollback Prepared (logical replication)
• Stream Abort (logical replication)
• Stream Commit (logical replication)