postgres=# — 在主节点1上创建发布
postgres=# CREATE PUBLICATION pub1 FOR ALL TABLES;
CREATE PUBLICATION

postgres=# — 在主节点2上创建发布
postgres=# CREATE PUBLICATION pub2 FOR ALL TABLES;
CREATE PUBLICATION

postgres=# — 在主节点1上创建订阅
postgres=# CREATE SUBSCRIPTION sub2 CONNECTION ‘host=192.168.1.11 port=5432 dbname=fgedudb user=postgres password=postgres_pass’ PUBLICATION pub2;
CREATE SUBSCRIPTION

postgres=# — 在主节点2上创建订阅
postgres=# CREATE SUBSCRIPTION sub1 CONNECTION ‘host=192.168.1.10 port=5432 dbname=fgedudb user=postgres password=postgres_pass’ PUBLICATION pub1;
CREATE SUBSCRIPTION

# 2. 测试多主复制
$ psql -h 192.168.1.10 -U fgedu -d fgedudb

fgedudb=> INSERT INTO fgedu_users (name, email) VALUES (‘user1’, ‘user1@fgedu.net.cn’);
INSERT 0 1

$ psql -h 192.168.1.11 -U fgedu -d fgedudb

fgedudb=> SELECT * FROM fgedu_users;
id | name | email
—-+——-+———————
1 | user1 | user1@fgedu.net.cn
(1 row)

fgedudb=> INSERT INTO fgedu_users (name, email) VALUES (‘user2’, ‘user2@fgedu.net.cn’);
INSERT 0 1

$ psql -h 192.168.1.10 -U fgedu -d fgedudb

fgedudb=> SELECT * FROM fgedu_users;
id | name | email
—-+——-+———————
1 | user1 | user1@fgedu.net.cn
2 | user2 | user2@fgedu.net.cn
(2 rows)

# 负载均衡配置
load_balance_mode = on

# 连接数限制
max_pool = 4

# 健康检查
health_check_period = 10
health_check_timeout = 5
health_check_user = ‘postgres’
health_check_password = ‘postgres_pass’

# 2. 重启PGPool-II
$ systemctl restart pgpool-II

# 3. 测试负载均衡
$ for i in {1..10}; do
psql -h fgedu.localhost -p 9999 -U fgedu -d fgedudb -c ‘SELECT pg_backend_pid();’
done

pg_backend_pid
—————-
12345
67890
12345
67890
12345
67890
12345
67890
12345
67890
(10 rows)

# 2. 检查集群状态
$ patronictl list
+ Cluster: postgresql (6900967337290748634) –+—-+———–+——————-+——–+———+—-+———–+
| Member | Host | Role | State | TL | Lag in MB | Pending restart |
+——–+—————+———+———+—-+———–+—————–+
| pg1 | 192.168.1.10 | Leader | stopped | 1 | | |
| pg2 | 192.168.1.11 | Replica | running | 1 | 0 | |
+——–+—————+———+———+—-+———–+—————–+

# 3. 执行故障切换
$ patronictl failover

# 4. 检查故障切换结果
$ patronictl list
+ Cluster: postgresql (6900967337290748634) –+—-+———–+——————-+——–+———+—-+———–+
| Member | Host | Role | State | TL | Lag in MB | Pending restart |
+——–+—————+———+———+—-+———–+—————–+
| pg1 | 192.168.1.10 | Replica | stopped | 1 | | |
| pg2 | 192.168.1.11 | Leader | running | 2 | | |
+——–+—————+———+———+—-+———–+—————–+

# 5. 恢复故障节点
$ ssh 192.168.1.10 “systemctl start postgresql”

# 6. 检查集群状态
$ patronictl list
+ Cluster: postgresql (6900967337290748634) –+—-+———–+——————-+——–+———+—-+———–+
| Member | Host | Role | State | TL | Lag in MB | Pending restart |
+——–+—————+———+———+—-+———–+—————–+
| pg1 | 192.168.1.10 | Replica | running | 2 | 0 | |
| pg2 | 192.168.1.11 | Leader | running | 2 | | |
+——–+—————+———+———+—-+———–+—————–+