流复制与高可用

流复制（Streaming Replication） 将 WAL 实时传到备库；配合 Patroni / repmgr 可实现自动故障切换。与 /roadmaps/postgresql-dba 复制节点对齐。

学习目标

CREATE ROLE replicator LOGIN REPLICATION PASSWORD 'replpass';

wal_level = replica
max_wal_senders = 10
max_replication_slots = 10
synchronous_commit = on   -- 同步复制时
synchronous_standby_names = 'standby1'

pg_basebackup -h primary-host -U replicator -D /var/lib/pgsql/data \
  -Fp -Xs -P -R -S standby1

-R 写入 primary_conninfo；备库 hot_standby = on 可只读查询。

SELECT client_addr, state, sync_state,
       pg_wal_lsn_diff(pg_current_wal_lsn(), replay_lsn) AS lag_bytes
FROM pg_stat_replication;

-- 备库
SELECT pg_is_in_recovery(), pg_last_wal_replay_lsn();

lag 持续增大需查网络、磁盘或备库负载。

Spring 写 → Primary
Spring 读（可选）→ Replica（注意复制延迟读旧数据）

可用 Hikari 双数据源 或中间件；与 MySQL 主从只读实例思路相同。

本站生产 MySQL 主库；PG 练习可用 Docker 两容器模拟 primary/standby。