docker 搭建 MySQL MGR (MySQL Group Replication) 集群

version: '3.8'

services:
  mysql1:
    image: mysql:8.4
    container_name: mysql1
    hostname: mysql1
    environment:
      MYSQL_ROOT_PASSWORD: rootpassword
      MYSQL_ROOT_HOST: '%'
    # MGR 8.4 节点必须开启 GTID 和 binlog，同时设置唯一的 server-id 和汇报的主机名
    command:
      - --server-id=1
      - --report-host=mysql1
      - --enforce-gtid-consistency=ON
      - --gtid-mode=ON
    ports:
      - '33061:3306'

  mysql2:
    image: mysql:8.4
    container_name: mysql2
    hostname: mysql2
    environment:
      MYSQL_ROOT_PASSWORD: rootpassword
      MYSQL_ROOT_HOST: '%'
    command:
      - --server-id=2
      - --report-host=mysql2
      - --enforce-gtid-consistency=ON
      - --gtid-mode=ON

  mysql3:
    image: mysql:8.4
    container_name: mysql3
    hostname: mysql3
    environment:
      MYSQL_ROOT_PASSWORD: rootpassword
      MYSQL_ROOT_HOST: '%'
    command:
      - --server-id=3
      - --report-host=mysql3
      - --enforce-gtid-consistency=ON
      - --gtid-mode=ON

  mysql-shell:
    image: mysql/mysql-shell:latest
    container_name: mysql-shell
    volumes:
      - ./init-cluster.js:/scripts/init-cluster.js
    command: tail -f /dev/null
    depends_on:
      - mysql1
      - mysql2
      - mysql3

  mysql-router:
    image: mysql/mysql-router:latest
    container_name: mysql-router
    environment:
      MYSQL_HOST: mysql1
      MYSQL_PORT: 3306
      MYSQL_USER: root
      MYSQL_PASSWORD: rootpassword
    ports:
      - '6446:6446' # 业务主库入口（读写）
      - '6447:6447' # 业务从库入口（只读）
    depends_on:
      - mysql1
    profiles:
      - router # 标记为 router profile，以使其不会随着默认启动而启动

var pwd = 'rootpassword';

print('\n[1/5] 连接到主节点 mysql1...\n');
shell.connect('root:' + pwd + '@mysql1:3306');

print('\n[2/5] 开始预配置各个实例 (自动设置 MGR 依赖的环境变量)...\n');
dba.configureInstance('root:' + pwd + '@mysql1:3306', { interactive: false });
dba.configureInstance('root:' + pwd + '@mysql2:3306', { interactive: false });
dba.configureInstance('root:' + pwd + '@mysql3:3306', { interactive: false });

print('\n[3/5] 基于 mysql1 创建 InnoDB 集群...\n');
var cluster = dba.createCluster('MyAwesomeCluster');

print('\n[4/5] 添加 mysql2 到集群，并使用原生 Clone 插件同步数据...\n');
cluster.addInstance('root:' + pwd + '@mysql2:3306', { recoveryMethod: 'clone', interactive: false });

print('\n[5/5] 添加 mysql3 到集群，并使用原生 Clone 插件同步数据...\n');
cluster.addInstance('root:' + pwd + '@mysql3:3306', { recoveryMethod: 'clone', interactive: false });

print('\n====== 集群创建成功，当前状态如下 ======\n');
print(JSON.stringify(cluster.status(), null, 4));

docker-compose up -d

docker exec -it mysql-shell mysqlsh --js -f /scripts/init-cluster.js

docker-compose --profile router up -d

// 登录任意集群节点
mysqlsh root@mysql1:3306

// 在 JS 模式下获取集群对象
var cluster = dba.getCluster();

// 1. 查看 3 节点健康状态
cluster.status();

// 2. 将 mysql2 手动切换为新的主库（平滑切换，不丢数据）
cluster.setPrimaryInstance('mysql2:3306');

// 3. 踢出故障节点
cluster.removeInstance('mysql3:3306');

# 在部署 Router 的机器上执行，假设 mysql1 是集群中任意一个存活节点
mysqlrouter --bootstrap root@mysql1:3306 --user=mysqlrouter

# 启动 router
systemctl start mysqlrouter

[应用层集群] (包含多个微服务节点)
   │
   ├── App Server 1
   │    └── 本地运行 MySQL Router (监听本地 127.0.0.1:6446)
   │           │
   ├── App Server 2
   │    └── 本地运行 MySQL Router (监听本地 127.0.0.1:6446)
   │           │
   ...         │ (Router 通过内网直连底层的 3 个数据库节点)
               │
============== 内部网络边界 ===============================
               │
[MySQL InnoDB Cluster 数据层] (MGR 无中心复制)
               │
    ┌──────────┼──────────┐ (Router 自动将 6446 流量发给 Primary，6447 发给 Secondary)
    ▼          ▼          ▼
[节点 1]    [节点 2]    [节点 3]
Primary    Secondary  Secondary
(读写)      (只读)     (只读)
    ▲          ▲          ▲
    └──────────┴──────────┘
               │
         (DBA 偶尔通过中控机的 MySQL Shell 连接进行管理维护)

docker stop mysql1