!!!由于MySQL官方驱动还不支持Group Replication，因此当前只是服务端可用，客户端驱动还需要等待新版本。
本文描述如何使用Docker+DockerCompose来部署一个MySQL的高可用集群。
此集群由3个MySQL实例组成，一个Master节点，2个Secondary节点。Master可读写，Secondary可读。集群之间会自动同步数据。Master失效剩余的Secondary会自动选举Master。
- 请准备三台Linux VM(Ubuntu14.04)，最好是异地的
- 每台VM上请部署docker
由于公司内部网络隔离，很多地址需要从公司内镜像网站下载。请注意，某些配置步骤在可以直连外网的情况下并不需要。
配置Docker环境（每台VM）
-
在配置文件/etc/default/docker中DOCKER_OPTS选项添加
--insecure-registry hub.witcloud.huawei.com，并重启docker服务 -
执行
apt-get install python-pip -
配置pip公司内网镜像
在~/.pip/目录下增加pip.conf文件 然后编辑其内容为： [global] trusted-host=rnd-mirrors.huawei.com index-url=http://rnd-mirrors.huawei.com/pypi/simple/ -
安装docker-compose
pip install docker-compose
部署完成后就可以使用docker-compose来进行镜像的下载和容器的启动了。
使用Docker部署MySQL（每台VM）
首先我们要编写DockerCompose文件，用于配置MySQL镜像的启动。
mkdir /home/docker/mysql -p
vim /home/docker/mysql/docker-compose.yml
注意：因为数据库容量未来可能较大，因此最好将大容量磁盘挂载到/data目录。
version: '2'
services:
mysql:
network_mode: "host"
environment:
MYSQL_ROOT_PASSWORD: "blu3Spoon55"
image: hub.witcloud.huawei.com/it-ark/mysql
restart: unless-stopped
volumes:
- "/data/mysql/db:/var/lib/mysql"
- "/data/mysql/conf:/etc/mysql/conf.d"
MYSQL_ROOT_PASSWORD为管理员密码，请自己设置一个强密码。
配置Group Replication节点（每台VM）
需要注意的差异如下：
-
server_id每台VM不同节点1: 1 节点2: 2 节点3: 3 -
loose-group_replication_local_address每台VM不同节点1: 10.183.22.167:24901 节点2: 100.112.98.176:24901 节点3: 10.167.117.41:24901 -
bind-address和report_host绑定为各VM的IP地址
我们使用配置文件来对集群进行配置：
mkdir /data/mysql/conf -p
vim /data/mysql/conf/ha.cnf
文件内容：
[mysqld]
#Encoding
collation-server = utf8_unicode_ci
init-connect='SET NAMES utf8'
character-set-server = utf8
#Replication Framework
gtid_mode=ON
enforce_gtid_consistency=ON
master_info_repository=TABLE
relay_log_info_repository=TABLE
binlog_checksum=NONE
log_slave_updates=ON
log_bin=binlog
binlog_format=ROW
# Host specific replication configuration
server_id=1
bind-address="10.183.22.167"
report_host="10.183.22.167"
loose-group_replication_local_address ="10.183.22.167:24901"
#Group Replication
transaction_write_set_extraction=XXHASH64
loose-group_replication_group_name="9a261783-7436-4df7-be2c-97fc7b37eb85"
loose-group_replication_start_on_boot=on
loose-group_replication_group_seeds="10.183.22.167:24901,100.112.98.176:24901,10.167.117.41:24901"
loose-group_replication_bootstrap_group=off
loose-group_replication_ip_whitelist="10.183.22.167,100.112.98.176,10.167.117.41,127.0.0.1/8"
依次启动每个节点，进行数据库内部配置
-
启动节点数据库
docker-compose up -d -
使用数据库工具链接节点
-
仅针对节点2,3，第一个节点不用:清理Docker容器内部产生的binlog，从完全干净的状态进行集群同步
RESET MASTER ; -
创建group replication所需要的用户
SET SQL_LOG_BIN =0; CREATE USER rpl_user@'%' IDENTIFIED BY 'rpl_pass'; GRANT REPLICATION SLAVE ON *.* TO rpl_user@'%'; FLUSH PRIVILEGES ; SET SQL_LOG_BIN =1; CHANGE MASTER TO MASTER_USER ='rpl_user', MASTER_PASSWORD ='rpl_pass' FOR CHANNEL 'group_replication_recovery'; -
安装组复制插件
INSTALL PLUGIN group_replication SONAME 'group_replication.so';检查是否插件是否启用：
mysql> SHOW PLUGINS; +----------------------------+----------+--------------------+----------------------+-------------+ | Name | Status | Type | Library | License | +----------------------------+----------+--------------------+----------------------+-------------+ | binlog | ACTIVE | STORAGE ENGINE | NULL | PROPRIETARY | (...) | group_replication | ACTIVE | GROUP REPLICATION | group_replication.so | PROPRIETARY | +----------------------------+----------+--------------------+----------------------+-------------+ -
启动group replication
-
节点1：
SET GLOBAL group_replication_bootstrap_group=ON; START GROUP_REPLICATION; SET GLOBAL group_replication_bootstrap_group=OFF; -
节点2/3
START GROUP_REPLICATION;
-
节点1：
-
仅针对节点1: 增加一些测试数据，用于测试节点2和节点3是否同步了数据
CREATE DATABASE test; use test; CREATE TABLE t1 (c1 INT PRIMARY KEY, c2 TEXT NOT NULL); INSERT INTO t1 VALUES (1, 'mysql集群测试');
客户端使用
!!!由于MySQL官方驱动还不支持Group Replication，因此当前只是服务端可用，客户端驱动还需要等待新版本。
官方ConnectJ支持使用Replication，以支持MySQL Group Replication。
只需要在连接字符串中配置即可：
jdbc:mysql:loadbalance://100.112.98.176:3306,10.183.22.167:3306,10.167.117.41:3306
应用程序代码无需修改，驱动会自动判断可用的Master。
Master/Secondary异步延时
由于Master/Secondary之间的数据同步存在一定延时，可能导致先写入后读取的时候，读取不到数据。
举例说明：
- 线程A在Master 1上插入一条数据，id为6217614201566007296
- 线程A把此ID(6217614201566007296)给线程B
- 线程B在Secondary 1上通过此ID(6217614201566007296)读取数据
- 但是此时数据还未从Master1同步到Secondary 1
- 线程B读取数据为空
因此，在这种情况下，由于写入到读取之间可能存在延时，那么在写入之后的处理阶段（比如线程B），需要增加重试或者延时，来等待数据同步。
这也是分布式数据库最终一致性带来的问题。
网友评论