Kubernetes 实战：基于 StatefulSet 构建 MySQL 主从集群（GTID + 自动复制）
K8s 实战：用 StatefulSet 搭建 MySQL 主从集群（GTID + 自动同步）
在生产环境中，MySQL 主从复制是实现数据高可用和读写分离的常见方案。在 Kubernetes 中部署有状态应用，首选控制器便是 StatefulSet。它能为每个 Pod 提供稳定的网络标识和独立的持久化存储，非常适合数据库这类有状态服务。
本文将带领你一步步在 Kubernetes 上，利用 StatefulSet 搭建一套基于 GTID 的 MySQL 主从集群，并实现 从库自动同步。你将学会：
- 使用 ConfigMap 管理 MySQL 配置和初始化脚本
- 使用 Secret 保存数据库密码
- 创建 Headless Service 为 StatefulSet 提供稳定的网络标识
- 编写 StatefulSet YAML，动态设置 server-id 并自动配置主从复制
- 验证集群同步状态
准备工作
- 一个可用的 Kubernetes 集群（版本 1.18+）
- 已配置默认 StorageClass 或准备使用特定 StorageClass
kubectl命令行工具已配置好集群访问权限- 基本了解 MySQL 主从复制和 GTID 概念
1. 创建 Namespace
我们将所有资源放在独立的命名空间 mysql 中，方便管理。
kubectl create namespace mysql2. 配置 MySQL 配置文件（ConfigMap）
我们需要为 MySQL 提供自定义配置，开启 GTID 模式并设置必要的复制参数。同时，我们将把两个初始化脚本也放入 ConfigMap：
init.sh：容器启动时运行的脚本，根据 Pod 名称设置唯一的server-id，然后启动 MySQL。init-replication.sh：当 MySQL 数据目录为空（首次启动）时，由 MySQL 官方镜像自动执行的初始化脚本。它负责创建复制用户，并在从库上配置 CHANGE MASTER。
创建 mysql-configmap.yaml：
apiVersion: v1 kind: ConfigMap metadata: name: mysql-config namespace: mysql data: my.cnf: | [mysqld] server-id = 1 # 占位，实际会被 init.sh 动态覆盖 gtid_mode = ON enforce_gtid_consistency = ON log_replica_updates = ON binlog_format = ROW log_bin = mysql-bin relay_log = mysql-relay-bin expire_logs_days = 7 symbolic-links = 0 init.sh: | #!/bin/bash set -e # 从 Pod 主机名中提取索引（例如 mysql-0 → 0） HOSTNAME=$(hostname) INDEX=${HOSTNAME##*-} # 生成 server-id (索引+1，确保唯一) SERVER_ID=$((INDEX + 1)) # 将 server-id 写入独立的配置文件 cat > /etc/mysql/conf.d/server-id.cnf <<EOF [mysqld] server-id = ${SERVER_ID} EOF echo "Generated server-id = ${SERVER_ID} for pod ${HOSTNAME}" # 调用官方 entrypoint 启动 MySQL，并传递所有参数 exec /usr/local/bin/docker-entrypoint.sh "$@" init-replication.sh: | #!/bin/bash set -e # 从主机名获取 Pod 索引 HOSTNAME=$(hostname) INDEX=${HOSTNAME##*-} # 获取密码（通过环境变量传入） MYSQL_ROOT_PASSWORD="${MYSQL_ROOT_PASSWORD}" REPL_USER="${REPL_USER}" REPL_PASSWORD="${REPL_PASSWORD}" if [ "$INDEX" = "0" ]; then # 主库 (mysql-0)：创建复制用户 echo "Primary node: creating replication user..." mysql -uroot -p"$MYSQL_ROOT_PASSWORD" <<-EOSQL CREATE USER IF NOT EXISTS '$REPL_USER'@'%' IDENTIFIED BY '$REPL_PASSWO