欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

mysql主从复制读写分离的配置方法详解

程序员文章站 2023-12-05 11:39:10
一、说明 前面我们说了mysql的安装配置,mysql语句使用以及备份恢复mysql数据;本次要介绍的是mysql的主从复制,读写分离;及高可用mha; 环境如下:...

一、说明

前面我们说了mysql的安装配置,mysql语句使用以及备份恢复mysql数据;本次要介绍的是mysql的主从复制,读写分离;及高可用mha;

环境如下:

master:centos7_x64 mysql5.721 172.16.3.175 db1
slave1:centos7_x64 mysql5.7.21 172.16.3.235 db2
slave2:centos7_x64 mysql5.7.21 172.16.3.235 db3
proxysql/mha:centos7_x64 mysql5.7.21 172.16.3.235 proxysql

架构图:

mysql主从复制读写分离的配置方法详解

说明:

配置测试时为了方便关闭了防火墙头,selinux安全策略;
现实中请开放防火墙策略;myslqdb的安装已经有脚本一键安装并配置好;这里就不在重复配置;只对对应的角色贴出对应的配置或安装与之相关的软件;

二、主从复制配置

一台主数据库,n从节点;从节点开启两个线程,通过slave_io_running线程和主节点上有权限的账号从 主数据库节点复制binlog日志到本地,能过slave_sql_running线程在本地执行binlog日志,达到主从节点内容同步;

master配置:

egrep -v '(^$|^#)' /usr/local/mysql/etc/my.cnf

[mysqld]
datadir=/data1/mysqldb
socket=/tmp/mysql.sock
key_buffer_size   = 16m
max_allowed_packet  = 16m
thread_stack   = 192k
thread_cache_size  = 8
query_cache_limit  = 1m
query_cache_size  = 64m
query_cache_type  = 1
symbolic-links=0
innodb_file_per_table=on
skip_name_resolve=on

server-id  = 1
log_bin   = /data1/mysqldb/mysql-bin.log
[mysqld_safe]
log-error=/usr/local/mysql/logs/error.log
pid-file=/data1/mysqldb/mysql.pid
!includedir /usr/local/mysql/etc/my.cnf.d

创建从节点同步账号:

mysql > grant replication client,replication slave on *.* to 'repluser'@'172.16.3.%' identified by 'replpass';
mysql > flush privileges;
mysql >show master logs;
+------------------+-----------+
| log_name   | file_size |
+------------------+-----------+
| mysql-bin.000001 |  622 |

主节点上的binlog日志文件及位置;请记下;从节点第一次同步时需要用;

slave节点:

 

egrep -v '(^$|^#)' /usr/local/mysql/etc/my.cnf

[mysqld]
datadir=/data1/mysqldb
socket=/data1/mysqldb/mysql.sock
key_buffer_size   = 16m
max_allowed_packet  = 16m
thread_stack   = 192k
thread_cache_size  = 8
query_cache_limit  = 1m
query_cache_size  = 64m
query_cache_type  = 1
symbolic-links=0

innodb_file_per_table=on
skip_name_resolve=on

server-id    = 11   #从节点标识id 各从节点均不一样 
relay_log = relay-log
read_only=on

[mysqld_safe]
log-error=/usr/local/mysql/log/error.log
pid-file=/var/run/mysql/mysql.pid
!includedir /usr/local/mysql/etc/my.cnf.d

启动mysq数据库

注意:两台从节点的server-id 值不一样;其他的都一样;因此从节点只展示一个配置文件;
登录数据库并同步数据启动slave

两台slave均要同步并启动

mysql > change master to master_host="172.16.3.175",master_user="repluser",master_password="replpass",master_port=3306,master_log_file="mysql-bin.000001",master_log_pos=622;
mysql > start slave;  #启动从节点()

#查看从节点状态
mysql > show slave status;
*************************** 1. row ***************************
    slave_io_state: waiting for master to send event
     master_host: 172.16.3.175     #主节点
     master_user: repluser       #同步账号
     master_port: 3306
    connect_retry: 60
    master_log_file: mysql-bin.000001
   read_master_log_pos: 622
    relay_log_file: relay-log.000001
    relay_log_pos: 582
  relay_master_log_file: mysql-bin.000001
    slave_io_running: yes      #同步线程正常
   slave_sql_running: yes     #本地写线程正常
    replicate_do_db:        #同步过滤为空(可以只同步某个或某些库)
   replicate_ignore_db:        #不同步的库
   replicate_do_table:      
  replicate_ignore_table: 
  replicate_wild_do_table: 
 replicate_wild_ignore_table: 
     last_errno: 0    #最后同步的错误 0表示正常同步
     last_error: 
     skip_counter: 0
   exec_master_log_pos: 622
    relay_log_space: 615
    until_condition: none
    until_log_file: 
    until_log_pos: 0
   master_ssl_allowed: no
   master_ssl_ca_file: 
   master_ssl_ca_path: 
    master_ssl_cert: 
   master_ssl_cipher: 
    master_ssl_key: 
  seconds_behind_master: 0
master_ssl_verify_server_cert: no
    last_io_errno: 0
    last_io_error: 
    last_sql_errno: 0
    last_sql_error: 
 replicate_ignore_server_ids: 
    master_server_id: 1
     master_uuid: 57017c43-36e3-11e8-ac76-080027393fc7
    master_info_file: /data1/mysqldb/master.info
     sql_delay: 0
   sql_remaining_delay: null
  slave_sql_running_state: slave has read all relay log; waiting for more updates
   master_retry_count: 86400
     master_bind: 
  last_io_error_timestamp: 
  last_sql_error_timestamp: 
    master_ssl_crl: 
   master_ssl_crlpath: 
   retrieved_gtid_set: 
   executed_gtid_set: 
    auto_position: 0
   replicate_rewrite_db: 
     channel_name: 
   master_tls_version: 
1 row in set (0.00 sec)
error: 
no query specified

测试主从同步

在master导入测试数据;修改数据并查看slave 中的数据是否一致;

[root@db1 ~]# mysql < testdb.sql
登录数据库
[root@db1 ~]# mysql -uroot -p
mysql> show databases;
+--------------------+
| database   |
+--------------------+
 study    |
+--------------------+
5 rows in set (0.00 sec)
###study测试数据库导入成功
mysql> use study;
database changed
mysql> show tables;
+-----------------+
| tables_in_study |
+-----------------+
| class   |
| course   |
| part   |
| score   |
| student   |
| tb31   |
| tb32   |
| teacher   |
| test1   |
| test2   |
| user_info  |
+-----------------+
11 rows in set (0.00 sec)
#删除test1 test2表

slave从节点上查看

mysql> show tables;
+-----------------+
| tables_in_study |
+-----------------+
| class   |
| course   |
| part   |
| score   |
| student   |
| tb31   |
| tb32   |
| teacher   |
| user_info  |
+-----------------+
9 rows in set (0.00 sec)

数据已经可以正常同步;注意主从同步只需要第一次手动启动;之后都随mysql服务自动启动;主从同步架构只方便了数据的同步,此时如果没有 第三方工具介入想做到读写分离就需要在程序中去做,难免出错;而出错了,就需要手动同步数据;这里通过proxysql来做读写分离;

三、proxysql之读写分离

以上已经完成了主从复制配置;然而这只是一个基本配置,加上一个proxysql实现mysql读写分离,proxysql类似haproxy七层代理路由功能且支持mysql 协议的的数据库代理;是dba开发给dba使用的;用户请求发向proxysql,如果是写请求发往主节点;读请求发下从节点组中;以此实现读写分离;一定程序上减轻了主数据库的io压力;
下载安装proxysql
目前最新版本是1.4.7-1(由于最新版本有问题)
我们这里下载使用1.3.6-1的基于centos7的rpm包;下载到本地并yum安装

[root@proxysql ~]# yum install proxysql-1.3.6-1-centos7.x86_64.rpm -y
[root@proxysql ~]# rpm -ql proxysql
/etc/init.d/proxysql
/etc/proxysql.cnf  #主配置文件
/usr/bin/proxysql
/usr/share/proxysql/tools/proxysql_galera_checker.sh
/usr/share/proxysql/tools/proxysql_galera_writer.pl

配置如下:

在配置proxysql之前需要在主节点配置授权账号以作proxysql对主从节点操作;另外proxysql上的mysql客户端工具需要和主从节点上的保持一致;
在主节点master上授权登录账号:

mysql > grant all on *.* to 'myadmin'@'172.16.3.%' identified by 'mypass';

proxysql.cnf配置

[root@proxysql ~]# egrep -v '(^$|^#)' /etc/proxysql.cnf

datadir="/var/lib/proxysql"
admin_variables=
{ 
 admin_credentials="admin:admin"    #proxysql自己的管理用户名密码
 mysql_ifaces="127.0.0.1:6032;/tmp/proxysql_admin.sock"
}
mysql_variables=
{
 threads=4       #线程数,建议和cpu核心数一致
 max_connections=2048  #最大连接
 default_query_delay=0
 default_query_timeout=36000000
 have_compress=true
 poll_timeout=2000
 interfaces="0.0.0.0:3306;/tmp/proxysql.sock"    #对外接口
 default_schema="information_schema"
 stacksize=1048576
 server_version="5.5.30"
 connect_timeout_server=3000
 monitor_username="monitor"
 monitor_password="monitor"
 monitor_history=600000
 monitor_connect_interval=60000
 monitor_ping_interval=10000
 monitor_read_only_interval=1500
 monitor_read_only_timeout=500
 ping_interval_server_msec=120000
 ping_timeout_server=500
 commands_stats=true
 sessions_sort=true
 connect_retries_on_failure=10
}

#####主从节点的配置
mysql_servers =      
(
 {
  address = "172.16.3.175" # no default, required . if port is 0 , address is interpred as a unix socket domain
  port = 3306   # no default, required . if port is 0 , address is interpred as a unix socket domain
  hostgroup = 1   # 设置组号
  status = "online"  # default: online
  weight = 1   # default: 1
  compression = 0  # default: 0
  max_connections = 200   ###定义最大的连接
 },
 {
  address = "172.16.3.235" # no default, required . if port is 0 , address is interpred as a unix socket domain
  port = 3306   # no default, required . if port is 0 , address is interpred as a unix socket domain
  hostgroup = 2   # no default, required
  status = "online"  # default: online
  weight = 1   # default: 1
  compression = 0  # default: 0
  max_connections=1000
 },
 {
  address = "172.16.3.241" # no default, required . if port is 0 , address is interpred as a unix socket domain
  port = 3306   # no default, required . if port is 0 , address is interpred as a unix socket domain
  hostgroup = 2   # no default, required
  status = "online"  # default: online
  weight = 1   # default: 1
  compression = 0  # default: 0
  max_connections=1000
 }
)
mysql_users:
(
 {
  username = "myadmin" # no default , required
  password = "mypass" # default: ''
  default_hostgroup = 1 # default: 0
  max_connections=1000
  default_schema="test"
  active = 1   #是否激活
 }
)
mysql_query_rules:
(
)
scheduler=
(
)
mysql_replication_hostgroups=
(
  {
    writer_hostgroup=1   #定义写组号1
    reader_hostgroup=2  #定义读组号2
    comment="test repl 1" #注释内容
  }
)

启动proxysql服务


[root@proxysql ~]# service proxysql start

测试proxysql

模拟通过proxysql使用数据库
[root@proxysql ]# mysql -h172.16.3.175 -umyadmin -pmypass
mysql: [warning] using a password on the command line interface can be insecure.
welcome to the mysql monitor. commands end with ; or \g.
your mysql connection id is 17406
server version: 5.7.21-log mysql community server (gpl)
copyright (c) 2000, 2018, oracle and/or its affiliates. all rights reserved.
oracle is a registered trademark of oracle corporation and/or its
affiliates. other names may be trademarks of their respective
owners.
type 'help;' or '\h' for help. type '\c' to clear the current input statement.
mysql> 

mysql > show databases;
mysql> show databases;
+--------------------+
| database   |
+--------------------+
| information_schema |
| mysql    |
| performance_schema |
| study    |
| sys    |
+--------------------+
5 rows in set (0.00 sec)
###删除study数据库user_info中6 -12之间的数据
删除之前:
mysql> select * from user_info;
+-----+-------+------+--------+----------+
| nid | name | age | gender | part_nid |
+-----+-------+------+--------+----------+
| 1 | san | 20 | 男  |  1 |
| 2 | dong | 29 | 男  |  2 |
| 4 | ling | 28 | 男  |  4 |
| 5 | ling | 28 | 男  |  3 |
| 6 | dong | 30 | 男  |  1 |
| 7 | b  | 11 | 女  |  1 |
| 8 | c  | 12 | 女  |  1 |
| 9 | d  | 18 | 女  |  4 |
| 10 | e  | 22 | 男  |  3 |
| 11 | f  | 23 | 男  |  2 |
| 12 | dongy | 22 | 男  |  1 |
+-----+-------+------+--------+----------+
11 rows in set (0.00 sec)
删除之后:
mysql> delete from user_info where nid >6 and nid <12;
query ok, 5 rows affected (0.03 sec)

mysql> select * from user_info;
+-----+-------+------+--------+----------+
| nid | name | age | gender | part_nid |
+-----+-------+------+--------+----------+
| 1 | san | 20 | 男  |  1 |
| 2 | dong | 29 | 男  |  2 |
| 4 | ling | 28 | 男  |  4 |
| 5 | ling | 28 | 男  |  3 |
| 6 | dong | 30 | 男  |  1 |
| 12 | dongy | 22 | 男  |  1 |
+-----+-------+------+--------+----------+
6 rows in set (0.00 sec)

到主从节点上查看,会发现以上的查和修改数据都被proxysql正确的代理到后端处理了;
以上看了并不直观;为了查看proxysql与各主从节点通讯我们在主从节点上安装tcpdump并过滤包

主节点:
类似如下:
[root@db1 ~]# tcpdump -i enp0s3 -nn tcp port 3306
tcpdump: verbose output suppressed, use -v or -vv for full protocol decode
listening on enp0s3, link-type en10mb (ethernet), capture size 262144 bytes
18:04:34.678861 ip 172.16.3.254.42191 > 172.16.3.175.3306: flags [s], seq 3385407732, win 29200, options [mss 1460,sackok,ts val 17576713 ecr 0,nop,wscale 7], length 0
18:04:34.678908 ip 172.16.3.175.3306 > 172.16.3.254.42191: flags [s.], seq 1579426335, ack 3385407733, win 28960, options [mss 1460,sackok,ts val 29413673 ecr 17576713,nop,wscale 7], length 0
18:04:34.680902 ip 172.16.3.254.42191 > 172.16.3.175.3306: flags [.], ack 1, win 229, options [nop,nop,ts val 17576715 ecr 29413673], length 0
18:04:34.681264 ip 172.16.3.175.3306 > 172.16.3.254.42191: flags [p.], seq 1:83, ack 1, win 227, options [nop,nop,ts val 29413675 ecr 17576715], length 82
....
从节点:
类似如下:
[root@db2 data1]# tcpdump -i enp0s3 -nn tcp port 3306
tcpdump: verbose output suppressed, use -v or -vv for full protocol decode
listening on enp0s3, link-type en10mb (ethernet), capture size 262144 bytes
18:02:57.932043 ip 172.16.3.254.42733 > 172.16.3.235.3306: flags [s], seq 76520456, win 29200, options [mss 1460,sackok,ts val 17479189 ecr 0,nop,wscale 7], length 0
...........

proxysql命令行管理接口:支持运行时修改

 [root@proxysql]# mysql -u admin -padmin -h 127.0.0.1 -p6032 --prompt='admin> '
admin> show databases;
+-----+---------+-------------------------------+
| seq | name | file       |
+-----+---------+-------------------------------+
| 0 | main |        |
| 2 | disk | /var/lib/proxysql/proxysql.db |
| 3 | stats |        |
| 4 | monitor |        |
+-----+---------+-------------------------------+
4 rows in set (0.00 sec)

以上stats,monitor,main都从配置文件中获取的数据库;可以通过类似mysql运行时修改;而不需要重启;

至此我们基于proxysql主从复制读写分离架构已经完成;
双主或多主模型是无须实现读写分离,仅需要负载均衡:haproxy, nginx, lvs等;
proxysql并没有解决,当主数据岩机时的问题;此时就需要量mha来解决 ;后续再介绍;