MySQL8.0.16新特性：The Communication Protocol In Group Replication

mgr优雅升级到mysql8.0.16

　　传统的升级手段之一，5.7 mgr集群与8.0 mgr集群进行数据传输，程序切换新集群后测试是否正常，如果不正常，要么将新集群的新增数据同步回旧集群，要么就舍弃掉这部分数据，一般看来这种回滚都是繁琐的，繁琐的操作一般都会相应的增加风险。

 

　　8.0.16的发布也带来一个新的功能-mgr通信协议的支持，可以让我们更轻松地切换到8.0，或者轻松地再切换回5.7。那么什么是mgr通信协议呢？ 

mgr通信协议(the communication protocol in group replication)

  从mysql 8.0.16中，mgr有一个通信协议的概念。可以直接管理mgr通信协议版本，并将其设置为适应你希望mgr成员支持的哪个mysql服务器版本。

 

  从而实现同一个mgr可用组中可以由不同mysql服务器版本的成员组成。

 

  是的你没有看错，也就是说：

 

成员1：8.0.16

​成员2：8.0.16

​成员3：5.7.22

​他们可以组成一个mgr集群了。

  同时确保向后兼容性。mysql 5.7.14的版本允许压缩消息，而mysql 8.0.16的版本也允许消息碎片化。

 

  同一个组中的所有成员必须使用相同的通信协议版本，以便mgr成员虽然各自处于不同的mysql版本，但他们之间只能发送所有mgr成员都能理解的消息。

 

  如果组的通信协议版本小于或等于x，则版本x的mysql服务器只能在复制组中加入并达到online状态。当新成员加入复制组时，它会检查通告的通信协议版本。

 

  该小组的现有成员。 如果加入成员支持该版本，则它加入该组并使用该组已宣布的通信协议，即使该成员支持其他通信功能。 如果加入成员不支持通信协议版本，则将其从组中驱逐出去。

 

  如果两个成员尝试加入相同的mgr集群，则只有两个成员的通信协议版本已与该mgr已有成员的通信协议版本兼容时，它们才能加入。 来自该组的具有不同通信协议版本的成员必须单独加入。 

     例如：

1个mysql server 8.0.16实例可以成功加入使用通信协议版本为5.7.22的组。
1个mysql server 5.7.22实例无法加入使用通信协议版本为8.0.16的组。
2个mysql server 8.0.16实例无法同时加入使用通信协议版本为5.7.22的组。
2个mysql server 8.0.16实例可以同时加入使用通信协议版本8.0.16的组

 

两个核心udf (user defined function)

1.    group_replication_get_communication_protocol

　　用于获取该mgr成员中最早的mysql版本的通信协议

 

select group_replication_get_communication_protocol();

 

 2.    group_replication_set_communication_protocol

 

　　需要更改mgr的通信协议版本以便早期版本的成员可以加入，需要具有group_replication_admin 权限哦

select group_replication_set_communication_protocol("5.7.22");

　　

　　如果后续将mgr的成员都升级成同一版本（原集群中最新的版本），通信协议是不会自动升级兼容的，需要继续执行group_replication_set_communication_protocol函数来指定：

select group_replication_set_communication_pruseotocol("8.0.16");

　　

demo

 

环境：

集群的节点：

192.168.4.35:3309 - primary node - mysql 5.7.25 

192.168.4.34:3309 - seconds node - mysql 5.7.25

192.168.4.36:3309 - seconds node - mysql 5.7.25

希望加入集群的节点：

192.168.4.35:3816 - mysql 8.0.16

 

 

 开始测试    

　　primary node (192.168.4.35 3309)：

show master status;
+-----------------------------+----------+--------------+------------------+-------------------------------------------------------------------+
| file                        | position | binlog_do_db | binlog_ignore_db | executed_gtid_set                                                 |
+-----------------------------+----------+--------------+------------------+-------------------------------------------------------------------+
| 0040353309-mysql-bin.000037 |  4090993 |              |                  | 2c7b4762-5963-5789-acdd-047677b98a9d:1-32876403:33576383-33576398 |
+-----------------------------+----------+--------------+------------------+-------------------------------------------------------------------+

 

　　新节点（192.168.4.35 3816）mysql 8.0.16

change master + install plugin 请自行完成
​
-- 如果通过还原已同步了gtid，忽略此步骤，这里为了简单测试，顾新节点没有同步原集群数据。
​
reset master;
​
set global gtid_purge = '2c7b4762-5963-5789-acdd-047677b98a9d:1-32876403:33576383-33576398'
 
-- 设置mgr相关参数

set global binlog_checksum = none;
​
set global group_replication_group_name = '2c7b4762-5963-5789-acdd-047677b98a9d';
​
set global group_replication_local_address = '192.168.4.35:23816';
​
set global group_replication_group_seeds = "192.168.4.35:23309";
​
set global group_replication_bootstrap_group = off;
​
set global group_replication_single_primary_mode = 0;
​
set global group_replication_enforce_update_everywhere_checks = 0;
​
set global group_replication_unreachable_majority_timeout = 120;
​
set global group_replication_enforce_update_everywhere_checks = 1;
​
-- 启动集群
​
start group_replication
​
-- 尝试执行udf：group_replication_get_communication_protocol：
​
select group_replication_get_communication_protocol();
+------------------------------------------------+
| group_replication_get_communication_protocol() |
+------------------------------------------------+
| 5.7.14                                         |
+------------------------------------------------+
​
-- mysql 8.0.16 加入由全部节点均为5.7.25版本，自动将通讯协议降成了5.7.14，以便相互通讯兼容。
​
-- 同时也说明 mysql的通信协议版本可能和mysql实例版本有可能不是一致的哦（这点还需要论证下，不敢打包票）
​
-- 注意：如果出现以下错误，原因是执行udf，必须要在集群成员均为online对的状态下才可执行

-- error 1123 (hy000): can't initialize function 'group_replication_get_communication_protocol'; a member is joining the group, wait for it to be online.'
-- 查看集群节点状态：
[performance_schema]> select * from replication_group_members;
+---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
| channel_name              | member_id                            | member_host | member_port | member_state | member_role | member_version |
+---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
| group_replication_applier | 6990a8f4-777c-11e9-a906-20040fecc760 | node004035  |        3816 | online       | secondary   | 8.0.16         |
| group_replication_applier | cc11c7de-446a-11e9-ae80-20040fecc760 | node004035  |        3309 | online       | secondary   | 5.7.25         |
| group_replication_applier | cc830e26-446a-11e9-be34-20040fed73f8 | node004036  |        3309 | online       | secondary   | 5.7.25         |
| group_replication_applier | cc88974a-446a-11e9-9e99-20040fed8fd8 | node004034  |        3309 | online       | primary     | 5.7.25         |
+---------------------------+--------------------------------------+-------------+-------------+--------------+-------------+----------------+
 

 搭建完成，均手工测试，数据可正常同步及读取。测试数据就不在这里介绍，可自行玩耍。

 

总的来说，这个特性对于已5.7 mgr为主的公司，但又想体验8.0的一些特性是个非常好的利器。架构支持了不同的mysql版本，玩法就可以多种多样了.

 

参考文档：