同步、非同步多從庫複製

在master上連線pocdb 資料庫 ，基於配置二的節點狀態

pocdb=# SELECT client_addr,application_name,sync_state FROM pg_stat_replication;
 client_addr | application_name | sync_state 
-------------+------------------+------------
 10.10.56.17 | slave1           | async
 10.10.56.19 | slave2           | async
(2 rows)
 

master有兩個slave都是async（非同步）流複製，現在修改slave1節點為sync（同步）流複製，修改master 節點的postgresql.conf中引數synchronous_standby_names

synchronous_standby_names = 'slave1' 
[email protected]-db1:~> /opt/pgsql-9.6/bin/pg_ctl -D /pgdata/9.6/poc/data/ reload
server signaled

檢視master的複製資訊：

pocdb=# SELECT client_addr,application_name,sync_state FROM pg_stat_replication;
 

 client_addr | application_name | sync_state 
-------------+------------------+------------
 10.10.56.17 | slave1           | sync
 10.10.56.19 | slave2           | async
(2 rows)

slave1已經修改為同步複製。

同步複製slave宕機測試

a. 隱式事務，同步slave宕機，事務掛起，slave恢復後寫事務繼續執行。

pocdb=# SELECT client_addr,application_name,sync_state FROM
 
 pg_stat_replication;
 client_addr | application_name | sync_state 
-------------+------------------+------------
 10.10.56.17 | slave1           | sync
(1 row)

slave1為同步複製方式，當slave1宕機（kill -9），在master上執行查詢可以執行，但寫入的DML語句，將被block；

pocdb=# SELECT * FROM tbl;    
 id | ival | cval 
----+------+------
  1 |    1 | A
  2 |   20 | B
(2 rows)

pocdb=# INSERT INTO tbl (ival,cval) VALUES ( 4,NULL);      

恢復slave1之後，master上的事務將繼續執行：
恢復slave：

[email protected]-db2:~> /opt/pgsql-9.6/bin/pg_ctl -D /pgdata/9.6/poc/data/ start
server starting

master上的事務：

pocdb=# INSERT INTO tbl (ival,cval) VALUES ( 4,NULL);      
INSERT 0 1
pocdb=# SELECT * FROM tbl;
 id | ival | cval 
----+------+------
  1 |    1 | A
  2 |   20 | B
  4 |    4 | 
(3 rows)

在同步複製的slave節點上查詢

pocdb=# SELECT * FROM tbl;
 id | ival | cval 
----+------+------
  1 |    1 | A
  2 |   20 | B
  4 |    4 | 
(3 rows)

b. 顯式事務，在slave宕機的情況下，提交的事務會本地提交，slave恢復後會將master上本地提交的事務同步到slave，rollback的事務在slave宕機時不受影響。
顯式本地提交事務：

pocdb=# BEGIN;  
BEGIN
pocdb=# INSERT INTO tbl (ival,cval) VALUES (5,NULL);
INSERT 0 1
pocdb=# COMMIT;
^CCancel request sent
WARNING:  canceling wait for synchronous replication due to user request
DETAIL:  The transaction has already committed locally, but might not have been replicated to the standby.
COMMIT
pocdb=# 

顯式本地ROLLBACK事務：

pocdb=# BEGIN;
BEGIN
pocdb=# INSERT INTO tbl (ival,cval) VALUES (10,'f');  
INSERT 0 1
pocdb=# ROLLBACK;
ROLLBACK
pocdb=# 

在slave上查詢：

[email protected]:~> /opt/pgsql-9.6/bin/psql pocdb
psql (9.6.8)
Type "help" for help.

pocdb=# SELECT * FROM tbl;
 id | ival | cval 
----+------+------
  1 |    1 | A
  2 |   20 | B
  4 |    4 | 
  6 |    5 | 
(4 rows)

非同步複製slave宕機

當非同步複製slave宕機，master讀寫不受影響，恢復後可即時同步到最新資料：

pocdb=# SELECT * FROM tbl;    
 id | ival | cval 
----+------+------
  1 |    1 | A
  2 |   20 | B
  4 |    4 | 
  6 |    5 | 
(4 rows)