背景

1、PG物理流复制的从库，当激活后，可以开启读写，使用pg_rewind可以将从库回退为只读从库的角色。而不需要重建整个从库。2、当异步主从发生角色切换后，主库的wal目录中可能还有没完全同步到从库的内容，因此老的主库无法直接切换为新主库的从库。使用pg_rewind可以修复老的主库，使之成为新主库的只读从库。而不需要重建整个从库。3、如果没有pg_rewind，遇到以上情况，需要完全重建从库。或者你可以使用存储层快照，回退回脑裂以前的状态。又或者可以使用文件系统快照，回退回脑裂以前的状态。

原理与修复步骤

1、使用pg_rewind功能的前提条件：必须开启full page write，必须开启wal hint或者data block checksum。2、需要被修复的库：从激活点开始，所有的WAL必须存在pg_wal目录中。如果WAL已经被覆盖，只要有归档，拷贝到pg_wal目录即可。3、新的主库，从激活点开始，产生的所有WAL必须存在pg_wal目录中，或者已归档，并且被修复的库可以使用restore_command访问到这部分WAL。4、修改(source db)新主库或老主库配置，允许连接。5、修复时，连接新主库，得到切换点。或连接老主库，同时比对当前要修复的新主库的TL与老主库进行比对，得到切换点。6、解析需要被修复的库的从切换点到现在所有的WAL。同时连接source db(新主库（或老主库）)，进行回退操作（被修改或删除的BLOCK从source db获取并覆盖，新增的BLOCK，直接抹除。）回退到切换点的状态。7、修改被修复库(target db)的recovery.conf, postgresql.conf配置。8、启动target db，连接source db接收WAL，或restore_command配置接收WAL，从切换点开始所有WAL，进行apply。9、target db现在是source db的从库。

以EDB PG 11为例讲解

环境部署

《MTK使用 - PG,PPAS,oracle,mysql,ms sql,sybase 迁移到 PG, PPAS (支持跨版本升级)》

（https://github.com/digoal/blog/blob/master/201812/20181226_01.md）

export PS1="$USER@`/bin/hostname -s`-> "      

export PGPORT=4000  

export PGDATA=/data04/ppas11/pg_root4000  

export LANG=en_US.utf8      

export PGHOME=/usr/edb/as11  

export LD_LIBRARY_PATH=$PGHOME/lib:/lib64:/usr/lib64:/usr/local/lib64:/lib:/usr/lib:/usr/local/lib:$LD_LIBRARY_PATH      

export DATE=`date +"%Y%m%d%H%M"`    

export PATH=$PGHOME/bin:$PATH:.      

export MANPATH=$PGHOME/share/man:$MANPATH      

export PGHOST=127.0.0.1  

export PGUSER=postgres   

export PGDATABASE=postgres      

alias rm='rm -i'      

alias ll='ls -lh'      

unalias vi

1、初始化数据库集群

initdb -D /data04/ppas11/pg_root4000 -E UTF8 --lc-collate=C --lc-ctype=en_US.UTF8 -U postgres -k --redwood-like

2、配置recovery.done

cd $PGDATA  
cp $PGHOME/share/recovery.conf.sample ./  
mv recovery.conf.sample recovery.done  
vi recovery.done  
restore_command = 'cp /data04/ppas11/wal/%f %p'  recovery_target_timeline = 'latest'  standby_mode = on  primary_conninfo = 'host=localhost port=4000 user=postgres'

3、配置postgresql.conf要使用rewind功能：必须开启full_page_writes必须开启data_checksums或wal_log_hints

postgresql.conf  

listen_addresses = '0.0.0.0'  

port = 4000  

max_connections = 8000  

superuser_reserved_connections = 13  

unix_socket_directories = '.,/tmp'  

unix_socket_permissions = 0700  

tcp_keepalives_idle = 60  

tcp_keepalives_interval = 10  

tcp_keepalives_count = 10  

shared_buffers = 16GB  

max_prepared_transactions = 8000  

maintenance_work_mem = 1GB  

autovacuum_work_mem = 1GB  

dynamic_shared_memory_type = posix  

vacuum_cost_delay = 0  

bgwriter_delay = 10ms  

bgwriter_lru_maxpages = 1000  

bgwriter_lru_multiplier = 10.0  

effective_io_concurrency = 0  

max_worker_processes = 128  

max_parallel_maintenance_workers = 8  

max_parallel_workers_per_gather = 8  

max_parallel_workers = 24  

wal_level = replica  

synchronous_commit = off  

full_page_writes = on  

wal_compression = on  

wal_buffers = 32MB  

wal_writer_delay = 10ms  

checkpoint_timeout = 25min  

max_wal_size = 32GB  

min_wal_size = 8GB  

checkpoint_completion_target = 0.2  

archive_mode = on  

archive_command = 'cp -n %p /data04/ppas11/wal/%f'  

max_wal_senders = 16  

wal_keep_segments = 4096  

max_replication_slots = 16  

hot_standby = on  

max_standby_archive_delay = 300s  

max_standby_streaming_delay = 300s  

wal_receiver_status_interval = 1s  

wal_receiver_timeout = 10s  

random_page_cost = 1.1  

effective_cache_size = 400GB  

log_destination = 'csvlog'  

logging_collector = on  

log_directory = 'log'  

log_filename = 'edb-%a.log'  

log_truncate_on_rotation = on  

log_rotation_age = 1d  

log_rotation_size = 0  

log_min_duration_statement = 1s  

log_checkpoints = on  

log_error_verbosity = verbose  

log_line_prefix = '%t '  

log_lock_waits = on  

log_statement = 'ddl'  

log_timezone = 'PRC'  

autovacuum = on  

log_autovacuum_min_duration = 0  

autovacuum_max_workers = 6  

autovacuum_freeze_max_age = 1200000000  

autovacuum_multixact_freeze_max_age = 1400000000  

autovacuum_vacuum_cost_delay = 0  

statement_timeout = 0  

lock_timeout = 0  

idle_in_transaction_session_timeout = 0  

vacuum_freeze_table_age = 1150000000  

vacuum_multixact_freeze_table_age = 1150000000  

datestyle = 'redwood,show_time'  

timezone = 'PRC'  

lc_messages = 'en_US.utf8'  

lc_monetary = 'en_US.utf8'  

lc_numeric = 'en_US.utf8'  

lc_time = 'en_US.utf8'  

default_text_search_config = 'pg_catalog.english'  

shared_preload_libraries = 'auto_explain,pg_stat_statements,$libdir/dbms_pipe,$libdir/edb_gen,$libdir/dbms_aq'  

edb_redwood_date = on  

edb_redwood_greatest_least = on  

edb_redwood_strings = on  

db_dialect = 'redwood'                

edb_dynatune = 66  

edb_dynatune_profile = oltp  

timed_statistics = off

4、配置pg_hba.conf，允许流复制

local   all             all                                     trust  

host    all             all             127.0.0.1/32            trust  

host    all             all             ::1/128                 trust  

local   replication     all                                     trust  

host    replication     all             127.0.0.1/32            trust  

host    replication     all             ::1/128                 trust  

host all all 0.0.0.0/0 md5

5、配置归档目录

mkdir /data04/ppas11/wal    

chown enterprisedb:enterprisedb /data04/ppas11/wal

6、创建从库

pg_basebackup -h 127.0.0.1 -p 4000 -D /data04/ppas11/pg_root4001 -F p -c fast