订阅端冲突指PostgreSQL逻辑复制中因数据不一致导致的更新、唯一性或约束冲突，常见于双端写入或数据删除。通过pg_stat_subscription和日志查看状态，利用conflict_resolution设置error、ignore、overwrite等策略应对。应避免订阅者本地写入，采用只读模式、合理主键设计及监控预防，确保复制稳定。
在使用 PostgreSQL 的逻辑复制时，订阅端（Subscriber）可能会遇到冲突问题。这些冲突通常发生在主库（发布者）和从库（订阅者）之间数据不一致的情况下，比如同一行记录在两端被修改，或订阅者上存在本地写入。PostgreSQL 提供了机制来检测和处理这类冲突，但需要合理配置和干预。
什么是订阅端冲突
当订阅者在应用来自发布者的 WAL 日志变更时，发现目标行与预期状态不符，就会触发冲突。常见的冲突类型包括：
- 更新/删除目标不存在：发布者要更新或删除某行，但订阅者上该行已被删除或未插入。
- 唯一性冲突：发布者插入一条记录，但订阅者已存在相同主键或唯一键的记录。
- 约束冲突：如外键、检查等约束导致无法应用变更。
发生冲突时，PostgreSQL 默认会停止复制进程，并在日志中记录错误信息，需手动介入解决。
查看冲突日志和状态
要定位冲突，先查看订阅状态和错误日志：
SELECT * FROM pg_stat_subscription;关注 status 字段是否为“down”，以及 latest_end_time 和错误信息。同时检查数据库日志（log_directory），搜索关键词如“conflict”、“could not apply”等。
还可以通过以下方式获取详细冲突信息：
SELECT * FROM pg_replication_origin_status WHERE roname = 'your_subscription_name';配置冲突处理策略
PostgreSQL 允许在创建订阅时设置冲突处理行为，主要通过 conflict_resolution 参数控制。支持的策略有：
- error：默认行为，遇到冲突报错并停止复制。
- ignore：忽略发布者的更改，保留订阅者现有数据。
- overwrite：用发布者的数据覆盖订阅者的数据。
- skip：跳过当前操作（适用于 INSERT 冲突）。
- update：对冲突的 UPDATE 操作尝试合并更新。
示例：创建订阅时指定策略
CREATE SUBSCRIPTION sub_name CONNECTION 'host=pub_host dbname=db' PUBLICATION pub_name WITH (conflict_resolution = overwrite);注意：该参数仅影响部分类型的冲突，不能完全避免所有问题。
常见场景与解决方案
根据实际业务场景选择合适的处理方式：
- 双端写入导致冲突：禁止在订阅者上进行本地写入。若必须写入，确保操作表不在复制范围内，或使用不同 schema 隔离。
-
临时数据不一致：可手动修复数据后重启订阅：
ALTER SUBSCRIPTION sub_name ENABLE; - 历史数据清理引发冲突：避免在订阅者上删除正在被复制的行。可通过软删除替代物理删除。
- 主键重复插入：检查应用逻辑是否保证全局唯一主键，或使用序列分离范围（如一端用奇数，另一端用偶数）。
对于已发生的冲突，可考虑临时切换为“ignore”或“overwrite”策略让复制追平，再评估数据一致性。
预防冲突的最佳实践
- 订阅者尽量设为只读模式，防止误写。
- 使用 REPLICA IDENTITY 确保复制键完整（尤其是无主键表）。
- 定期监控
pg_stat_subscription状态。 - 测试环境中模拟异常场景，验证冲突处理逻辑。
- 重要系统启用 log_min_messages = debug1 或 log_replication_commands = on 便于排查。
基本上就这些。PostgreSQL 的逻辑复制冲突虽不可避免，但通过合理配置和运维规范可以有效控制。关键是明确数据流向，避免双向修改，同时做好监控和应急响应。
