PostgreSQL流复制热备

关于pg热备与主备切换网上很多内容都有了,本文仅为自己测试使用,特意记录过程,或对其他人提供参考。本文作者选择pg9.6.1版本作为测试。

一 主备机器规划

主机名

IP

角色

端口

master

192.168.0.108

Master

5432

slave

192.168.0.109

Slave

5432

前提:分别在两台主机上安装好pg数据库,安装过程参考之前博客说明http://www.jianshu.com/p/639ebb43bfb4。

二 创建流复制

2.1 设置host

master,slave两节点都要操作。

1[root@bogon ~]# vim /etc/hosts 2#编辑内容如下: 3192.168.43.127 master 4192.168.43.243 slave

按esc,wq!保存退出。

2.2 初始化master数据库

以下操作在master下执行:

1#切换到postgres账户 2[root@bogon ~]# su - postgres 3#初始化data 4[postgres@bogon ~]$ initdb -D $PGDATA 5# 启动master数据库 6[postgres@bogon ~]$ pg_ctl start -D $PGDATA 7#创建流复制用户 8[postgres@bogon ~]$ psql 9psql (9.6.1) 10Type "help" for help. 11 12postgres=# CREATE USER repuser replication LOGIN CONNECTION LIMIT 3 ENCRYPTED PASSWORD 'repuser'; 13CREATE ROLE

2.3 配置pg_hba.conf

在master的pg_hba.conf最后一行增加如下:

1host all all 0.0.0.0/0 md5 2host replication repuser slave md5

2.4 配置postgresql.conf

在master端配置如下:

1listen_addresses = '*' 2port = 5432 3max_wal_senders = 1 4wal_level = replica 5archive_mode = on 6archive_command = 'cd ./' 7hot_standby = on 8wal_keep_segments = 64 9full_page_writes = on 10wal_log_hints = on

配置完成后,重启master数据库

[postgres@bogon ~]$ pg_ctl restart -D $PGDATA

2.5 pg_basebackup 创建备库

在slave端的postgres账户下执行:

1#切换到postgres账户 2[root@bogon ~]# su - postgres 3#从主库备份创建备库 4[postgres@bogon ~]$ pg_basebackup -D $PGDATA -Fp -Xs -v -P -h master -p 5432 -U repuser 5transaction log start point: 0/2000060 on timeline 1 6pg_basebackup: starting background WAL receiver 722806/22806 kB (100%), 1/1 tablespace 8transaction log end point: 0/2000130 9pg_basebackup: waiting for background process to finish streaming ... 10pg_basebackup: base backup completed

修改slave中data目录下的pg_hba.conf最后一行修改如下:

1host all all 0.0.0.0/0 md5 2host replication repuser master md5

2.6 配置recovery.conf

Master端配置如下:

1[postgres@bogon ~]$ ls 2bin data gdal geos include lib proj4 share 3[postgres@bogon ~]$ cp share/recovery.conf.sample data/recovery.done 4[postgres@bogon ~]$ vim data/recovery.done 5#编辑内容如下 6recovery_target_timeline = 'latest' 7standby_mode = on 8primary_conninfo = 'host=slave port=5432 user=repuser password=repuser' 9trigger_file = '/home/postgres/data/trigger_file'

Salve端配置如下:

1[postgres@bogon ~]$ ls 2bin data gdal geos include lib proj4 share 3[postgres@bogon ~]$ cp share/recovery.conf.sample data/recovery.conf 4[postgres@bogon ~]$ vim data/recovery.conf 5#编辑内容如下 6recovery_target_timeline = 'latest' 7standby_mode = on 8primary_conninfo = 'host=master port=5432 user=repuser password=repuser' 9trigger_file = '/home/postgres/data/trigger_file'

2.7 配置.pgpass

master上配置访问slave参数

1[postgres@bogon ~]$ vim .pgpass 2slave:5432:postgres:repuser:repuser

slave上配置访问master参数

1[postgres@bogon ~]$ vim .pgpass 2master:5432:postgres:repuser:repuser

2.8 流复制数据同步测试

分别启动master,slave数据库
在master上创建一个数据库和临时表

1[postgres@bogon data]$ psql 2psql (9.6.1) 3Type "help" for help. 4postgres=# \password #创建数据库密码 5#创建测试数据库 6postgres=# create database test; 7CREATE DATABASE 8postgres=# \c test 9You are now connected to database "test" as user "postgres". 10test=# create table tt(id serial not null,name text); 11CREATE TABLE 12test=# insert into tt(name) values ('china'); 13INSERT 0 1

在slave上查询刚才创建的表和数据,判定是否有数据同步

1[postgres@bogon data]$ psql 2psql (9.6.1) 3Type "help" for help. 4 5postgres=# \c test 6You are now connected to database "test" as user "postgres". 7test=# select * from tt; 8 id | name 9----+------- 10 1 | china 11(1 row)

很明显,从库已经同步了主库的数据,到此可以说PG流复制热备已经创建结束了。以下对流复制做一些简单的应用。

三 主备切换

一般可以通过若干命令查询数据库的主备属性,主数据库是读写的,备数据库是只读的。当主数据库宕机了,可以通过建立触发文件,备数据库将被提升为主数据库,实现一些基本的HA应用。

3.1 查询主备

3.1.1 pg_controldata

1主机 2[postgres@localhost ~]$ pg_controldata 3pg_control version number: 960 4Catalog version number: 201608131 5Database system identifier: 6362107256088627972 6Database cluster state: in production 7备机 8pg_control version number: 960 9Catalog version number: 201608131 10Database system identifier: 6362107256088627972 11Database cluster state: in archive recovery

主机的cluster state是in production,备机的cluster state是in archive recovery。

3.1.2 字典表pg_stat_replication

在主机字典表中是能查到记录,备机中是查询不到的。

1postgres=# select pid,application_name,client_addr,client_port,state,sync_state from pg_stat_replication; 2 pid | application_name | client_addr | client_port | state | sync_state 3-------+------------------+---------------+-------------+-----------+------------ 4 17131 | walreceiver | 192.168.0.105 | 55734 | streaming | async 5(1 row)

3.1.3 进程信息识别

进程中显示wal sender的是主机,显示wal receiver的是备机
master:

主机进程.png

slave:

备机进程.png

3.1.4 通过pg函数

备机是t,主机是f。
主机

1postgres=# select pg_is_in_recovery(); 2 pg_is_in_recovery 3------------------- 4 f 5(1 row)

备机

1postgres=# select pg_is_in_recovery(); 2 pg_is_in_recovery 3------------------- 4 t 5(1 row)

3.2 备机切换成主机

主机宕机前:

宕机前备机进程.png

主机执行pg_ctl stop 命令。
宕机后:

主机宕机后.png

备机报错,说不能连接主机了。
之前曾配置过:

 trigger_file = '/home/postgres/datatrigger_file'

备机切换到主机,在备机上执行

[postgres@localhost ]$  touch /home/postgres/data/trigger_file;

再去备机上查看进程:

备机进程.png

备机已经切换到主机了。

3.3 原来主机切换成备机

在当前主机(现在是slave了,主机切换了)执行插入语句

postgres=#  insert into tt(name) values('sdf');

如果master上data目录中的recovery.done没有变成recovery.conf,可以手动强制更改。

[postgres@data]$  mv recovery.done recovery.conf

如果已经是recovery.conf就直接执行下面的。

1#启动数据库 2[postgres@data]$ pg_ctl start 3[postgres@bogon data]$ ERROR: requested starting point 0/6000000 on timeline 1 is not in this server's history 4DETAIL: This server's history forked from timeline 1 at 0/4000098. 5ERROR: requested starting point 0/6000000 on timeline 1 is not in this server's history 6DETAIL: This server's history forked from timeline 1 at 0/4000098. 7ERROR: requested starting point 0/6000000 on timeline 1 is not in this server's history 8#其实还有很多时间线不一致等

原因是当前主机slave数据发生变化了,原来的master数据和当前数据不一致了,要确保数据时间线一致。我们使用pg_rewind来同步时间线。
在master(从机上操作)

1#从slave上拉取最新时间线和数据给当前的master 2[postgres@bogon ~]$ pg_rewind --target-pgdata=/home/postgres/data --source-server='host=slave port=5432 user=postgres dbname=postgres' 3 4target server must be shut down cleanly 5Failure, exiting

发现报错了,说target server 必须关闭,source-server是slave,那么target server就是master,那么停掉master上pg服务。

1#先停止服务 2[postgres@bogon ~]$ pg_ctl stop 3#再拉取数据 4[postgres@bogon ~]$ pg_rewind --target-pgdata=/home/postgres/data --sourceserver='host=slave port=5432 user=postgres dbname=postgres' 5servers diverged at WAL position 0/4000098 on timeline 1 6rewinding from last common checkpoint at 0/4000028 on timeline 1 7Done! 8#重启服务 9[postgres@bogon ~]$ pg_ctl start

可以检查下,现在的master上数据和slave是一致的了。

点赞
收藏

评论区

加载中...

相关推荐

MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1

文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s

Oracle 分组与拼接字符串同时使用

SELECTT.,ROWNUMIDFROM(SELECTT.EMPLID,T.NAME,T.BU,T.REALDEPART,T.FORMATDATE,SUM(T.S0)S0,MAX(UPDATETIME)CREATETIME,LISTAGG(TOCHAR(

MySQL部分从库上面因为大量的临时表tmp_table造成慢查询

背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_

皕杰报表之UUID

​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为

手写Java HashMap源码

HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22

2020年前端实用代码段,为你的工作保驾护航

有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )