分分鐘搭建MySQL Group Replication測試環境（二）(r12筆記第41天)

   之前總結過一篇，是分分鐘搭建MySQL MGR環境的，但是有一個地方還有待改善，那就是那個腳本僅僅支援single-primary模式，不支援多主模式，而官方文檔中這部分資訊還比較少。

   我覺得這部分内容一方面和本身MGR的多主支援還不夠成熟也有關系，需要一個過渡。但是如果想測試測試也是完全可以的，是以我決定改進我的腳本。

   大體來說，如果要開啟多主模式，如果能夠輕松搭建出單主，讀寫分離的架構，那麼搭建多主是很簡單的一件事情。

在原來單主模式的主節點執行操作如下：

stop GROUP_REPLICATION;

set global group_replication_single_primary_mode=off;

set global group_replication_enforce_update_everywhere_checks=ON;

SET GLOBAL group_replication_bootstrap_group=ON;

START GROUP_REPLICATION;

SET GLOBAL group_replication_bootstrap_group=OFF;而對于他的節點，執行下面的操作即可。

start group_replication;

裡面有一個地方比較有意思，那就是我需要修改不少校驗邏輯在配置檔案上。

原本的額配置檔案依舊不變,通過下面的配置能夠标示那個是主寫節點，搭建出讀寫風能力的架構後，再根據條件進行多主的設定。裡面的重點就是第四列的處理上。

# cat init.lst

24801 s1  24901  Y

24802 s2  24902  Y

24803 s3  24903  Y資料庫的參數模闆檔案如下：

[mysqld]

# server configuration

datadir=${base_data_dir}/${node_name}

basedir=${base_dir}

port=${port}

socket=${base_data_dir}/${node_name}/${node_name}.sock

server_id=${port}

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

transaction_write_set_extraction=XXHASH64

loose-group_replication_group_name="1bb1b861-f776-11e6-be42-782bcb377193"

loose-group_replication_start_on_boot=off

loose-group_replication_local_address= "127.0.0.1:${v_port}"

loose-group_replication_group_seeds= "${seed_list}"

loose-group_replication_bootstrap_group= off這個模闆檔案的内容會根據配置而動态生成。

關鍵的部分就是如何初始化，如果有條不紊的進行多主環境的階段性演進。

base_dir=/usr/local/mysql

base_data_dir=/home/data

init_node_flag=`cat init.lst|head -1|awk '{print $4}'`

function get_seed_list

{

while read line

do

tmp_port='127.0.0.1:'`echo $line|awk '{print $3}'`

echo ${tmp_port}

done <init.lst|xargs |sed 's/ /,/g'

}

export seed_list=`get_seed_list`

#echo ${seed_list}

function init_node

echo $seed_list

port=$1

node_name=$2

v_port=$3

primary_flag=$4

init_node_flag=`cat init.lst|head -1|grep -w ${port}`

if [[ -z ${init_node_flag} ]];

then

init_node_flag='N'

else

init_node_flag='Y'

fi

echo $init_node_flag

if [ ${primary_flag} = 'Y' -a ${init_node_flag} = 'Y' ];

primary_flag='Y'

primary_flag='N'

${base_dir}/bin/mysqld

--initialize-insecure --basedir=${base_dir}

--datadir=${base_data_dir}/${node_name}

--explicit_defaults_for_timestamp

chown -R mysql:mysql  ${base_data_dir}/${node_dir}

cp ${base_data_dir}/s.cnf ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's:${base_data_dir}:'"${base_data_dir}:g"'' ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's:${base_dir}:'"${base_dir}:g"'' ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's:${node_name}:'"${node_name}:g"''  ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's:${port}:'"${port}:g"''  ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's:${v_port}:'"${v_port}:g"'' ${base_data_dir}/${node_name}/${node_name}.cnf

sed -i 's/${seed_list}/'"${seed_list}/g"'' ${base_data_dir}/${node_name}/${node_name}.cnf

chown -R mysql:mysql ${base_data_dir}/${node_name}

${base_dir}/bin/mysqld_safe --defaults-file=${base_data_dir}/${node_name}/${node_name}.cnf &

sleep  5

${base_dir}/bin/mysql -P${port}  -S ${base_data_dir}/${node_name}/${node_name}.sock  -e "show databases"

if [[ ${primary_flag} = 'Y' ]];then

mysql -P${port}  -S ${base_data_dir}/${node_name}/${node_name}.sock -e "

SET SQL_LOG_BIN=0;

CREATE USER rpl_user@'%';

GRANT REPLICATION SLAVE ON *.* TO rpl_user@'%' IDENTIFIED BY 'rpl_pass';

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';               

SET GLOBAL group_replication_bootstrap_group=OFF;

select *from performance_schema.replication_group_members;

"

elif [[ ${primary_flag} = 'N' ]];then

mysql -P${port}  -S ${base_data_dir}/${node_name}/${node_name}.sock -e   "

        FOR CHANNEL 'group_replication_recovery';

INSTALL PLUGIN group_replication SONAME 'group_replication.so';

set global group_replication_allow_local_disjoint_gtids_join=on;

   echo 'Please check variable primary_flag'

function reset_node

init_node_flag=`cat init.lst|sed -n '2p'|awk '{print $4}'`

if [ ${init_node_flag} = 'N' ];

 exit

  echo change

elif [ ${primary_flag} = 'Y' -a ${init_node_flag} = 'N'  ];then

#MAIN

echo ${seed_list}

echo ok

init_node $line

done <init.lst

reset_node $line

done <init.lst   運作這個腳本隻需要sh init.sh即可，這個過程會自動讀取配置檔案init.lst的配置，然後初始化，搭建出多主的環境來，整個過程也就分分鐘即可搞定。

   整個腳本會執行兩大部分的内容，一個是函數init_node，一個是reset_node。init_node會初始化，搭建傳統的單主MGR環境，而reset_node是在單主模式的基礎上的設定，把單主改變為多主。

    感興趣的同學可以多加交流，後期我打算放在github上，讓更多的朋友來參考，提出改進建議。