双活架构故障处理脚本示例

#!/bin/bash
# dual_active_failover.sh
# from:www.itpux.com.qq113257174.wx:itpux-com
# web: http://www.fgedu.net.cn

# 定义变量
NODE1_IP="192.168.1.10"
NODE2_IP="192.168.2.10"
DB_USER="fgedu"
DB_PASS="Fgedu@123"
DATA_DIR="/opengauss/fgdata"

# 检查节点状态
check_node() {
    local node_ip=$1
    echo "检查节点 $node_ip 状态..."
    ping -c 3 $node_ip > /dev/null 2>&1
    if [ $? -ne 0 ]; then
        echo "节点 $node_ip 网络不可达"
        return 1
    fi
    
    ssh $DB_USER@$node_ip "gs_ctl status -D $DATA_DIR" > /dev/null 2>&1
    if [ $? -ne 0 ]; then
        echo "节点 $node_ip 数据库服务异常"
        return 1
    fi
    
    return 0
}

# 检查复制状态
check_replication() {
    echo "检查复制状态..."
    ssh $DB_USER@$NODE1_IP "gsql -U $DB_USER -d postgres -c 'SELECT application_name, state, sync_state FROM pg_stat_replication; 
'"
}

# 执行故障切换
do_failover() {
    local failed_node=$1
    local healthy_node=$2
    
    echo "开始执行故障切换，将 $healthy_node 提升为主节点..."
    ssh $DB_USER@$healthy_node "gs_ctl promote -D $DATA_DIR"
    if [ $? -eq 0 ]; then
        echo "故障切换成功，节点 $healthy_node 已提升为主节点"
        # 更新负载均衡配置
        update_load_balancer $healthy_node
    else
        echo "故障切换失败"
    fi
}

# 更新负载均衡配置
update_load_balancer() {
    local primary_node=$1
    echo "更新负载均衡配置，将流量导向 $primary_node..."
    # 这里根据实际负载均衡器类型进行配置
    # 例如更新HAProxy配置或DNS记录
    echo "负载均衡配置已更新"
}

# 主流程
echo "=== 双活架构故障处理开始 ==="

# 检查两个节点状态
check_node $NODE1_IP
NODE1_STATUS=$?

check_node $NODE2_IP
NODE2_STATUS=$?

# 根据状态执行相应操作
if [ $NODE1_STATUS -eq 0 ] && [ $NODE2_STATUS -eq 0 ]; then
    echo "两个节点状态正常"
    check_replication
elif [ $NODE1_STATUS -eq 0 ] && [ $NODE2_STATUS -ne 0 ]; then
    echo "节点 $NODE2_IP 故障，执行故障切换"
    do_failover $NODE2_IP $NODE1_IP
elif [ $NODE1_STATUS -ne 0 ] && [ $NODE2_STATUS -eq 0 ]; then
    echo "节点 $NODE1_IP 故障，执行故障切换"
    do_failover $NODE1_IP $NODE2_IP
else
    echo "两个节点都故障，需要人工干预"
fi

echo "=== 双活架构故障处理完成 ==="