動態建立MySQL Group Replication的節點(r11筆記第84天)
阿新 • • 發佈：2022-05-05
前幾天分享了下搭建MySQL Group Replication的指令碼，
分分鐘搭建MySQL Group Replication測試環境(r11筆記第82天) 其實感覺還是不太踏實，雖然我成功搭建了3個節點的環境，但是有不少問題還沒有解決，甚至是特意避開了。
1.節點數都是在腳本里固定的，想搭建4個，6個節點的，完全適應不了
2.模板臃腫，每個節點一個引數模板，其實就幾個引數不一樣
3.單主模式下的節點，其實就一個寫節點的配置略有不同，其它節點配置都是一樣的，但是腳本里也是寫固定了。
4.埠也是寫固定了，沒法再改了。
我能夠一口氣列出很多很多的缺點，但是你說這麼多缺點，搭建3個節點耗時多少，大概不到1分鐘，明顯滿足需求。
在這個方面，看著臃腫的指令碼就有些難受，我決定做些什麼，我自己在想，我想搭建5個節點的環境，能不能秒級完成，最多的節點數是9個，我能不能1分鐘左右模擬出來這個超限的錯誤。所以我重新改了一版指令碼，把之前碰到的問題大部分都做了整合。
首先說兩個配置檔案。這個檔案是動態搭建的核心，每個節點的埠號，節點的編碼（自定義），是否為主節點等都一一做了標識。
[root@grtest data]# cat init.lst 24801 s1 24901 Y 24802 s2 24902 N 24803 s3 24903 N 24804 s4 24904 N 24805 s5 24905 N 24806 s6 24906 N 24807 s7 24907 N 24808 s8 24908 N 24809 s9 24909 N
接下來就是引數檔案,裡面的動態部分都使用變數來達到動態替換的效果。
[root@grtest data]# cat s.cnf [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
其中難點在於引數group_replication_group_seeds=這個引數值需要花點功夫拼出來。
除此之外，就沒有其它的配置檔案了，直接上我們的核心指令碼。
get_seed_list就是特別處理引數group_replication_group_seeds的值，init_node用來初始化各個節點。
base_dir=/usr/local/mysql
base_data_dir=/home/mysql/data
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
${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=ON;
START GROUP_REPLICATION;
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 "
SET SQL_LOG_BIN=0;
CREATE USER rpl_user@'%';
GRANT REPLICATION SLAVE ON *.* TO rpl_user@'%' IDENTIFIED BY 'rpl_pass';
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_allow_local_disjoint_gtids_join=on;
start group_replication;
select *from performance_schema.replication_group_members;
"
else
echo 'Please check variable primary_flag'
fi
}
#MAIN
while read line
do
echo ${seed_list}
init_node $line
done <init.lst我們花一兩分鐘來模擬一下節點數超限的問題。
即在init.lst新增10個節點資訊。
很快就得到了報錯資訊：
ERROR 3191 (HY000) at line 10: The START GROUP_REPLICATION command failed since the group already has 9 members.