构建读写分离的数据库集群

Posted 2020-11-27 tui463

4.1实战案例——构建读写分离的数据库集群

使用Mycat作为数据库中间件服务构建读写分离的数据库集群

使用一台虚拟机部署Mycat数据库中间件服务，将用户提交的读写操作识别分发给相应的数据库

节点。这样将用户的访问操作、数据库的读与写操作分给3台主机，只有数据库集群的主节点接

收增、删、改SQL语句，从节点接收查询语句，分担了主节点的查询压力

基础准备

使用CentOS 7.2系统，创建3台虚拟机进行实验。

其中2台虚拟机db1和db2部署MariaDB数据库服务，搭建主从数据库集群；一台作为主节点，负

责写入数据库信息；另一台作为从节点，负责读取数据库信息。

基础环境配置

修改主机名

# hostnamectl set-hostname mycat

# hostnamectl set-hostname db1

# hostnamectl set-hostname db2

修改完之后使命令生效

# bash

编辑hosts文件（mycat，db1，db2）

# vi /etc/hosts

 

安装JDK环境（mycat）

安装java环境

# yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel

查看java版本

# java -version

 

部署MariaDB主从数据库集群服务

安装MariaDB服务（db1和db2）

# yum install -y mariadb mariadb-server

启动服务并设置开机自启

# systemctl start mariadb

# systemctl enable mariadb

初始化MariaDB数据库（db1和db2）

初始化MariaDB数据库，并设置MariaDB数据库root访问用户的密码为123456

# mysql_secure_installation

还没有设置根密码，直接回车

设置根密码，yes

删除匿名用户，yes

不允许远程登陆，no

删除测试数据库并访问它，yes

现在重新加载特权表，yes

 

配置数据库集群主节点（db1）

编辑配置文件

# vi /etc/my.cnf

 

 log_bin = mysql-bin   记录操作日志

 binlog_ignore_db = mysql    不同步MySQL系统数据库

 server_id = 12    数据库集群中的每个节点ip都要不同，一般使用ip最后段的数字

编辑完成后重启服务

# systemctl restart mariadb

关闭防火墙

# systemctl stop firewalld

开放数据库权限（db1）

登录数据库

# mysql -uroot -p123456

授权在任何客户端机器上可以以root用户登录到数据库

> grant all privileges  on  *.*  to root@‘%‘ identified by "123456";

创建一个用户，并赋予从节点同步主节点数据库的权限

> grant replication slave on  *.*  to ‘user‘@‘db2‘ identified by ‘123456‘;

配置同步（db2）

登录数据库

# mysql -uroot -p123456

配置连接信息

>  change master to master_host=‘db1‘,master_user=‘user‘,master_password=‘123456‘;

开启从服务

> start slave;

查看从服务状态

> show slave statusG;

验证主从数据库的同步功能

创建库表数据（db1）

创建库test

> create database test;

在库test中创建表company

> use test

> create table company(id int not null primary key,name varchar(50),addr varchar(255));

插入表数据

> insert into company values(1,"facebook","usa");

查看表数据

> select * from company;

查询是否同步（db2）

查询数据库

> show databases;

查询表company

> select * from test.company;

部署mycat读写分离中间件服务

安装mycat服务（mycat）

将软件包上传到mycat的/root目录下，将软件包解压

# tar -zxvf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz -C /usr/local/

赋予权限

# chown -R 777 /usr/local/mycat/

添加系统变量，并生效变量

# echo export MYCAT_HOME=/usr/local/mycat/ >> /etc/profile

# source /etc/profile

编辑逻辑库配置文件（mycat）

在文件中定义一个逻辑库

# vi /usr/local/mycat/conf/schema.xml

<?xml version="1.0"?>

<!DOCTYPE mycat:schema SYSTEM "schema.dtd">

<mycat:schema xmlns:mycat="http://io.mycat/">

<schema name="USERDB" checkSQLschema="true" sqlMaxLimit="100" dataNode="dn1"></schema>

<dataNode name="dn1" dataHost="localhost1" database="test" /> 

<dataHost name="localhost1" maxCon="1000" minCon="10" balance="3" dbType="mysql" dbDriver="native" writeType="0" switchType="1"  slaveThreshold="100"> 

    <heartbeat>select user()</heartbeat>

    <writeHost host="hostM1" url="172.16.51.18:3306" user="root" password="123456">

        <readHost host="hostS1" url="172.16.51.30:3306" user="root" password="123456" />

    </writeHost>

</dataHost>

</mycat:schema>

保存并退出

注释：

sqlMaxLimit    配置默认查询数量

database    为真实数据库名

balance="0"    不开启读写分离机制，所有读操作都发送到当前可用的writeHost上

balance="1"    全部的readHost与stand by writeHost参与select语句的负载均衡，简单来说，当双主双从模式（M1->S1，M2->S2，并且M1与M2互为主备），正常情况下，M2、S1、S2都参与select语句的负载均衡

balance="2"    所有读操作都随机的在writeHost、readhost上分发

balance="3"    所有读请求随机地分发到wiriterHost对应的readhost执行，writerHost不负担读压力，注意balance=3只在1.4及其以后版本有，1.3版本没有

writeType="0"    所有写操作发送到配置的第一个writeHost，第一个挂了需要切换到还生存的第二个writeHost，重新启动后已切换后的为准，切换记录在配置文件dnindex.properties中

writeType="1"    所有写操作都随机的发送到配置的writeHost

修改配置文件权限（mycat）

修改schema.xml的用户权限

# chown root:root /usr/local/mycat/conf/schema.xml

编辑访问用户（mycat）

修改root用户的访问密码与数据库

# vi /usr/local/mycat/conf/server.xml

修改内容

删除内容

<user name="user">

              <property name="password">user</property>

              <property name="schemas">TESTDB</property>

              <property name="readOnly">true</property>

</user>

保存并退出

启动服务（mycat）

启动数据库中间件服务

# /bin/bash /usr/local/mycat/bin/mycat start

查看虚拟机端口开放情况（8066和9066）

# netstat -ntpl

验证数据库集群服务读写分离功能

查询数据库信息（mycat）

安装服务

# yum install -y mariadb mariadb-client

登录数据库

# mysql -h127.0.0.1 -P8066 -uroot -p123456

查看逻辑库

> show databases;

> use USERDB

> show tables;

查看表company

> select * from company;

添加表数据（mycat）

在表中添加一条数据

> insert into company values(2,"bastetball","usa");

查看表信息

> select * from company;

验证读写操作分离（mycat）

查询对数据库读写操作的分离信息

# mysql -h127.0.0.1 -P9066 -uroot -p123456 -e ‘show  @@datasource;‘