当前位置: 首页 > backend >正文

repmgr+vip实现对业务透明的高可用切换

本方案说明

  • PostgreSQL + repmgr:实现主从自动故障检测与切换(Failover)。
  • vip:作为应用连接地址,屏蔽后端数据库变动,提供透明连接。
  • vip漂移:通过repmgr组件的promote_command阶段触发脚本,将vip漂移到新主库。

节点规划

主机hostname角色组件
10.0.0.41repmgr01LeaderPostgreSQL 15.5、repmgr 5.5.0
10.0.0.42repmgr02standby1PostgreSQL 15.5、repmgr 5.5.0
10.0.0.43repmgr03standby2PostgreSQL 15.5、repmgr 5.5.0

目录文件说明

/data/pgsql/data后端postgresql的数据目录
/data/pgsql/log后端postgresql的日志目录
/data/pgsql/data/postgres.conf后端postgresql的配置文件
/data/pgsql/data/pg_hba.conf后端postgresql的访问控制文件
/data/repmgr高可用组件repmgr的家目录
/data/repmgr/repmgr.conf高可用组件repmgr的配置文件
/data/repmgr/promte_standby_vip.shrepmgr监测到后端主节点故障后触发的脚本

1.集群准备

准备一套1主2从的repmgr集群,部署过程参考我的另一篇文章PostgreSQL高可用架构Repmgr部署流程

# 配置集群所有节点postgres用户的sudo权限
[root@repmgr01 ~]# visudo
postgres ALL=(ALL) NOPASSWD: ALL

2.编辑repmgr触发脚本

#所有节点
vim /data/repmgr/promte_standby_vip.sh
#!/bin/bash
set -o xtrace
PGCANDIDATES=(10.0.0.41 10.0.0.42 10.0.0.43)
HOSTNAME=`hostname -i`
VIP=10.0.0.44
GW=10.0.0.254
DEVICE=ens33
PG_HOME=/usr/local/pgsql
PG_PORT=5432
REPMGR_USER=repmgr
REPMGR_PASSWD=repmgr
REPMGR_CONF=/data/repmgr/repmgr.confSTEP1="Remove the VIP on all nodes"
STEP2="Check if vip still online"
STEP3="Promte primary DB"
STEP4="Add vip on new primary DB"
STEP5="Clear ARP Cache"###step1. Remove the VIP on all nodes
for candidate in "${PGCANDIDATES[@]}"; do[ "$HOSTNAME" = "$candidate" ] && continuessh -T -o StrictHostKeyChecking=no -o UserKnownHostsFile=/dev/null postgres@$candidate  "/usr/bin/sudo /sbin/ip addr del $VIP/24 dev $DEVICE"
done###step2.Check if vip still online
/usr/bin/sudo  /usr/bin/ping -c1 -w1 -t5 ${VIP}
if [ $? -eq 0 ]; thenecho repmgr_promote_command.sh: ${STEP2} : ${VIP} failed !!!  exit 1
fi###step3.Promte primary DB
${PG_HOME}/bin/repmgr standby promote -f ${REPMGR_CONF} --log-to-fileif [ $? -ne 0 ]; thenecho repmgr_promote_command.sh: ${STEP3} on ${HOSTNAME} failed !!!  exit 1
fistandby_flg=`${PG_HOME}/bin/psql -p ${PG_PORT} -U ${REPMGR_USER} -w ${REPMGR_PASSWD} -h localhost -At -c "SELECT pg_is_in_recovery();"`if [ ${standby_flg} == 'f' ]; thenecho repmgr_promote_command.sh: ${STEP3} on ${HOSTNAME} successfully !!!
elif [ ${standby_flg} == 't' ]; thenecho repmgr_promote_command.sh: ${STEP3} on ${HOSTNAME} failed !!!exit 1
fi###step4.Add vip on new primary DB
/usr/bin/sudo /sbin/ip addr add $VIP/24 dev $DEVICE
if [ $? -ne 0 ]; thenecho repmgr_promote_command.sh: ${STEP4} on ${HOSTNAME} failed !!!  exit 1
fi####step5.Clear arp cache
/usr/bin/sudo /sbin/arping -I $DEVICE -s $VIP -b -c 3 $GW
if [ $? -ne 0 ]; thenecho repmgr_promote_command.sh: ${STEP5} on ${HOSTNAME} failed !!!  exit 1
fi
# 授予脚本可执行权限
chmod +x /data/repmgr/promte_standby_vip.sh

3.修改repmgr配置文件

# 修改promote_command参数,执行我们新建的脚本
vim /data/repmgr/repmgr.conf
promote_command='/data/repmgr/promte_standby_vip.sh >> /data/repmgr/repmgrd.log'

4.将vip挂载到主节点

[postgres@repmgr01 ~]$ /usr/bin/sudo /sbin/ip addr add 10.0.0.44/24 dev ens33

5.重新启动repmgrd守护进程

kill $(pgrep -f repmgrd)
repmgrd -f /data/repmgr/repmgr.conf --daemonize

6.验证failover

查看当前集群状态

[postgres@repmgr01 ~]$ repmgr -f  /data/repmgr/repmgr.conf cluster show

在这里插入图片描述

使用vip连接查看从库信息

[postgres@repmgr01 ~]$ PGPASSWORD="repmgr" psql -p 5432 -U repmgr -h 10.0.0.44 -d repmgr
repmgr=# select * from pg_stat_replication;

在这里插入图片描述

手动关闭主节点

[postgres@postgres-01 data]$ pg_ctl stop -D $PGDATA
waiting for server to shut down.... done
server stopped

查看日志

[postgres@repmgr02 ~]$ vim /data/repmgr/repmgrd.log 

经过三次重试无法连接node-01

在这里插入图片描述

node-02作为主节点,在该节点上执行了触发脚本,成功被提升为主库,并且node-03节点作为从节点

在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

查看vip

vip漂移到了node-02节点

[postgres@repmgr02 ~]$ ip a| grep 10.0.0.44inet 10.0.0.44/24 scope global secondary ens33

通过vip连接主节点,查看从库信息

[postgres@repmgr02 ~]$ PGPASSWORD="repmgr" psql -p 5432 -U repmgr -h 10.0.0.44 -d repmgr
psql (15.5)
Type "help" for help.repmgr=# select * from pg_stat_replication\gx

在这里插入图片描述

http://www.xdnf.cn/news/16029.html

相关文章:

  • 【金融机器学习】第四章:风险-收益权衡——Bryan Kelly, 修大成(中文翻译)
  • 92套毕业相册PPT模版
  • 【vscode】vscode中python虚拟环境的创建
  • SpringBoot与Vue实战:高效开发秘籍
  • 基于LangGraph的Open Deep Research架构全解析:从多Agent协作到企业级落地
  • 精密全波整流电路(二)
  • 大疆视觉算法面试30问全景精解
  • 企业工商信息查询API详细文档对接流程-JavaScript营业执照真伪解析
  • Word Press富文本控件的保存
  • Matlab学习笔记:矩阵基础
  • 《Uniapp-Vue 3-TS 实战开发》自定义预约时间段组件
  • 学习python中离线安装pip及下载package的方法
  • Django中间件
  • 云祺容灾备份系统阿里云对象存储备份与恢复实操手册
  • map和set的应用与模拟实现
  • postgresql使用记录 SCRAM authentication requires libpq version 10 or above
  • 得物视觉算法面试30问全景精解
  • C++刷题常用方法
  • iOS组件化详解
  • 架构演进核心路线:从离线仓库到实时湖仓一体
  • 建造者设计模式
  • ArcGIS水文及空间分析与SWMM融合协同在城市排水防涝领域中的应用
  • web复习
  • Element Plus Table 组件扩展:表尾合计功能详解
  • 【后端】HMAC签名
  • 【React 入门系列】React 组件通讯与生命周期详解
  • 替代Oracle?金仓数据库用「敢替力」重新定义国产数据库
  • Node.js:Web模块、Express框架
  • [hot 100]两数之和-Python3-Hash Table
  • 蔚来汽车视觉算法面试30问全景精解