Mysql数据库平滑扩容解决高并发和大数据量问题 3

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
云数据库 RDS PostgreSQL,集群系列 2核4GB
简介: Mysql数据库平滑扩容解决高并发和大数据量问题

5 数据库秒级平滑2N扩容实践

扩容部署架构:

5.1 新增数据库VIP

  1. 在Server2节点, 增加VIP
    修改/etc/keepalived/keepalived.conf,追加:
...
vrrp_instance VI_2 {       #vrrp实例定义
 state BACKUP        #lvs的状态模式,MASTER代表主, BACKUP代表备份节点
 interface ens33        #绑定对外访问的网卡
 virtual_router_id 112     #虚拟路由标示,同一个vrrp实例采用唯一标示
 priority 100        #优先级,100代表最大优先级, 数字越大优先级越高
 advert_int 1        #master与backup节点同步检查的时间间隔,单位是秒
 authentication {      #设置验证信息
   auth_type PASS     #有PASS和AH两种
   auth_pass 6666     #验证密码,BACKUP密码须相同
 }
 virtual_ipaddress {     #KeepAlived虚拟的IP地址
    10.10.20.131
 }
}
virtual_server 10.10.20.131 3306 {    #配置虚拟服务器IP与访问端口
 delay_loop 6         #健康检查时间
 persistence_timeout 0     #会话保持时间,这里要做测试, 所以设为0, 实际可根
据session有效时间配置
 protocol TCP        #转发协议类型,支持TCP和UDP
 real_server 10.10.20.126 3306{   #配置服务器节点VIP1
 notify_down /usr/local/shell/mariadb.sh
 weight 1        #设置权重,越大权重越高
 TCP_CHECK {        #r状态监测设置
   connect_timeout 10    #超时配置, 单位秒
   retry 3       #重试次数
   delay_before_retry 3     #重试间隔
   connect_port 3306     #连接端口, 和上面保持一致
   }
 }
}

注意配置项:

virtual_router_id 112     #虚拟路由标示,同一个vrrp实例采用唯一标示
priority 100        #优先级,100代表最大优先级, 数字越大优先级越高

5.2 应用服务增加动态数据源

  1. 修改应用服务配置, 增加新的数据源, 指向新设置的VIP: 10.10.20.131
  2. 通过应用服务接口, 动态扩容调整

5.3 解除原双主同步

  1. 进入Server1: MariaDB [(none)]> stop slave;
  2. 进入Server2:MariaDB [(none)]> stop slave;
  3. 通过应用服务接口验证数据是否解除同步

5.4 安装MariaDB扩容服务器

  1. 新建两台虚拟机, 分别为Server3和Server4。
  2. 在Server3和Server4两台节点上安装MariaDB服务
    参考 MariaDB服务安装
  3. 配置Server3与Server1,实现新的双主同步
  4. Server3节点, 修改/etc/my.cnf:
[mysqld]
server-id = 2
log-bin=mysql-bin
relay-log = mysql-relay-bin
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
log-slave-updates=on
slave-skip-errors=all
auto-increment-offset=2
auto-increment-increment=2
binlog_format=mixed
expire_logs_days=10
  1. 重启Server3数据库
    service mariadb restart
  2. 创建replica用于主从同步的用户:
MariaDB [(none)]> grant replication slave, replication client on *.* to
'replica'@'%' identified by 'replica';
mysql> flush privileges;
  1. 在Server1节点,进行数据全量备份:
mysqldump -uroot -p654321 --routines --single_transaction --master-data=2 --
databases smooth > server1.sql
  1. 查看并记录master status信息:
...
--
-- Position to start replication or point-in-time recovery from
--
-- CHANGE MASTER TO MASTER_LOG_FILE='mysql-bin.000002',
MASTER_LOG_POS=17748;
...

将备份的server1.sql通过scp命令拷贝至Server3节点。scp server1.sql root@10.10.20.127:/usr/local/

将数据还原至Server3节点:mysql -uroot -p654321 < /usr/local/server1.sql

  1. 配置主从同步信息

根据上面的master status信息, 在Server3中执行:

MariaDB [(none)]> change master to
master_host='10.10.20.125',master_user='replica', master_password='replica',
master_port=3306, master_log_file='mysql-bin.000002', master_log_pos=17748,
master_connect_retry=30;
Query OK, 0 rows affected (0.01 sec)
  1. 开启主从同步:
MariaDB [(none)]> start slave;
Query OK, 0 rows affected (0.00 sec)

如果出现问题, 复原主从同步信息:

MariaDB [(none)]> reset slave;
Query OK, 0 rows affected (0.01 sec)
  1. 检查同步状态信息:
MariaDB [(none)]> show slave status \G
*************************** 1. row ***************************
       Slave_IO_State: Waiting for master to send event
        Master_Host: 10.10.20.125
        Master_User: replica
        Master_Port: 3306
       Connect_Retry: 30
      Master_Log_File: mysql-bin.000004
    Read_Master_Log_Pos: 11174
       Relay_Log_File: mysql-relay-bin.000002
       Relay_Log_Pos: 1746
   Relay_Master_Log_File: mysql-bin.000004
      Slave_IO_Running: Yes
     Slave_SQL_Running: Yes
  1. 配置Server1与Server3节点的同步
    查看Server3的日志信息:
MariaDB [(none)]> show master status;
+------------------+----------+--------------+------------------+
| File       | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+------------------+----------+--------------+------------------+
| mysql-bin.000001 |   4781 |       |         |
+------------------+----------+--------------+------------------+

在Server1节点, 配置同步信息:

MariaDB [(none)]> reset slave;
Query OK, 0 rows affected (0.00 sec)
MariaDB [(none)]> change master to
master_host='10.10.20.127',master_user='replica', master_password='replica',
master_port=3306, master_log_file='mysql-bin.000001', master_log_pos=4781,
master_connect_retry=30;
MariaDB [(none)]> start slave;
Query OK, 0 rows affected (0.00 sec)
  1. 配置Server4与Server2的双主同步
  2. Server4节点, 修改/etc/my.cnf:
[mysqld]
server-id = 3
log-bin=mysql-bin
relay-log = mysql-relay-bin
replicate-wild-ignore-table=mysql.%
replicate-wild-ignore-table=information_schema.%
log-slave-updates=on
slave-skip-errors=all
auto-increment-offset=2
auto-increment-increment=2
binlog_format=mixed
expire_logs_days=10
  1. 重启Server4数据库
    service mariadb restart
  2. 创建replica用于主从同步的用户
MariaDB [(none)]> grant replication slave, replication client on *.* to
'replica'@'%' identified by 'replica';
mysql> flush privileges;
  1. 在Server2节点,进行数据全量备份:
mysqldump -uroot -p654321 --routines --single_transaction --master-data=2 --
databases smooth > server2.sql
  1. 查看并记录master status信息:
...
--
-- Position to start replication or point-in-time recovery from
--
-- CHANGE MASTER TO MASTER_LOG_FILE='mysql-bin.000003', MASTER_LOG_POS=4208;
...

将备份的server2.sql通过scp命令拷贝至Server4节点。scp server2.sql root@10.10.20.128:/usr/local/


将数据还原至Server4节点:mysql -uroot -p654321 < /usr/local/server2.sql


配置主从同步信息

根据上面的master status信息, 在Server4中执行:

MariaDB [(none)]> change master to
master_host='10.10.20.126',master_user='replica', master_password='replica',
master_port=3306, master_log_file='mysql-bin.000003', master_log_pos=4208,
master_connect_retry=30;
Query OK, 0 rows affected (0.01 sec)
  1. 开启主从同步:
MariaDB [(none)]> start slave;
Query OK, 0 rows affected (0.00 sec)

注意, 如果出现问题, 复原主从同步信息:

MariaDB [(none)]> reset slave;
Query OK, 0 rows affected (0.01 sec)
  1. 检查同步状态信息:
MariaDB [(none)]> show slave status \G
*************************** 1. row ***************************
       Slave_IO_State: Waiting for master to send event
        Master_Host: 10.10.20.125
        Master_User: replica
        Master_Port: 3306
       Connect_Retry: 30
      Master_Log_File: mysql-bin.000004
    Read_Master_Log_Pos: 11174
       Relay_Log_File: mysql-relay-bin.000002
       Relay_Log_Pos: 1746
   Relay_Master_Log_File: mysql-bin.000004
      Slave_IO_Running: Yes
     Slave_SQL_Running: Yes
  1. 配置Server2与Server4节点的同步
    查看Server4的日志信息:
MariaDB [(none)]> show master status;
+------------------+----------+--------------+------------------+
| File       | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+------------------+----------+--------------+------------------+
| mysql-bin.000001 |   3696 |       |         |
+------------------+----------+--------------+------------------+

在Server2节点, 配置同步信息:

MariaDB [(none)]> reset slave;
Query OK, 0 rows affected (0.00 sec)
MariaDB [(none)]> change master to
master_host='10.10.20.128',master_user='replica', master_password='replica',
master_port=3306, master_log_file='mysql-bin.000001', master_log_pos=3696,
master_connect_retry=30;
MariaDB [(none)]> start slave;
Query OK, 0 rows affected (0.00 sec)

5.5 增加KeepAlived服务实现高可用

  1. 确保新增的Server3和Server4节点安装Keepalived服务。
  2. 修改Server3节点配置
global_defs {
 router_id vip3      # 机器标识,一般设为hostname,故障发生时,邮件通知会使用
到。
}
vrrp_instance VI_1 {       #vrrp实例定义
 state BACKUP        #lvs的状态模式,MASTER代表主, BACKUP代表备份节点
 interface ens33        #绑定对外访问的网卡
 virtual_router_id 111     #虚拟路由标示,同一个vrrp实例采用唯一标示
 priority 98        #优先级,100代表最大优先级, 数字越大优先级越高
 advert_int 1        #master与backup节点同步检查的时间间隔,单位是秒
 authentication {      #设置验证信息
   auth_type PASS     #有PASS和AH两种
   auth_pass 6666     #验证密码,BACKUP密码须相同
 }
 virtual_ipaddress {     #KeepAlived虚拟的IP地址
    10.10.20.130
 }
}
virtual_server 10.10.20.130 3306 {    #配置虚拟服务器IP与访问端口
 delay_loop 6         #健康检查时间
 persistence_timeout 0     #会话保持时间,这里要做测试, 所以设为0, 实际可根
据session有效时间配置
 protocol TCP        #转发协议类型,支持TCP和UDP
 real_server 10.10.20.127 3306{   #配置服务器节点VIP3
 notify_down /usr/local/shell/mariadb.sh
 weight 1        #设置权重,越大权重越高
 TCP_CHECK {        #r状态监测设置
   connect_timeout 10    #超时配置, 单位秒
   retry 3       #重试次数
   delay_before_retry 3     #重试间隔
   connect_port 3306     #连接端口, 和上面保持一致
   }
 }
}

注意里面IP配置正确, 修改完成后重启服务。

创建关闭脚本mariadb.sh

/usr/local/shell/mariadb.sh:

pkill keepalived

加入执行权限:

chmod a+x mariadb.sh

3. 修改Server4节点配置

global_defs {
 router_id vip4      # 机器标识,一般设为hostname,故障发生时,邮件通知会使用
到。
}
vrrp_instance VI_1 {       #vrrp实例定义
 state BACKUP        #lvs的状态模式,MASTER代表主, BACKUP代表备份节点
 interface ens33        #绑定对外访问的网卡
 virtual_router_id 112     #虚拟路由标示,同一个vrrp实例采用唯一标示
 priority 98        #优先级,100代表最大优先级, 数字越大优先级越高
 advert_int 1        #master与backup节点同步检查的时间间隔,单位是秒
 authentication {      #设置验证信息
   auth_type PASS     #有PASS和AH两种
   auth_pass 6666     #验证密码,BACKUP密码须相同
 }
 virtual_ipaddress {     #KeepAlived虚拟的IP地址
    10.10.20.131
 }
}
virtual_server 10.10.20.131 3306 {    #配置虚拟服务器IP与访问端口
 delay_loop 6         #健康检查时间
  persistence_timeout 0     #会话保持时间,这里要做测试, 所以设为0, 实际可根
据session有效时间配置
 protocol TCP        #转发协议类型,支持TCP和UDP
 real_server 10.10.20.128 3306{   #配置服务器节点VIP4
 notify_down /usr/local/shell/mariadb.sh
 weight 1        #设置权重,越大权重越高
 TCP_CHECK {        #r状态监测设置
   connect_timeout 10    #超时配置, 单位秒
   retry 3       #重试次数
   delay_before_retry 3     #重试间隔
   connect_port 3306     #连接端口, 和上面保持一致
   }
 }
}

重启服务,创建关闭脚本mariadb.sh

/usr/local/shell/mariadb.sh:

pkill keepalived

加入执行权限:chmod a+x mariadb.sh

4. 修改Server2节点的keepAlived配置:

global_defs {
 router_id vip2      # 机器标识,一般设为hostname,故障发生时,邮件通知会使用
到。
}
vrrp_instance VI_1 {       #vrrp实例定义
 state BACKUP        #lvs的状态模式,MASTER代表主, BACKUP代表备份节点
 interface ens33        #绑定对外访问的网卡
 virtual_router_id 112     #虚拟路由标示,同一个vrrp实例采用唯一标示
 priority 100        #优先级,100代表最大优先级, 数字越大优先级越高
 advert_int 1        #master与backup节点同步检查的时间间隔,单位是秒
 authentication {      #设置验证信息
   auth_type PASS     #有PASS和AH两种
   auth_pass 6666     #验证密码,BACKUP密码须相同
 }
 virtual_ipaddress {     #KeepAlived虚拟的IP地址
    10.10.20.131
 }
}
virtual_server 10.10.20.131 3306 {    #配置虚拟服务器IP与访问端口
 delay_loop 6         #健康检查时间
 persistence_timeout 0     #会话保持时间,这里要做测试, 所以设为0, 实际可根
据session有效时间配置
 protocol TCP        #转发协议类型,支持TCP和UDP
 real_server 10.10.20.126 3306{   #配置服务器节点VIP1
 notify_down /usr/local/shell/mariadb.sh
 weight 1        #设置权重,越大权重越高
 TCP_CHECK {        #r状态监测设置
   connect_timeout 10    #超时配置, 单位秒
   retry 3       #重试次数
   delay_before_retry 3     #重试间隔
   connect_port 3306     #连接端口, 和上面保持一致
   }
 }
}

修改完后重启Keepalived服务。

5.6 清理数据并验证

  1. 通过应用服务动态扩容接口做调整和验证
  2. 在Server1节点清理数据
  3. 根据取模规则, 保留accountNo为偶数的数据
    delete from t_trade_order where accountNo % 2 != 0
  4. 在Server2节点清理数据

根据取模规则, 保留accountNo为奇数的数据

delete from t_trade_order where accountNo % 2 != 1


相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
25天前
|
存储 人工智能 数据管理
|
18天前
|
存储 人工智能 数据管理
媒体声音|专访阿里云数据库周文超博士:AI就绪的智能数据平台设计思路
在生成式AI的浪潮中,数据的重要性日益凸显。大模型在实际业务场景的落地过程中,必须有海量数据的支撑:经过训练、推理和分析等一系列复杂的数据处理过程,才能最终产生业务价值。事实上,大模型本身就是数据处理后的产物,以数据驱动的决策与创新需要通过更智能的平台解决数据多模处理、实时分析等问题,这正是以阿里云为代表的企业推动 “Data+AI”融合战略的核心动因。
|
3月前
|
算法 大数据 数据库
云计算与大数据平台的数据库迁移与同步
本文详细介绍了云计算与大数据平台的数据库迁移与同步的核心概念、算法原理、具体操作步骤、数学模型公式、代码实例及未来发展趋势与挑战。涵盖全量与增量迁移、一致性与异步复制等内容,旨在帮助读者全面了解并应对相关技术挑战。
70 3
|
3月前
|
存储 缓存 NoSQL
大数据-38 Redis 高并发下的分布式缓存 Redis简介 缓存场景 读写模式 旁路模式 穿透模式 缓存模式 基本概念等
大数据-38 Redis 高并发下的分布式缓存 Redis简介 缓存场景 读写模式 旁路模式 穿透模式 缓存模式 基本概念等
98 4
|
3月前
|
缓存 NoSQL Ubuntu
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
大数据-39 Redis 高并发分布式缓存 Ubuntu源码编译安装 云服务器 启动并测试 redis-server redis-cli
73 3
|
3月前
|
SQL 缓存 大数据
C#高效处理大数据的批次处理,以及最好的数据库设计
C#高效处理大数据的批次处理,以及最好的数据库设计
126 0
|
3月前
|
大数据 关系型数据库 数据库
python 批量处理大数据写入数据库
python 批量处理大数据写入数据库
192 0
|
5月前
|
关系型数据库 MySQL 大数据
教你使用Python玩转MySQL数据库,大数据导入不再是难题!
教你使用Python玩转MySQL数据库,大数据导入不再是难题!
135 1
|
5月前
|
分布式计算 DataWorks 关系型数据库
DataWorks产品使用合集之ODPS数据怎么Merge到MySQL数据库
DataWorks作为一站式的数据开发与治理平台,提供了从数据采集、清洗、开发、调度、服务化、质量监控到安全管理的全套解决方案,帮助企业构建高效、规范、安全的大数据处理体系。以下是对DataWorks产品使用合集的概述,涵盖数据处理的各个环节。
|
5月前
|
存储 SQL 关系型数据库
(二十一)MySQL之高并发大流量情况下海量数据分库分表的正确姿势
从最初开设《全解MySQL专栏》到现在,共计撰写了二十个大章节详细讲到了MySQL各方面的进阶技术点,从最初的数据库架构开始,到SQL执行流程、库表设计范式、索引机制与原理、事务与锁机制剖析、日志与内存详解、常用命令与高级特性、线上调优与故障排查.....,似乎涉及到了MySQL的方方面面。但到此为止就黔驴技穷了吗?答案并非如此,以《MySQL特性篇》为分割线,整个MySQL专栏从此会进入“高可用”阶段的分析,即从上篇之后会开启MySQL的新内容,主要讲述分布式、高可用、高性能方面的讲解。
386 1

热门文章

最新文章