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

news/2024/7/7 19:12:17

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版本,玩法就可以多种多样了。

  迁移时一定要注意数据一致性,第一优先级保证:无论迁移前、中、后的数据同步,或者迁移后的失败回迁,都要保证两边数据一定要一致。当你面临修复数据,你就会知道它是个无底洞了。

 

参考文档:

https://dev.mysql.com/doc/refman/8.0/en/group-replication-communication-protocol.html

 
  
 
 

转载于:https://www.cnblogs.com/SQLServer2012/p/10884909.html


http://www.niftyadmin.cn/n/1933754.html

相关文章

wsgiref模块

使用流程 from urllib.parse import parse_qs#导入parse_qs用于解析form提交的数据from wsgiref.simple_server import make_server#导入make_server方法def fun(environ,start_response):xxxreturn [data]   #最终必须返回一个列表httpdmake_server(127.0.0.1,10086,fun)#类…

Python19/1/11--标签与过滤器/Django模块导入继承/静态文件配置

1 模板语言之变量: -{{ }} 相当于执行了print -深度查询 . 如果是方法,不能加括号,不能传参数2 过滤器 {{ 变量|过滤器的名字:参数 }} -add -default -safe:(慎重,注意xss攻击) -在视图层处理标签字符串:href2mark_safe(href) -length -date3…

「青松资讯」2019年第三季度DDoS攻击报告

新闻概述 上季度,我们发现一种新的DDoS攻击,攻击者利用Memcached协议进行放大攻击,正如之前我们的推测。比如,安全人员最近发现一类攻击是通过WS-Discovery多播协议欺骗返回IP地址。虽然网络罪犯最近才开始使用这种方法&#xff…

React Hook 不完全指南

前言 本文内容大部分参考了 overreacted.io 博客一文,同时结合 React Hook 官方 文章,整理并归纳一些笔记和输出个人的一些理解 什么是 Hook ? 官方介绍:Hook 是 React 16.8 的新增特性。它可以让你在不编写 class 的情况下使用 s…

Router入门0x204: react-route简单栗子

0x000 概述 这一章仔细讲一讲 react-route 的使用栗子 0x001 简单使用 源码 import React from react import ReactDom from react-dom import {BrowserRouter, Switch, Route, Link, withRouter} from react-router-dom// 简单使用 class App extends React.Component {render…

2018-2019-2 20165235《网络对抗技术》Exp8 Web基础

2018-2019-2 20165235《网络对抗技术》Exp8 Web基础 实践过程记录: (1).Web前端HTML 能正常安装、启停Apache。理解HTML,理解表单,理解GET与POST方法,编写一个含有表单的HTML。 直接使用service apache2 start命令可打开Apache服务在浏览器输…

浏览器中的诈骗广告,你留意过吗?

2015年,推送通知刚刚出现在浏览器上,很少有人想知道这个工具将来会如何使用。它曾经是一种有用的技术,可以让经常阅读它的读者了解最新消息,但如今它经常被用来向网站访问者发送未经请求的广告。 受访者最终订阅了广告&#xff0…

知识点049-supervisor

2019独角兽企业重金招聘Python工程师标准>>> supervisor安装 cd /usr/local/src wget https://pypi.python.org/packages/7b/17/88adf8cb25f80e2bc0d18e094fcd7ab300632ea00b601cbbbb84c2419eae/supervisor-3.3.2.tar.gz tar -zxvf supervisor-3.3.2.tar.gz cd supe…