百度360必应搜狗淘宝本站头条
当前位置:网站首页 > IT技术 > 正文

基于Maxscale中间件实现Mysql读写分离实战

wptr33 2024-11-24 22:27 15 浏览


环境介绍:

?CentOS 7.5

?Mysql 5.7.29

?Mysql主服务器:192.168.2.128

?Mysql从服务器:192.168.2.129

?Mysql代理服务器:192.168.2.130

?客户端服务器:192.168.2.132

读写分离概述:




1、什么是读写分离?

?读写分离的基本原理是让主数据库处理事务性增、改、删操作(INSERT、UPDATE、DELETE),而从数据库处理SELECT查询操作。数据库复制被用来把事务性操作导致的变更同步到集群中的从数据库。一般来说都是通过 主从复制(Master-Slave)的方式来同步数据,再通过读写分离(MySQL-Proxy)来提升数据库的并发负载能力这样的方案来进行部署与实施的。

2、为什么要读写分离?

?因为数据库的“写”操作是比较耗时的,但是数据库的“读”操作耗时非常短,所以读写分离,解决的是数据库的写入影响了查询的效率(即读操作比写操作多的场景)。

3、什么时候读写分离?

?数据库不一定要读写分离,如果程序使用数据库较多时,而更新少,查询多的情况下会考虑使用,利用数据库主从同步,可以减少数据库压力,提高性能。

4、主从复制与读写分离:

?在实际的生产环境中,对数据库的读和写都在同一个数据库服务器中,是不能满足实际需求的。无论是在安全性、高可用性还是高并发等各个方面都是完全不能满足实际需求的。因此,通过主从复制的方式来同步数据,再通过读写分离来提升数据库的并发负载能力。

5.读写分离的好处:

?1)分摊服务器压力, 减轻主服务器的工作压力,提高机器的系统处理效率。
?2)增加冗余,提高服务可用性,当一台数据库服务器宕机后可以调整另外一台从库以最快速度恢复服务。

?读写分离适用于读远比写多的场景,如果有一台服务器,当select很多时,update和delete会被这些select访问中的数据堵塞,等待select结束,并发性能并不高,而主从只负责各自的写和读,极大程度的缓解X锁和S锁争用。

共享锁[S锁]   -->读锁
排他锁[X锁]   -->写锁
读锁是共享的,或者说是相互不阻塞的。
写锁是排他的,一个写锁会阻塞其他的写锁和读锁。

6.实现Mysql读写分离常见的2种方式:

1)基于程序代码内部实现

?在代码中根据select 、insert进行路由分类,这类方法也是目前生产环境下应用最广泛的。优点是性能较好,因为程序在代码中实现,不需要增加额外的硬件开支,缺点是需要开发人员来实现,运维人员无从下手。

2) 基于中间件(代理层)实现

?代理一般介于应用服务器和数据库服务器之间,代理数据库服务器接收到应用服务器的请求后根据判断后转发到后端数据库。如:Mycat、Mysql-proxy、Maxscale...

构建思路:

?1.配置Mysql主从同步

?这里就不讲述Mysql主从同步的配置了,上面一篇文章里面讲得很详细,大家可以去看一下。

?2.部署Maxscale服务

?Maxscale下载:https://downloads.mariadb.com/MaxScale/

1.下载并安装Maxscale服务

[root@test3 ~]# wget https://downloads.mariadb.com/MaxScale/2.1.2/rhel/7/x86_64/maxscale-2.1.2-1.rhel.7.x86_64.rpm

[root@test3 ~]# ll maxscale-2.1.2-1.rhel.7.x86_64.rpm
-rw-r--r-- 1 root root 17333732 3月  31 2017 maxscale-2.1.2-1.rhel.7.x86_64.rpm

[root@test3 ~]# yum -y install maxscale-2.1.2-1.rhel.7.x86_64.rpm
...
已安装:
  maxscale.x86_64 0:2.1.2-1

作为依赖被安装:
  gnutls.x86_64 0:3.3.29-9.el7_6             nettle.x86_64 0:2.7.1-8.el7             trousers.x86_64 0:0.3.14-2.el7

完毕!

[root@test3 ~]# max (连续按Tab两次)    //maxscale服务的管理命令
maxadmin        maxavrocheck    maxbinlogcheck  maxkeys         maxpasswd

[root@test3 ~]# ll /etc/maxscale.cnf      //配置文件
-rw-r--r-- 1 root root 1560 6月   9 16:40 /etc/maxscale.cnf

-----下面是备份maxscale服务的配置文件-----
[root@test3 ~]# mkdir maxscale

[root@test3 ~]# cp /etc/maxscale.cnf /root/maxscale/

[root@test3 ~]# ll /root/maxscale/
总用量 4
-rw-r--r-- 1 root root 1560 6月   9 16:44 maxscale.cnf

2.修改Maxscale配置文件

[root@test3 ~]# vim /etc/maxscale.cnf
[maxscale]
threads=auto     //线程数,auto表示自动根据cpu的性能创建多少个线程
...
[server1]       //定义数据库服务器的主机名
type=server
address=192.168.2.128     //master(主库)主机的ip地址
port=3306
protocol=MySQLBackend
...
[server2]      //定义数据库服务器的主机名
type=server
address=192.168.2.129     //slave(从库)主机ip地址
port=3306
protocol=MySQLBackend
...
[MySQL Monitor]        //定义要监视的服务器及监控的用户
type=monitor
module=mysqlmon
servers=server1,server2     /主、从数据库的主机名
user=maxscalemon       //监控用户名
password=123qqq...A     //监控用户密码
monitor_interval=10000     //监控的时间间隔,单位为毫秒
...
#[Read-Only-Service]   //读负载均衡模块,由于读写分离模块也能实现读负载均衡,因此注释掉该模块
#type=service
#router=readconnroute
#servers=server1
#user=myuser
#password=mypwd
#router_options=slave
...
[Read-Write-Service]     //定义读写分离服务及路由用户
type=service  
router=readwritesplit
servers=server1,server2     //主、从数据库的主机名
user=maxscalerouter       //路由用户名
password=123qqq...A       //路由用户密码
max_slave_connections=100%     //多少比例的从服务器被使用,默认就是所有从服务器都提供读服务
...
[MaxAdmin Service]      //定义管理服务
type=service
router=cli

#[Read-Only-Listener]      //注释该模块
#type=listener
#service=Read-Only-Service
#protocol=MariaDBClient
#port=4008

[Read-Write-Listener]        //定义读写分离服务的端口号
type=listener
service=Read-Write-Service
protocol=MySQLClient
port=4006

[MaxAdmin Listener]        //定义管理服务的端口号
type=listener
service=MaxAdmin Service
protocol=maxscaled
socket=default
port=4016

3.在主数据库上创建授权用户

[root@localhost ~]# mysql -uroot -p123qqq...A
...
mysql> grant replication slave,replication client on *.* to maxscalemon@"%" identified by "123qqq...A";
    //创建监控用户授权

mysql> grant select on mysql.* to maxscalerouter@"%" identified by "123qqq...A";
    //创建路由用户授权

mysql> select user,host from mysql.user where user like "maxscale%";
+----------------+------+
| user           | host |
+----------------+------+
| maxscalemon    | %    |
| maxscalerouter | %    |
+----------------+------+

4.在从数据库上查看主库上授权的用户是否同步

[root@test2 ~]# mysql -uroot -p123qqq...A
...
mysql> select user,host from mysql.user where user like "maxscale%";
+----------------+------+
| user           | host |
+----------------+------+
| maxscalemon    | %    |
| maxscalerouter | %    |
+----------------+------+

5.在代理服务器上启动Maxscale服务

[root@test3 ~]# maxscale -f /etc/maxscale.cnf     //启动maxscale服务

[root@test3 ~]# ss -antulp | grep maxscale
tcp    LISTEN     0      128      :::4006                 :::*                   users:(("maxscale",pid=2732,fd=11))
        //查询读写分离端口号4006是否启用

tcp    LISTEN     0      128      :::4016                 :::*                   users:(("maxscale",pid=2732,fd=12))
        //查询管理服务端口号4016是否启用

测试配置:

1.在代理服务器本机访问Maxscale管理服务

?-maxadmin -uadmin -pmariadb -P管理服务端口号

[root@test3 ~]# maxadmin -uadmin -pmariadb -P4016
MaxScale> list servers      //显示监控信息(集群状态)
Servers.
-------------------+-----------------+-------+-------------+--------------------
Server             | Address         | Port  | Connections | Status
-------------------+-----------------+-------+-------------+--------------------
server1            | 192.168.2.128   |  3306 |           0 | Master, Running
server2            | 192.168.2.129   |  3306 |           0 | Slave, Running
-------------------+-----------------+-------+-------------+--------------------
  //详细信息server1为主服务器,server2为从服务器,running为开启状态,ip以及主机端口

2.在主服务器上新增数据及授权连接用户

[root@localhost ~]# mysql -uroot -p123qqq...A
mysql> create database gamedb;     //创建gamedb库

mysql> create table gamedb.a(id int);     //在gamedb库创建名为a的表

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| db1                |
| gamedb             |
| mysql              |
| performance_schema |
| sys                |
| test               |
| zabbix             |
+--------------------+

mysql> use gamedb;

mysql> show tables;
+------------------+
| Tables_in_gamedb |
+------------------+
| a                |
+------------------+

mysql> grant select,insert on gamedb.* to tom66@"%" identified by "123qqq...A";       
    //授权连接用户tom66,权限为select、insert

mysql> select user,host from mysql.user where user like "tom66";
+-------+------+
| user  | host |
+-------+------+
| tom66 | %    |
+-------+------+

3.客户端132连接代理服务器130访问数据

?-mysql -h服务器地址 -P读写分离服务端口号 -u用户名 -p密码

[root@VOS3000 ~]# mysql -P4006 -h192.168.2.130 -utom66 -p123qqq...A
...
mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| gamedb             |
+--------------------+

mysql> use gamedb;

mysql> show tables;
+------------------+
| Tables_in_gamedb |
+------------------+
| a                |
+------------------+

验证代理服务器读写分离功能:

?-在从数据库服务器上添加新数据,主数据库服务器上并不会同步这些数据,客户端访问代理服务器访问数据时能看到从服务新添加的数据,说明读数据时是读取的从数据库服务器上的数据。(验证读写分离中的从“读”)

?-在代理服务器上添加新数据,到主数据库服务器上查看新数据写入情况,说明写数据时是在主服务上写。(验证读写分离中的主“写”)

1.在从数据库服务器上添加新数据

?在从服务器上新增数据,并不会同步到主数据库服务器上。

[root@test2 ~]# mysql -uroot -p123qqq...A
...
mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| db1                |
| gamedb             |
| mysql              |
| performance_schema |
| sys                |
| test               |
| zabbix             |
+--------------------+

mysql> use gamedb;

mysql> show tables;
+------------------+
| Tables_in_gamedb |
+------------------+
| a                |
+------------------+

mysql> insert into gamedb.a values(55);

mysql> select * from gamedb.a;
+------+
| id   |
+------+
|   55 |
+------+

2.在主数据库服务器上查看数据

[root@localhost ~]# mysql -uroot -p123qqq...A
...
mysql> select * from gamedb.a;
Empty set (0.00 sec)       //没有数据

?可以看到主数据库服务器上并没有新增数据。

3.客户端访问代理服务器查看数据

[root@VOS3000 ~]# mysql -P4006 -h192.168.2.130 -utom66 -p123qqq...A
...
mysql> select * from gamedb.a;
+------+
| id   |
+------+
|   55 |
+------+

?可以看到客户端通过代理服务器访问到了之前在从数据库服务器上新增的数据,所以说明代理服务器读数据是读取的从服务器上的数据。

4.客户端连接代理服务器新增数据

[root@VOS3000 ~]# mysql -P4006 -h192.168.2.130 -utom66 -p123qqq...A
...
mysql> select * from gamedb.a;     //读取到从服务器上之前新增的数据
+------+
| id   |
+------+
|   55 |
+------+

mysql> insert into gamedb.a values(88);

mysql> insert into gamedb.a values(100);

mysql> select * from gamedb.a;   //查看新增的数据
+------+
| id   |
+------+
|   55 |
|   88 |
|  100 |
+------+

5.主数据库服务器查看客户端通过代理服务新增的数据

[root@localhost ~]# mysql -uroot -p123qqq...A
...
mysql> select * from gamedb.a;
+------+
| id   |
+------+
|   88 |
|  100 |
+------+

?可以看到刚才通过客户端连接代理服务器新增的两条数据全部都写入到了主数据库服务器中并同步到从服务器上。

6.从数据库服务器上查看数据同步情况

[root@test2 ~]# mysql -uroot -p123qqq...A
...
mysql> select * from gamedb.a;
+------+
| id   |
+------+
|   55 |      
|   88 |
|  100 |
+------+

总结:

?上面的实验说明代理服务器实现了读写分离功能。

?? -写数据时,代理服务器会在主数据库服务器上写。(在主数据库服务器上写入的数据会同步到从数据库服务器上)

?? -读数据时,代理服务器会在从数据库服务器上读。

如果你觉得这篇文章还不错,就请动动你的发财手为本文点赞-评论-转发吧,因为这将是我持续输出更多优质文章的最强动力,谢谢!

相关推荐

Linux高性能服务器设计

C10K和C10M计算机领域的很多技术都是需求推动的,上世纪90年代,由于互联网的飞速发展,网络服务器无法支撑快速增长的用户规模。1999年,DanKegel提出了著名的C10问题:一台服务器上同时...

独立游戏开发者常犯的十大错误

...

学C了一头雾水该咋办?

学C了一头雾水该怎么办?最简单的方法就是你再学一遍呗。俗话说熟能生巧,铁杵也能磨成针。但是一味的为学而学,这个好像没什么卵用。为什么学了还是一头雾水,重点就在这,找出为什么会这个样子?1、概念理解不深...

C++基础语法梳理:inline 内联函数!虚函数可以是内联函数吗?

上节我们分析了C++基础语法的const,static以及this指针,那么这节内容我们来看一下inline内联函数吧!inline内联函数...

C语言实战小游戏:井字棋(三子棋)大战!文内含有源码

井字棋是黑白棋的一种。井字棋是一种民间传统游戏,又叫九宫棋、圈圈叉叉、一条龙、三子旗等。将正方形对角线连起来,相对两边依次摆上三个双方棋子,只要将自己的三个棋子走成一条线,对方就算输了。但是,有很多时...

C++语言到底是不是C语言的超集之一

C与C++两个关系亲密的编程语言,它们本质上是两中语言,只是C++语言设计时要求尽可能的兼容C语言特性,因此C语言中99%以上的功能都可以使用C++完成。本文探讨那些存在于C语言中的特性,但是在C++...

在C++中,如何避免出现Bug?

C++中的主要问题之一是存在大量行为未定义或对程序员来说意外的构造。我们在使用静态分析器检查各种项目时经常会遇到这些问题。但正如我们所知,最佳做法是在编译阶段尽早检测错误。让我们来看看现代C++中的一...

ESL-通过事件控制FreeSWITCH

通过事件提供的最底层控制机制,允许我们有效地利用工具箱,适时选择使用其中的单个工具。FreeSWITCH是一个核心交换与混合矩阵,它周围有几十个模块提供各种功能特性。我们完全控制了所有的即时信息,这些...

物理老师教你学C++语言(中篇)

一、条件语句与实验判断...

C语言入门指南

当然!以下是关于C语言入门编程的基础介绍和入门建议,希望能帮你顺利起步:C语言入门指南...

C++选择结构,让程序自动进行决策

什么是选择结构?正常的程序都是从上至下顺序执行,这就是顺序结构...

C++特性使用建议

1.引用参数使用引用替代指针且所有不变的引用参数必须加上const。在C语言中,如果函数需要修改变量的值,参数必须为指针,如...

C++程序员学习Zig指南(中篇)

1.复合数据类型结构体与方法的对比C++类:...

研一自学C++啃得动吗?

研一自学C++啃得动吗?在开始前我有一些资料,是我根据网友给的问题精心整理了一份「C++的资料从专业入门到高级教程」,点个关注在评论区回复“888”之后私信回复“888”,全部无偿共享给大家!!!个人...

C++关键字介绍

下表列出了C++中的常用关键字,这些关键字不能作为变量名或其他标识符名称。1、autoC++11的auto用于表示变量的自动类型推断。即在声明变量的时候,根据变量初始值的类型自动为此变量选择匹配的...