Kubernetes环境下如何通过Java程序周期性验证MariaDB主从是否失步

核心验证逻辑 #

MariaDB主从同步状态可通过查询SHOW SLAVE STATUS结果中的关键字段判断：

• Slave_IO_Running：需为Yes，代表从节点I/O线程正常读取主节点binlog
• Slave_SQL_Running：需为Yes，代表从节点SQL线程正常回放binlog
• Seconds_Behind_Master：需为0或低于业务容忍阈值，代表从节点无延迟或延迟可控

周期性验证方案 #

1. Java触发的验证与定时执行 #

直接通过JDBC连接从节点实现状态检查，结合定时任务框架完成周期性触发：

核心检查代码

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class MariaDBSyncChecker {
    public static void checkSlaveStatus(String slaveJdbcUrl, String username, String password) throws Exception {
        try (Connection conn = DriverManager.getConnection(slaveJdbcUrl, username, password);
             Statement stmt = conn.createStatement();
             ResultSet rs = stmt.executeQuery("SHOW SLAVE STATUS")) {
            if (rs.next()) {
                String ioRunning = rs.getString("Slave_IO_Running");
                String sqlRunning = rs.getString("Slave_SQL_Running");
                long secondsBehind = rs.getLong("Seconds_Behind_Master");
                
                // 可根据业务调整阈值
                boolean isHealthy = "Yes".equals(ioRunning) && "Yes".equals(sqlRunning) && secondsBehind <= 5;
                if (!isHealthy) {
                    sendAlert("MariaDB主从失步：IO线程=" + ioRunning + ", SQL线程=" + sqlRunning + ", 延迟=" + secondsBehind + "秒");
                }
            }
        }
    }

    // 实现告警逻辑（如企业微信/钉钉推送、邮件发送）
    private static void sendAlert(String message) {
        System.err.println("告警：" + message);
    }
}

定时触发示例（Spring Task）

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class SyncCheckScheduler {
    // 每5分钟执行一次，可调整cron表达式
    @Scheduled(fixedRate = 300000)
    public void scheduledCheck() {
        try {
            MariaDBSyncChecker.checkSlaveStatus(
                "jdbc:mariadb://slave-node-service:3306/",
                "check_user",
                "check_password"
            );
        } catch (Exception e) {
            sendAlert("主从状态检查失败：" + e.getMessage());
        }
    }

    private void sendAlert(String message) {
        // 告警逻辑实现
    }
}

2. 结合Kubernetes CronJob的批量执行 #

若Java程序已打包为镜像，可通过K8s CronJob实现集群级定时触发，避免单点问题：

apiVersion: batch/v1
kind: CronJob
metadata:
  name: mariadb-sync-check
spec:
  schedule: "*/5 * * * *" # 每5分钟执行一次
  jobTemplate:
    spec:
      template:
        spec:
          containers:
          - name: sync-checker
            image: your-java-checker-image:latest
            env:
            - name: SLAVE_JDBC_URL
              value: "jdbc:mariadb://slave-node-service:3306/"
            - name: DB_USERNAME
              valueFrom:
                secretKeyRef:
                  name: mariadb-secrets
                  key: check-username
            - name: DB_PASSWORD
              valueFrom:
                secretKeyRef:
                  name: mariadb-secrets
                  key: check-password
          restartPolicy: OnFailure

告警与恢复优化 #

• 去重控制：在Java程序中加入告警频率限制，同一问题1小时内仅推送一次
• 权限最小化：创建只读数据库账号，仅授予REPLICATION CLIENT权限用于执行状态查询
• 恢复指引：在告警中附带快速恢复步骤：

1. 登录从节点执行STOP SLAVE;
2. 从主节点SHOW MASTER STATUS获取binlog文件名和位置，执行CHANGE MASTER TO MASTER_LOG_FILE='xxx', MASTER_LOG_POS=xxx;
3. 执行START SLAVE;后重新检查同步状态

内容的提问来源于stack exchange，提问作者StackOverflowFan