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

news2024/12/23 14:17:51

目录

1. 基础环境配置

（1）修改主机名

（2）编辑hosts文件

（3）配置Yum安装源

（4）安装JDK环境

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

（1）安装MariaDB服务

（2）初始化MariaDB数据库

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

（4）开放主节点的数据库权限

（5）配置从节点db2同步主节点db1

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

3. 部署Mycat读写分离中间件服务

（1）安装Mycat服务

（2）编辑Mycat的逻辑库配置文件

（3）修改配置文件权限

（4）编辑mycat的访问用户

（5）启动Mycat服务

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

（1）用Mycat服务查询数据库信息

（2）用Mycat服务添加表数据

（3）验证Mycat服务对数据库读写操作分离

1. 规划节点

用Mycat作为数据库中间件服务构建读写分离的数据库集群，节点规划见下表：

IP主机名节点
192.168.100.10mycatMycat中间服务节点
192.168.100.20 db1MariaDB数据库集群主节点
192.168.100.30db2MariaDB数据库集群从节点

2. 基础准备

使用CentOS 7.2系统，flavor使用2vCPU/4G内存/50G硬盘，创建3台虚拟机进行实验。 其中2台虚拟机db1和db2部署MariaDB数据库服务，搭建主从数据库集群；一台作为主节 点，负责写入数据库信息；另一台作为从节点，负责读取数据库信息。 使用一台虚拟机部署Mycat数据库中间件服务，将用户提交的读写操作识别分发给相应的数 据库节点。这样将用户的访问操作、数据库的读与写操作分给3台主机，只有数据库集群的主节点 接收增、删、改SQL语句，从节点接收查询语句，分担了主节点的查询压力。 Yum源使用提供的gpmall-repo文件夹作为本地源，Mycat组件使用提供的Mycat-server- 1.6-RELEASE-20161028204710-linux.tar.gz压缩包安装。

1. 基础环境配置

（1）修改主机名

使用hostnamectl命令修改3台主机的主机名：

[root@localhost ~]# hostnamectl set-hostname mycat
[root@localhost ~]# bash
[root@mycat ~]#
[root@localhost ~]# hostnamectl set-hostname db1
[root@localhost ~]# bash
[root@db1 ~]#
[root@localhost ~]# hostnamectl set-hostname db2
[root@localhost ~]# bash
[root@db2 ~]#

（2）编辑hosts文件

3台集群虚拟机的/etc/hosts文件配置部分：

# cat /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
192.168.100.10 mycat
192.168.100.20 db1
192.168.100.30 db2

（3）配置Yum安装源

数据库集群需要安装MariaDB数据库服务，需要给集群虚拟机配置Yum安装源文件，使用提 供的gpmall-repo文件上传至3个虚拟机的/opt目录下，设置本地Yum源。 首先将3个节点/etc/yum.repo.d目录下的文件移动到/media下，命令如下：

# mv /etc/yum.repos.d/* /media/

3台集群虚拟机的Yum安装源文件配置部分：

# mkdir /opt/centos
# mount /dev/sr0 /opt/centos/
mount: /dev/sr0 is write-protected, mounting read-only
# vi /etc/yum.repos.d/local.repo
# cat /etc/yum.repos.d/local.repo
[centos]
name=centos
baseurl=file:///opt/centos
gpgcheck=0
enabled=1
[mariadb]
name=mariadb
baseurl=file:///opt/gpmall-repo
gpgcheck=0
enabled=1

（4）安装JDK环境

部署Mycat中间件服务需要先部署JDK 1.7或以上版本的JDK软件环境，这里部署JDK 1.8版 本。 Mycat节点安装Java环境：

[root@mycat ~]# yum install -y java-1.8.0-openjdk java-1.8.0-openjdk-devel

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

（1）安装MariaDB服务

通过YUM命令在db1和db2虚拟机节点上安装MariaDB服务，命令如下：

# yum install -y mariadb mariadb-server

2个节点启动MariaDB服务，并设置MariaDB服务为开机自启。

# systemctl start mariadb
# systemctl enable mariadb

（2）初始化MariaDB数据库

在db1和db2虚拟机节点上初始化MariaDB数据库，并设置MariaDB数据库root访问用户的密码 为123456

# mysql_secure_installation …
Enter current password for root (enter for none): ##默认按回车
Set root password? [Y/n] y
New password: ##输入数据库root密码123456
Re-enter new password: ##重复输入密码123456
Remove anonymous users? [Y/n] y
Disallow root login remotely? [Y/n] n
Remove test database and access to it? [Y/n] y
Reload privilege tables now? [Y/n] y

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

编辑主节点db1虚拟机的数据库配置文件my.cnf，在配置文件my.cnf中增添下面的内容：

[root@db1 ~]# vi /etc/my.cnf
[root@db1 ~]# cat /etc/my.cnf
#
# This group is read both both by the client and the server
# use it for options that affect everything
#
[client-server]

#
# include all files from the config directory
#
!includedir /etc/my.cnf.d
[mysqld]
log_bin = mysql-bin
binlog_ignore_db = mysql
server_id = 20
datadir=/var/lib/mysql
socket=/var/lib/mysql/mysql.sock
symbolic-links=0
[mysqld_safe]
log-error=/var/log/mariadb/mariadb.log
pid-file=/var/run/mariadb/mariadb.pid

[root@db2 ~]# vi /etc/my.cnf
[root@db2 ~]# cat /etc/my.cnf
#
# This group is read both both by the client and the server
# use it for options that affect everything
#
[client-server]

#
# include all files from the config directory
#
!includedir /etc/my.cnf.d
[mysqld]
log_bin = mysql-bin
binlog_ignore_db = mysql
server_id = 30
datadir=/var/lib/mysql
socket=/var/lib/mysql/mysql.sock
symbolic-links=0
[mysqld_safe]
log-error=/var/log/mariadb/mariadb.log
pid-file=/var/run/mariadb/mariadb.pid

编辑完成配置文件my.cnf后，重启MariaDB服务。

[root@db1 ~]# systemctl restart mariadb
[root@db1 ~]# systemctl stop firewalld
[root@db1 ~]# setenforce 0

[root@db2 ~]# systemctl restart mariadb
[root@db2 ~]# systemctl stop firewalld
[root@db2 ~]# setenforce 0

（4）开放主节点的数据库权限

在主节点db1虚拟机上使用mysql命令登录MariaDB数据库，授权在任何客户端机器上可以以 root用户登录到数据库。

[root@db1 ~]# mysql -uroot -p123456
Welcome to the MariaDB monitor.  Commands end with ; or \g.
Your MariaDB connection id is 9
Server version: 10.3.18-MariaDB-log MariaDB Server

Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

MariaDB [(none)]> grant all privileges on *.* to root@'%' identified by "123456";
Query OK, 0 rows affected (0.002 sec)

MariaDB [(none)]> grant replication slave on *.* to 'user'@'db2' identified by '123456';
Query OK, 0 rows affected (0.001 sec)

（5）配置从节点db2同步主节点db1

在从节点db2虚拟机上使用mysql命令登录MariaDB数据库，配置从节点连接主节点的连接信息。 master_host为主节点主机名db1，master_user为在步骤（4）中创建的用户user，命令如下：

[root@db2 ~]# mysql -uroot -p123456
Welcome to the MariaDB monitor.  Commands end with ; or \g.
Your MariaDB connection id is 9
Server version: 10.3.18-MariaDB-log MariaDB Server

Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

MariaDB [(none)]> change master to master_host='db1',master_user='user',master_password='123456';
Query OK, 0 rows affected (0.040 sec)

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

先在主节点db1的数据库中 创建库test，并在库test中创建表 company，插入表数据。创建完 成后，查看表company数据，如 右所示：

[root@db1 ~]# mysql -uroot -p123456
Welcome to the MariaDB monitor.  Commands end with ; or \g.
Your MariaDB connection id is 11
Server version: 10.3.18-MariaDB-log MariaDB Server

Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

MariaDB [(none)]> create database test;
Query OK, 1 row affected (0.001 sec)

MariaDB [(none)]> use test;
Database changed
MariaDB [test]> create table company(id int not null primary key,name varchar(50),addr varchar(255));
Query OK, 0 rows affected (0.016 sec)

MariaDB [test]> insert into company values(1,"facebook","usa")
    -> ;
Query OK, 1 row affected (0.005 sec)

MariaDB [test]> select * from company;
+----+----------+------+
| id | name     | addr |
+----+----------+------+
|  1 | facebook | usa  |
+----+----------+------+
1 row in set (0.001 sec)

 这时从节点db2的数据库就会同步主节点数据库创 建的test库，可以在从节点查询test数据库与表company， 如果可以查询到信息，就能验证主从数据库集群功能在正 常运行。 查询结果如下图所示：

[root@db2 ~]# mysql -uroot -p123456
Welcome to the MariaDB monitor.  Commands end with ; or \g.
Your MariaDB connection id is 14
Server version: 10.3.18-MariaDB-log MariaDB Server

Copyright (c) 2000, 2018, Oracle, MariaDB Corporation Ab and others.

Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.

MariaDB [(none)]> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| test               |
+--------------------+
4 rows in set (0.001 sec)

3. 部署Mycat读写分离中间件服务

（1）安装Mycat服务


将Mycat服务的二进制软件包Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz上传 到Mycat虚拟机的/root目录下，并将软件包解压到/use/local目录中。赋予解压后的Mycat目录权限。

[root@mycat ~]# systemctl stop firewalld
[root@mycat ~]# setenforce 0
[root@mycat ~]# tar -zxvf Mycat-server-1.6-RELEASE-20161028204710-linux.tar.gz -C /usr/local/
[root@mycat ~]# chown -R 777 /usr/local/mycat/

在/etc/profile系统变量文件中添加Mycat服务的系统变量，并生效变量。

[root@mycat ~]# echo export MYCAT_HOME=/usr/local/mycat/ >> /etc/profile
[root@mycat ~]# source /etc/profile

（2）编辑Mycat的逻辑库配置文件

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
    <!-- 数据库配置 与server.xml 中的数据库对应 -->
 <schema name="db_test" checkSQLschema="false" dataNode="db_node" sqlMaxLimit="100" 
 </schema>
 
    <!-- 分片配置 -->
 <dataNode name="db_node" dataHost="db_host" database="db_test" />
 
    <!-- 物理数据库配置 -->
 <dataHost name="db_host" maxCon="1000"  minCon="10" balance="0"
  writeType="0" dbType="mysql"  dbDriver="native" switchType="1"  slaveThreshold="100">
   <heartbeat>select user()</heartbeat>
   <writeHost host="hostM1"  url="192.168.66.101:3339" user="root"  password="123456">
   <readHost host="hostS2" url="192.168.66.101:3340" user="root" password="123456" />
   </writeHost>
 </dataHost>
 
</mycat:schema>

（3）修改配置文件权限

修改schema.xml的用户权限，命令如下：

[root@mycat ~]# chown root:root /usr/local/mycat/conf/schema.xml

（4）编辑mycat的访问用户

修改/usr/local/mycat/conf/目录下的server.xml文件，修改root用户的访问密码与数据库，密码 设置为123456，访问Mycat的逻辑库为USERDB，命令如下：

[root@mycat ~]# cat /usr/local/mycat/conf/server.xml 
<user name="root">
<property name="password">123456</property>
<property name="schemas">USERDB</property>
</user>

保存并退出server.xml配置文件。

（5）启动Mycat服务

通过命令启动Mycat数据库中间件服务，启动后使用netstat -ntpl命令查看虚拟机端口开放情 况，如果有开放8066和9066端口，则表示Mycat服务开启成功。

[root@mycat ~]# /bin/bash /usr/local/mycat/bin/mycat start

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

（1）用Mycat服务查询数据库信息

先在Mycat虚拟机上使用Yum安装mariadb-client服务。

[root@mycat ~]# yum install -y MariaDB-client

在Mycat虚拟机上使用mysql命令查看Mycat服务的逻辑库 USERDB，因为Mycat的逻辑库USERDB对应数据库test， 所以可以查看库中已经创建的表company。命令如下

mysql -h127.0.0.1 -P8066 -uroot -p123456

（2）用Mycat服务添加表数据

在Mycat虚拟机上使用mysql命令对表company添加一条数据(2,“basketball”,“usa”)，添加 完毕后查看表信息。命令如下：

MySQL [USERDB]> insert into company values(2,"bastetball","usa");
Query OK, 1 row affected (0.050 sec)
MySQL [USERDB]> select * from company;
+----+------------+------+
| id | name | addr |
+----+------------+------+
| 1 | facebook | usa |
| 2 | bastetball | usa |
+----+------------+------+
2 rows in set (0.002 sec)

（3）验证Mycat服务对数据库读写操作分离

在Mycat虚拟机节点使用mysql命令，通过9066端口查询对数据库读写操作的分离信息。可以看 到所有的写入操作WRITE_LOAD数都在db1主数据库节点上，所有的读取操作READ_LOAD数都在db2 主数据库节点上。由此可见，数据库读写操作已经分离到db1和db2节点上了。命令如下：

root@mycat ~]# mysql -h127.0.0.1 -P9066 -uroot -p123456 -e 'show @@datasource;'

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1498720.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

用readproc函数读取进程的状态

用readproc函数读取进程的状态

概要&#xff1a; 本篇演示用readproc函数读取进程的状态 libprocps库的安装参考笔者的文章readproc.h-CSDN博客 演示所用的系统是Ubuntu22.04 一、代码 #include<stdio.h> #include<stdlib.h> #include<proc/readproc.h> int main() {struct PROCTAB *…
阅读更多...
清空 Redis 中所有的 key value

清空 Redis 中所有的 key value

我们先登录 redis 服务 然后 输入 keys *这样 就可以查询到内部所有的key 然后 执行 FLUSHDB清空全部键值对 这里 OK后 我们重写查询 keys *显然 数据就被清空了
阅读更多...
Redis几大数据类型

Redis几大数据类型

使用场景&#xff1a; Redis 数据类型及应用场景https://segmentfault.com/a/1190000012212663 Redis的五种常用数据类型在实际应用中有丰富的使用场景&#xff1a; 字符串&#xff08;String&#xff09; 缓存&#xff1a;存储经常查询但不频繁修改的数据&#xff0c;如网页…
阅读更多...
java-新手笔记-(File篇)

java-新手笔记-(File篇)

1.File File类提供了许多方法来操作文件和目录&#xff0c;包括创建、查找、删除文件等 file常见功能 1.增 创建文件 exits() 判断文件是否存在 createNewFile() 创建新文件 二个搭配一起.判断文件是否存在来创建文件(需要使用try/catch处理异常情况) File file new File(&…
阅读更多...
Java 学习和实践笔记（30）：继承树的追溯

Java 学习和实践笔记（30）：继承树的追溯

如上图所示&#xff0c;在上图中&#xff0c; 在最下面的子类Husky(哈士奇&#xff09;中&#xff0c;假定要查找一个变量或者方法h, 那么其查找顺序属性/方法查找顺序是这样的&#xff1a; 首先&#xff0c;查找当前类中有没有属性h 如果没有&#xff0c;则依次往上上溯每个…
阅读更多...
SkyEye：助力飞行器状态控制系统仿真

SkyEye：助力飞行器状态控制系统仿真

飞行器与常见的航天器一样&#xff0c;属于安全关键领域的大型复杂设备&#xff0c;对安全性、可靠性有着极高的要求。为保证稳定飞行&#xff0c;需要对目标对象进行实时跟踪&#xff0c;通过发出正确的修正偏差指令来操纵飞行器改变飞行姿态&#xff0c;因此对飞行器状态控制…
阅读更多...
[Buuctf] [MRCTF2020] Xor

[Buuctf] [MRCTF2020] Xor

运行 1.查壳 32位exe文件&#xff0c;没有壳 2.用32位IDA打开 找到main函数&#xff0c;F5查看伪代码&#xff0c;但是这里会弹出一个窗口 函数分析失败&#xff01;&#xff01; 这里我在看别人的题解时发现一种玄学方式解决了这个问题 窗口里面弹出了一个地址401095&…
阅读更多...
2024年1月京东牛奶乳品行业分析：TOP10品牌销量及销额排行榜

2024年1月京东牛奶乳品行业分析：TOP10品牌销量及销额排行榜

鲸参谋监测的京东平台1月份牛奶乳品市场销售数据已出炉&#xff01; 根据鲸参谋电商数据分析平台显示&#xff0c;今年1月份&#xff0c;京东平台上牛奶乳品的销量约1600万件&#xff0c;环比上个月增长87%&#xff0c;同比去年下滑16%&#xff1b;销售额约12亿元&#xff0c;…
阅读更多...
部署SpringBoot项目

部署SpringBoot项目

方案一&#xff1a;纯手工部署 1&#xff0c;购买一台云服务器 这里我使用腾讯云&#xff0c;推荐Centos8/Centos7.6 2&#xff0c;安装springBoot项目所需要的环境 1&#xff0c;数据库单独安装在另一台服务器上&#xff0c;只需要修改IP地址即可 2&#xff0c;安装jdk yum…
阅读更多...
MyBatis的#{}和${}：安全与灵活并存的SQL之道

MyBatis的#{}和${}：安全与灵活并存的SQL之道

MyBatis的#{}和${}&#xff1a;安全与灵活并存的SQL之道 MyBatis是一款广泛使用的Java持久化框架&#xff0c;提供了强大的SQL映射和数据库操作功能。在编写MyBatis的SQL语句时&#xff0c;我们经常会遇到#{}和${}两种不同的占位符语法。本文将详细解析#{}和${}的区别以及它们在…
阅读更多...
微信小程序uniapp+django+python的酒店民宿预订系统ea9i3

微信小程序uniapp+django+python的酒店民宿预订系统ea9i3

Android的民宿预订系统设计的目的是为用户提供民宿客房、公告信息等方面的平台。 与PC端应用程序相比&#xff0c;Android的民宿预订系统的设计主要面向于民宿&#xff0c;旨在为管理员和用户、商家提供一个Android的民宿预订系统。用户可以通过Android及时查看民宿客房等。 An…
阅读更多...
appium解锁android真机系统的屏幕

appium解锁android真机系统的屏幕

在使用appium进行app自动化操作的过程中&#xff0c;经常遇到的第一个难题就是如何解锁系统屏幕&#xff0c;也就是亮屏解锁。 实际上解决办法如下&#xff1a;在desired_capabilities中增加两个参数unlockType和unlockKey&#xff0c;类似的示例代码如下&#xff1a; desire…
阅读更多...
blast原理与使用技巧，最全最详细

blast原理与使用技巧，最全最详细

BLAST 序列比对 在生物信息学领域&#xff0c;序列比对是一项基础而关键的任务。它帮助研究人员识别基因、理解蛋白质功能&#xff0c;并揭示物种之间的进化关系。 本文旨在介绍BLAST&#xff08;Basic Local Alignment Search Tool&#xff09;的原理及其不同变体&#xff0c;…
阅读更多...
支小蜜校园防欺凌报警系统如何识别霸凌

支小蜜校园防欺凌报警系统如何识别霸凌

校园霸凌给受害者带来了深重的心理和身体伤害。为了有效应对这一问题&#xff0c;校园防欺凌报警系统应运而生&#xff0c;其核心技术在于如何准确、迅速地识别霸凌行为。那么校园防欺凌报警系统是如何识别霸凌的呢&#xff1f; 图像识别技术 这些系统利用高清摄像头捕捉校园…
阅读更多...
部署运维 防火墙，进程 常用命令

部署运维 防火墙，进程 常用命令

防火墙: 1. 查看是否安装了firewalld sudo systemctl status firewalld 查看防火墙状态或者sudo systemctl is-active firewalld 查看防火墙是否是开启状态 2. 开放6379port sudo firewall-cmd --add-port6379/tcp --permanent 刷新防火墙 sudo firewall-cmd --reload 3…
阅读更多...
Go-Gin-example 第五部分 加入swagger

Go-Gin-example 第五部分 加入swagger

上一节链接 swagger 为什么要用swagger 问题起源于 前后端分离&#xff0c; 后端&#xff1a;后端控制层&#xff0c;服务层&#xff0c;数据访问层【后端团队】前端&#xff1a;前端控制层&#xff0c;视图层&#xff0c;【前端团队】 所以产生问题&#xff1a;前后端联调…
阅读更多...
高级运维工程师手把手教从0到1搭建一套linux服务器硬盘监控平台实战训练

高级运维工程师手把手教从0到1搭建一套linux服务器硬盘监控平台实战训练

高级运维工程师手把手教你获取当前服务器硬盘空间数据并写入MYSQL数据库监控表实战 一、前言 我们在日常工作生活中&#xff0c;经常遇到服务器硬盘爆满的事故&#xff0c;现在互联网的监控产品非常丰富&#xff0c;但是有些场景下不得不自己解决。有些特殊条件下不能用互联网…
阅读更多...
讨论：5万官网是建站界的劳斯莱斯了吧，到了软件开发领域呢？

讨论：5万官网是建站界的劳斯莱斯了吧，到了软件开发领域呢？

如题&#xff0c;所以赛道选择很重要&#xff0c;当然难度系数也不一样。能花5万元做官网的&#xff0c;凤毛麟角&#xff0c;如果是做软件开发&#xff0c;5万元顶多算个起步价&#xff0c;老铁们&#xff0c;是这样吗&#xff1f;
阅读更多...
Hive的性能优化

Hive的性能优化

1.调优概述 Hive 作为大数据领域常用的数据仓库组件&#xff0c;在设计和查询时要特别注意效率。影响 Hive 效率的几乎从不是数据量过大&#xff0c;而是数据倾斜、数据冗余、Job或I/O过多、MapReduce分配不合理等等。对 Hive 的调优既包含 Hive 的建表设计方面&#xff0c;对H…
阅读更多...
Deeplearning4j【基础 01】初识Java深度学习框架DL4J

Deeplearning4j【基础 01】初识Java深度学习框架DL4J

初识Java深度学习框架DL4J 1.起因2.简介3.组件3.1 Deeplearning4j/ScalNet3.1.1 Deeplearning4jf&#xff08;Java&#xff09;3.1.2 ScalNet&#xff08;Scala&#xff09; 3.2 ND4J/LibND4J3.3 SameDiff3.4 DataVec3.5 Arbiter3.6 RL4J 4.总结 内容来自网络&#xff0c;基于官…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023