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

目录

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.mfbz.cn/a/437438.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

记录一次Dubbo远程调用的错误

记录一次Dubbo远程调用的错误

情景&#xff1a;有一个生成PDF的接口中&#xff0c;如下&#xff1a; GET Path("/getPDF") public void getPDF(QueryParam("id") String id, Context HttpServletResponse response) {………… }之前实现的代码都写在了Controller里面&#xff0c;代码里…
阅读更多...
网络调试助手使用MQTT协议与Mosquitto通信(3)

网络调试助手使用MQTT协议与Mosquitto通信(3)

一、连接报文 一开始设备需要连接到mqtt服务器&#xff0c;连接时的数据包内需要携带对应的设备ID&#xff0c;以及用户名和密码。这使用默认的用户名和密码。设备ID每一个设备都需要设置为不同的&#xff0c;两个相同的ID只能允许一台设备在线&#xff0c;另一个相同的ID的设备…
阅读更多...
VUE前端问题

VUE前端问题

一、图表内容不显示 watch: {chartData3: {handler() {this.init();},},timeData3: {handler() {this.init();},},}, 添加上面代码可以动态监控数据&#xff0c;实现图表的展示。 二、背景图片报错显示不出来 解决方法&#xff1a; background: url(~/assets/login/e.png) …
阅读更多...
hack the box 之Bizness

hack the box 之Bizness

端口扫描 服务扫描 漏洞扫描 Web 没什么东西目录扫描一下 注意这里有301需要操作一下 这个需要登入 直接查一下这个登入的目录 【Apache OFBiz 系列】手把手教你快速运行OFBiz项目_/ofbiz/runtime/data/derby/ofbiz/seg0-CSDN博客 右下角有版本 有关apache ofbiz的漏洞信息 …
阅读更多...
【Linux】权限管理（文件的访问者、类型和访问权限，chmod、chown、chgrp、umask，粘滞位）

【Linux】权限管理（文件的访问者、类型和访问权限，chmod、chown、chgrp、umask，粘滞位）

目录 00.前言 01.文件访问者的分类 02.文件类型和访问权限 文件类型&#xff1a; 文件基本权限&#xff1a; 03.文件权限值的表示方法 04.访问权限的设置 &#xff08;1&#xff09;chmod &#xff08;2&#xff09;chown &#xff08;3&#xff09;chgrp &#xff0…
阅读更多...
测试入门篇

测试入门篇

测试: 这里写目录标题 测试:基础概念:BUG:创建一个合理的bug:bug 的级别:跟开发争执如何解决: 测试用例:编写测试用例的万能公式:案例: 登录功能的测试:设计测试用例的方法: 进阶篇(主要介绍测试方法):自动化测试:自动化测试的分类:selenium( web 自动化测试工具 )环境部署:什么…
阅读更多...
Jvm 虚拟机命令

Jvm 虚拟机命令

Jps (查看正在运行的Java 进程) jps -q 只输出进程id、省略主类名称 -m 输出Jvm 进程启动时传递给主类main 函数参数 -l 输出主类全名称 -v 输出 Jvm 启动时的Jvm 参数 Jstat 查看 Jvm 统计信息 -class 监视类装载、卸载数量、总空间以及类装载所耗费的时间 -gc 监视 Java 堆…
阅读更多...
【力扣 - 无重复字符的最长字符串】

【力扣 - 无重复字符的最长字符串】

题目描述 给定一个字符串 s &#xff0c;请你找出其中不含有重复字符的 最长子串 的长度。 示例 1: 输入: s "abcabcbb" 输出: 3 解释: 因为无重复字符的最长子串是 "abc"&#xff0c;所以其长度为 3。 示例 2: 输入: s "bbbbb" 输出: 1 …
阅读更多...
程序地址空间

程序地址空间

引入 看这样一段代码 1 #include<stdio.h>2 #include<unistd.h>3 #include<stdlib.h>4 5 int g_val 100;6 int main()7 {8 pid_t id fork();9 if(id0)10 {11 int cnt 0;12 while(1)13 {14 printf("child,pid:%d,ppid:%d,g_val:%d,&g_v…
阅读更多...
记一次Flink任务无限期INITIALIZING排查过程

记一次Flink任务无限期INITIALIZING排查过程

1.前言 环境&#xff1a;Flink-1.16.1&#xff0c;部署模式&#xff1a;Flink On YARN&#xff0c;现象&#xff1a;Flink程序能正常提交到 YARN&#xff0c;Job状态是 RUNNING&#xff0c;而 Task状态一直处于 INITIALIZING&#xff0c;如下图&#xff1a; 通过界面可以看到…
阅读更多...
分布式搜索引擎-elasticsearch基础

分布式搜索引擎-elasticsearch基础

分布式搜索引擎-elasticsearch基础 1、什么是elasticsearch&#xff1f; elasticsearch是一款非常强大的开源搜索引擎&#xff0c;可以帮助我们从海量数据中快速找到需要的内容。 elasticsearch结合kibana、Logstash、Beats&#xff0c;也就是elastic stack&#xff08;ELK&a…
阅读更多...
【问题解决】| 关于vscode调试python文件 报错 且直接运行正常的诡异情况记录

【问题解决】| 关于vscode调试python文件 报错 且直接运行正常的诡异情况记录

关于python的debug报错&#xff0c;其实很奇怪 首先&#xff0c;对于工作区代码&#xff0c;我们可以通过CtrlShiftP 来切换Python解释器 这样的话&#xff0c;工作区的代码就不会报import error 而且这样的话是可以运行跑通的&#xff0c;但最抽象的一集来了&#xff0c;这…
阅读更多...
element-ui radio 组件源码分享

element-ui radio 组件源码分享

今日简单分享 radio 组件的实现原理&#xff0c;主要从以下三个方面来分享&#xff1a; 1、radio 页面结构 2、radio 组件属性 3、radio 组件方法 一、radio 页面结构 1.1 页面结构如下&#xff1a; 二、radio 属性 2.1 value / v-model 属性&#xff0c;类型为 string / …
阅读更多...
DNS——域名系统

DNS——域名系统

TCP/IP提供了通过IP地址来连接到设备的功能&#xff0c;但对用户来讲&#xff0c;记住某台设备的IP地址是相当困难的&#xff0c;因此专门设计了一种字符串形式的主机命名机制&#xff0c;这些主机名与IP地址相对应。在IP地址与主机名之间需要有一种转换和查询机制&#xff0c;…
阅读更多...
算法题 — 三个数的最大乘机

算法题 — 三个数的最大乘机

三个数的最大乘机 整型数组 nums&#xff0c;在数组中找出由三个数字组成的最大乘机&#xff0c;并输出这个乘积。&#xff08;乘积不会越界&#xff09; 重点考察&#xff1a;线性扫描 排序法&#xff1a; public static void main(String[] args) {System.out.println(so…
阅读更多...
Vue.js+SpringBoot开发农村物流配送系统

Vue.js+SpringBoot开发农村物流配送系统

目录 一、摘要1.1 项目介绍1.2 项目录屏 二、功能模块2.1 系统登录、注册界面2.2 系统功能2.2.1 快递信息管理&#xff1a;2.2.2 位置信息管理&#xff1a;2.2.3 配送人员分配&#xff1a;2.2.4 路线规划&#xff1a;2.2.5 个人中心&#xff1a;2.2.6 退换快递处理&#xff1a;…
阅读更多...
FreeROTS day2

FreeROTS day2

总结DMA空闲中断接收数据的使用方法 首先要要选择串口然后配置串口的参数&#xff0c;配置MDA通道选择接受数据&#xff0c;配置空闲中断&#xff0c;定义一个数据接收的容器&#xff0c;启动MDA传输当串口收到数据时MDA将数据传输到容器中,MDA会一直检测是否有数据当有数据并…
阅读更多...
《TCP/IP详解 卷一》第15章 TCP数据流与窗口管理

《TCP/IP详解 卷一》第15章 TCP数据流与窗口管理

目录 15.1 引言 15.2 交互式通信 15.3 延时确认 15.4 Nagle 算法 15.4.1 延时ACK与Nagle算法结合 15.4.2 禁用Nagle算法 15.5 流量控制与窗口管理 15.5.1 滑动窗口 15.5.2 零窗口与TCP持续计时器 15.5.3 糊涂窗口综合征 15.5.4 大容量缓存与自动调优 15.6 紧急机制…
阅读更多...
有一点好看的wordpress外贸独立站模板

有一点好看的wordpress外贸独立站模板

手机配件wordpress外贸网站模板 充电器、移动电源、手机膜、手机电池、手机壳、手机转接头等手机配件wordpress外贸网站模板。 https://www.jianzhanpress.com/?p3809 车载电器wordpress外贸网站模板 车载吸尘器、空气净化器、行车记录仪、车载充电器、车载影音导航等车载电…
阅读更多...
设计模式—命令模式：探索【命令模式】的奥秘与应用实践！

设计模式—命令模式：探索【命令模式】的奥秘与应用实践！

命令模式 命令模式是一种行为设计模式&#xff0c;它的主要目的是将请求封装成一个对象&#xff0c;从而使得请求的发送者和接收者之间进行解耦。 在命令模式中&#xff0c;命令被封装为一个对象&#xff0c;包含了需要执行的操作以及执行这些操作所需的所有参数。 命令的发送者…
阅读更多...
最新文章

Copyright @ 2022~2023