您的位置：首页 > 运维架构 > Linux

Centos8.3、proxysql2.0读写分离实战记录

2021-06-22 18:05 1191 查看

接着主从复制继续往下讲，这个项目中我是使用proxysql做读写分离的中间件,之前是使用mycat.老实说mycat属于比较重量级的中间件,1.0还好到了2.0配置变得很复杂而且文档不是很齐全，我看着比较吃力.所以我就选择了proxysql作为读写分离的中间件，相比mycat 它更加轻量级、配置简单、更改配置的时候不用重启就能生效。

快捷安装命令

还是是喜欢一键脚本安装比较省力气。其他安装方法请看 https://gitee.com/mirrors/proxysql#red-hat--centos

cat <<EOF | tee /etc/yum.repos.d/proxysql.repo[proxysql_repo]name= ProxySQL YUM repositorybaseurl=https://repo.proxysql.com/ProxySQL/proxysql-2.0.x/centos/\$releasevergpgcheck=1gpgkey=https://repo.proxysql.com/ProxySQL/repo_pub_key EOF

然后执行

yum install proxysql                #安装默认
yum install proxysql-version        #安装指定版本  二选一
systemctl enable  proxysql          #添加到开机启动
systemctl start  proxysql           #启动服务

开始配置

proxysql客户端：6033端口代理mysql服务的端口也就是应用连接使用的

proxysql管理端：6032端口管理proxysql配置的端口只能本地登录

登录管理端

mysql -uadmin -padmin -h127.0.0.1 -P6032 --prompt='Admin> ' --default-auth=mysql_native_password

proxysql的管理端和mysql的客户类似可以使用 show tables;查询表如下图:

主要用到

mysql_servers 表是用来存储数据库实例信息

mysql_user 表是用来存储数据库实例账号信息

mysql_query_rules 路由规则表

添加数据库实例

insert into mysql_servers(hostgroup_id,hostname,port,weight,comment) values(1,'172.16.102.7',3306,1,'master');#添加数据库实例master

insert into mysql_servers(hostgroup_id,hostname,port,weight,comment) values(2,'172.16.102.8',3306,1,'slave1');#添加数据库实例slave1

insert into mysql_servers(hostgroup_id,hostname,port,weight,comment) values(2,'172.16.102.9',3306,1,'slave2');#添加数据库实例slave2

hostgroup_id  mysql_servers表的主键 很重要路由规则和账号表都有用到

hostname      mysql数据库实例的ip

   port       mysql数据库实例的端口

 weight       负载权重 数字越大承受的请求越多

comment       备注

查询添加结果

select * from mysql_servers; #和sql语句语法一致

如下图：

添加客户端连接账号

insert into mysql_users(username,password,default_hostgroup,transaction_persistent)values('proxysql','jishuzhai',1,1);

username  mysql        实例的账号

password  mysql        实例的密码 意味着所有mysql实例需要创建相同的账号密码。

default_hostgroup      和mysql_servers表的hostgroup_id进行关联 这里设置为1 意味着所有请求
1044
默认到hostgroup_id为1的这组实例然后在根据路由规则进行分发

transaction_persistent 开启事物支持 默认 0 关闭 这里设置为1开启。

查询添加结果

select * from mysql_users;

如下图:

添加路由规则

insert into mysql_query_rules(rule_id,active,match_digest,destination_hostgroup,apply) VALUES (1,1,'^SELECT.*FOR UPDATE$',1,1), (2,1,'^SELECT',2,1)

rule_id 路由编号

active 是否启用路由

match_digest 路由匹配规则支持正则

destination_hostgroup 路由目标也就数据库实例组

apply 1 匹配目标后直接转发

路由策略所有请求到 default_hostgroup 设置的默认数据库实例组然后根据路由规则把查询请求分发到hostgroup_id为2的数据库实例组

查询添加结果

select rule_id,active,match_digest,destination_hostgroup,log,apply  from mysql_query_rules;

如下图：

规则1:查询更新结果的语句匹配搭配到hostgrouo_id 为1的实例组也就是写的实例组

规则2: 匹配所有查询路由到hostgroup_id 为 2的实例组也就是读的实例组

注意 proxysql的匹配规则是从路由编号 1开始的所以这两条规则顺序不能颠倒否则查询更新结果的语句永远不会路由到写的实例因为查询包含查询更新结果。

添加监控账号

所谓监控账号就是用来监控数据库实例状态的账号，这里我和上面使用了同一个账号，可以分开但是要在所有实例上都要创建。

set mysql-monitor_username='proxysql';
set mysql-monitor_password='jishuzhai';

查看监控情况

SELECT * FROM monitor.mysql_server_connect_log ORDER BY time_start_us DESC LIMIT 10;

结果如下图：

如果 connect_error 不为null 说明配置监控账号失败请检查监控账号是否正确

设置数据库版本和语法兼容

set mysql-server_version='8.0.21';        #设置数据库版本 如果不设置使用druid连接的时候会出现问题
set mysql-set_query_lock_on_hostgroup=0;  # 设置语法兼容 如果不配置使用数据库连接工具比如说navicat 连接执行一些特殊查询比如说select @@version 就会提示语法不兼容

加载到配置到内存

load mysql users to runtime;
load mysql servers to runtime;
load mysql query rules to runtime;
load mysql variables to runtime;
load admin variables to runtime;

写入配置到硬盘

save mysql users to disk;
save mysql servers to disk;
save mysql query rules to disk;
save mysql variables to disk;
save admin variables to disk;

建议每次修改完配置都执行一遍

接下来关闭从数据库的数据复制在所有从数据库执行

stop slave  # 接着上篇 关闭主从复制

登录到proxysql 客户端可以使用数据库连接工具登录也可以使用mysql客户端登录

mysql -uproxysql -pjishuzhai -h127.0.0.1 -P6033 --default-auth=mysql_native_password

show databaases; #登录后执行 显示所有数据

出现如下图:

出现这个结果说明配置成功了。

测试读写分离路由规则

1.添加一条数据然后查询看结果

INSERT INTO `test` VALUES (4, 'master4');

如下图：

我添加了一条数据成功了但是查询看不到结果然后我们单独登录master数据也就是hostgroup_id 为 1的数据实例查看结果如下图：

结果有五条数据说明读写分离是配置成功了

现在我们在做一个实验更换主数据库把从数据库 slave1 设置为主数据库

登录proxysql 管理端

mysql -uadmin -padmin -h127.0.0.1 -P6032 --prompt='Admin> ' --default-auth=mysql_native_password

1.更新mysql_servers 表将master 的 hostgroup_id 更新为 2, 将slave1 的hostgroup_id 更新为3

2.更新mysql_users 表将 default_hostgroup 更新为3

3.更新mysql_query_rules 表将 destination_hostgroup 更新为 3

4.然后加载到内存中

update mysql_servers set  hostgroup_id = 2 where comment = 'master';

update mysql_servers set  hostgroup_id = 3  where comment = 'slave1';

update mysql_users set default_hostgroup = 3;

update mysql_query_rules set destination_hostgroup = 3 where rule_id =1;

load mysql users to runtime;
load mysql servers to runtime;
load mysql query rules to runtime;
save mysql users to disk;
save mysql servers to disk;
save mysql query rules to disk;

登录客户端测试结果如下图：