MySQL主从复制+读写分离（ShardingJDBC）

MySQL主从复制+读写分离

  • MySQL主从复制
    • 介绍
      • 二进制日志：
    • MySQL的主从复制原理如下
    • 搭建主从复制
      • 准备工作
      • 主库配置
      • 从库配置
    • 测试
  • 读写分离案例
    • ShardingJDBC介绍
    • 数据库环境
    • 初始工程导入
    • 读写分离配置
    • 测试
      • 1). 保存数据
      • 2). 修改数据
      • 3). 查询数据
      • 4). 删除数据

MySQL主从复制

介绍

MySQL主从复制是一个异步的复制过程，底层是基于Mysql数据库自带的 二进制日志 功能。就是一台或多台MySQL数据库（slave，即从库）从另一台MySQL数据库（master，即主库）进行日志的复制，然后再解析日志并应用到自身，最终实现 从库 的数据和 主库 的数据保持一致。MySQL主从复制是MySQL数据库自带功能，无需借助第三方工具。

二进制日志：

二进制日志（BINLOG）记录了所有的 DDL（数据定义语言）语句和 DML（数据操纵语言）语句，但是不包括数据查询语句。此日志对于灾难时的数据恢复起着极其重要的作用，MySQL的主从复制， 就是通过该binlog实现的。默认MySQL是未开启该日志的。

MySQL的主从复制原理如下

在这里插入图片描述
MySQL复制过程分成三步：

1). MySQL master 将数据变更写入二进制日志( binary log)

2). slave将master的binary log拷贝到它的中继日志（relay log）

3). slave重做中继日志中的事件，将数据变更反映它自己的数据

搭建主从复制

准备工作

提前准备两台服务器，并且在服务器中安装MySQL，服务器的信息如下：
在这里插入图片描述
并在两台服务器上做如下准备工作:

1). 防火墙开放3306端口号

firewall-cmd --zone=public --add-port=3306/tcp --permanentfirewall-cmd --zone=public --list-ports

在这里插入图片描述
2). 并将两台数据库服务器启动起来：

systemctl start mysqld

登录MySQL，验证是否正常启动

主库配置

1). 修改Mysql数据库的配置文件/etc/my.cnf
在最下面增加配置:

log-bin=mysql-bin   #[必须]启用二进制日志
server-id=200       #[必须]服务器唯一ID(唯一即可)

在这里插入图片描述
2). 重启Mysql服务
执行指令：

systemctl restart mysqld

在这里插入图片描述
3). 创建数据同步的用户并授权
登录mysql，并执行如下指令，创建用户并授权：

GRANT REPLICATION SLAVE ON *.* to 'xiaoming'@'%' identified by 'Root@123456';

注：上面SQL的作用是创建一个用户 xiaoming ，密码为 Root@123456 ，并且给xiaoming用户授予REPLICATION SLAVE权限。常用于建立复制时所需要用到的用户权限，也就是slave必须被master授权具有该权限的用户，才能通过该用户复制。
4). 登录Mysql数据库，查看master同步状态
执行下面SQL，记录下结果中File和Position的值

show master status;

在这里插入图片描述
注：上面SQL的作用是查看Master的状态，执行完此SQL后不要再执行任何操作

从库配置

1). 修改Mysql数据库的配置文件/etc/my.cnf

server-id=201 	#[必须]服务器唯一ID

2). 重启Mysql服务

systemctl restart mysqld

3). 登录Mysql数据库，设置主库地址及同步位置

change master to master_host='192.168.200.200',master_user='xiaoming',master_password='Root@123456',master_log_file='mysql-bin.000001',master_log_pos=154;start slave;

在这里插入图片描述
4). 查看从数据库的状态

show slave status;

然后通过状态信息中的 Slave_IO_running 和 Slave_SQL_running 可以看出主从同步是否就绪，如果这两个参数全为Yes，表示主从同步已经配置完成。
在这里插入图片描述

测试

主从复制的环境,已经搭建好了,接下来,我们可以通过Navicat连接上两台MySQL服务器,进行测试。测试时，我们只需要在主库Master执行操作，查看从库Slave中是否将数据同步过去即可。

1). 在master中创建数据库itcast, 刷新slave查看是否可以同步过去
在这里插入图片描述
2). 在master的itcast数据下创建user表, 刷新slave查看是否可以同步过去
在这里插入图片描述
3). 在master的user表中插入一条数据, 刷新slave查看是否可以同步过去
在这里插入图片描述

读写分离案例

面对日益增加的系统访问量，数据库的吞吐量面临着巨大瓶颈。 对于同一时刻有大量并发读操作和较少写操作类型的应用系统来说，将数据库拆分为主库和从库，主库负责处理事务性的增删改操作，从库负责处理查询操作，能够有效的避免由数据更新导致的行锁，使得整个系统的查询性能得到极大的改善。
在这里插入图片描述
通过读写分离,就可以降低单台数据库的访问压力, 提高访问效率，也可以避免单机故障。

主从复制的结构，我们在第一节已经完成了，那么我们在项目中，如何通过java代码来完成读写分离呢，如何在执行select的时候查询从库，而在执行insert、update、delete的时候，操作主库呢？这个时候，我们就需要介绍一个新的技术 ShardingJDBC。

ShardingJDBC介绍

Sharding-JDBC定位为轻量级Java框架，在Java的JDBC层提供的额外服务。 它使用客户端直连数据库，以jar包形式提供服务，无需额外部署和依赖，可理解为增强版的JDBC驱动，完全兼容JDBC和各种ORM框架。

使用Sharding-JDBC可以在程序中轻松的实现数据库读写分离。

Sharding-JDBC具有以下几个特点：

1). 适用于任何基于JDBC的ORM框架，如：JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC。

2). 支持任何第三方的数据库连接池，如：DBCP, C3P0, BoneCP, Druid, HikariCP等。

3). 支持任意实现JDBC规范的数据库。目前支持MySQL，Oracle，SQLServer，PostgreSQL以及任何遵循SQL92标准的数据库。

依赖:

<dependency><groupId>org.apache.shardingsphere</groupId><artifactId>sharding-jdbc-spring-boot-starter</artifactId><version>4.0.0-RC1</version>
</dependency>

数据库环境

在主库中创建一个数据库rw, 并且创建一张表， 该数据库及表结构创建完毕后会自动同步至从数据库，SQL语句如下：

create database rw default charset utf8mb4;use rw;CREATE TABLE `user` (`id` int(11) NOT NULL AUTO_INCREMENT,`name` varchar(255) DEFAULT NULL,`age` int(11) DEFAULT NULL,`address` varchar(255) DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

在这里插入图片描述

初始工程导入

我们本案例主要是演示一下读写分离操作，对于基本的增删改查的业务操作，我们就不再去编写了，我们可以直接导入资料中提供的demo工程（rw_demo），在demo工程中，我们已经完成了user的增删改查操作，具体的工程结构如下：
在这里插入图片描述

读写分离配置

1). 在pom.xml中增加shardingJdbc的maven坐标

<dependency><groupId>org.apache.shardingsphere</groupId><artifactId>sharding-jdbc-spring-boot-starter</artifactId><version>4.0.0-RC1</version>
</dependency>

2). 在application.yml中增加数据源的配置

spring:shardingsphere:datasource:names:master,slave# 主数据源master:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://192.168.200.200:3306/rw?characterEncoding=utf-8username: rootpassword: root# 从数据源slave:type: com.alibaba.druid.pool.DruidDataSourcedriver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://192.168.200.201:3306/rw?characterEncoding=utf-8username: rootpassword: rootmasterslave:# 读写分离配置load-balance-algorithm-type: round_robin #轮询# 最终的数据源名称name: dataSource# 主库数据源名称master-data-source-name: master# 从库数据源名称列表，多个逗号分隔slave-data-source-names: slaveprops:sql:show: true #开启SQL显示，默认false

在这里插入图片描述
3). 在application.yml中增加配置

spring:  main:allow-bean-definition-overriding: true

该配置项的目的,就是如果当前项目中存在同名的bean,后定义的bean会覆盖先定义的。

如果不配置该项，项目启动之后将会报错：
在这里插入图片描述
报错信息表明，在声明 org.apache.shardingsphere.shardingjdbc.spring.boot 包下的SpringBootConfiguration中的dataSource这个bean时出错, 原因是有一个同名的 dataSource 的bean在com.alibaba.druid.spring.boot.autoconfigure包下的DruidDataSourceAutoConfigure类加载时已经声明了。
在这里插入图片描述
在这里插入图片描述
而我们需要用到的是 shardingjdbc包下的dataSource，所以我们需要配置上述属性，让后加载的覆盖先加载的。

测试

我们使用shardingjdbc来实现读写分离，直接通过上述简单的配置就可以了。配置完毕之后，我们就可以重启服务，通过postman来访问controller的方法，来完成用户信息的增删改查，我们可以通过debug及日志的方式来查看每一次执行增删改查操作，使用的是哪个数据源，连接的是哪个数据库。

1). 保存数据

在这里插入图片描述
控制台输出日志，可以看到操作master主库：
在这里插入图片描述

2). 修改数据

在这里插入图片描述
控制台输出日志，可以看到操作master主库：
在这里插入图片描述

3). 查询数据

在这里插入图片描述
控制台输出日志，可以看到操作slave主库：
在这里插入图片描述

4). 删除数据

在这里插入图片描述
控制台输出日志，可以看到操作master主库：
在这里插入图片描述

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

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

相关文章

音频数据集大全（2）-语音合成

音频数据集大全（2）-语音合成

1、Speechocean762 简介&#xff1a;一个开源语音语料库&#xff0c;专为发音评估设计。该语料库包含来自250名非母语人士的5000个英语发音&#xff0c;其中一半的人是儿童。五位专家对每个发音进行了句子级、词级和音素级的注释。 该语料库允许用于商业和非商业目的。 下载…
阅读更多...
adb 汇总

adb 汇总

常用命令 adb devices 查看链接设备列表 adb kill-server 关闭并清楚所有链接 adb connect 设置链接 adb tcpip 该条命令是设置网络adb监听的端口&#xff0c;5555是默认&#xff0c;也可以设置其他的&#xff0c;在安卓设备重启后会失效&#xff0c;不需要root权限&#x…
阅读更多...
vue 拷贝

vue 拷贝

在 Vue.js 中，拷贝对象或数组是常见的操作，尤其是在处理状态管理或数据变更时。Vue 2 和 Vue 3 都提供了多种方法来实现对象和数组的拷贝。以下是详细的说明和示例： Vue 2 中的拷贝 1. 浅拷贝 浅拷贝只复制对象或数组的第一层属性，深层属性仍然引用原对象或数组。 使用 …
阅读更多...
【C++】多态（多态的原理）

【C++】多态（多态的原理）

在本篇博客中&#xff0c;作者将会带领你深入理解C中的多态。 声明&#xff01;&#xff01;&#xff01;本代码以及讲解都是在32位机器下进行完成的&#xff0c;64位机器下会有所不同&#xff0c;但大同小异。 一.多态的概念 什么是多态&#xff1f; 多态就是不同的对象去做…
阅读更多...
Linux如何通过md5校验远程传输的内容的完整性（随手记）

Linux如何通过md5校验远程传输的内容的完整性（随手记）

对需要校验的文件生成md5值&#xff0c;并保存 find /etc/ -type f | xargs md5sum > etc.md5校验 md5sum --check etc.md5Linux 中的 md5sum 命令 md5sum 是一个在 Linux 和 Unix 系统中广泛使用的命令行工具&#xff0c;用于计算和检查文件的 MD5&#xff08;Message D…
阅读更多...
cudnn是什么

cudnn是什么

NVIDIA cuDNN&#xff08;CUDA Deep Neural Network&#xff09;是用于深度神经网络的GPU加速库。 它强调性能、易用性和低内存开销。 NVIDIA cuDNN可以集成到更高级别的机器学习框架中&#xff0c;如加州大学伯克利分校的流行caffe软件。简单的&#xff0c;插入式设计可以让…
阅读更多...
bash: nvidia-smi: command not found

bash: nvidia-smi: command not found

服务器突然输入&#xff1a; nvidia-smi 出现&#xff1a; bash: nvidia-smi: command not found 确认nvidia-smi的安装路径&#xff0c;通常其位于/usr/bin/目录下&#xff0c;用如下的命令来检查&#xff1a; ls /usr/bin/nvidia-smi如果文件不存在&#xff0c;则 cd /…
阅读更多...
简易CAD程序：Qt多文档程序的一种实现

简易CAD程序：Qt多文档程序的一种实现

注&#xff1a;文中所列代码质量不高&#xff0c;但不影响演示我的思路 实现思路说明 实现DemoApplication 相当于MFC中CWinAppEx的派生类&#xff0c;暂时没加什么功能。 DemoApplication.h #pragma once#include <QtWidgets/QApplication>//相当于MFC中CWinAppEx的派生…
阅读更多...
以太坊（3）——智能合约

以太坊（3）——智能合约

智能合约 首先明确一下几个说法&#xff08;说法不严谨&#xff0c;为了介绍清晰才说的&#xff09;&#xff1a; 全节点矿工 节点账户 智能合约是基于Solidity语言编写的 学习Solidity语言可以到WFT学院官网&#xff08;Hello from WTF Academy | WTF Academy&#xff09;…
阅读更多...
以x为界，分隔链表为两个分区，各分区内元素相对位置不变

以x为界，分隔链表为两个分区，各分区内元素相对位置不变

题目描述&#xff1a; 题目思路&#xff1a; 1.设置两个头指针表示两个分区&#xff0c;并对每个分区设置相对于的遍历指针&#xff0c;指向分区链表链尾 2.设置原链表的遍历指针&#xff0c;判断指针所指元素是否小于目标值x&#xff0c;小于的话将结点添加到第一个分区末尾…
阅读更多...
C# 中combobox 控件初始化

C# 中combobox 控件初始化

怎么获取绑定数据的combobox的选中值及选中text 1、绑定combobox的代码如下&#xff1a; DataTable LDT_CodeType Models.MoCodefile.GetCodeType(); if (LDT_CodeType ! null) { cboxCtype.DataSource LDT_CodeType; cboxCtype.DisplayMember codetypename; cboxCtype.Val…
阅读更多...
搭建电商电子商务平台有哪些好用的电商API数据采集接口？

搭建电商电子商务平台有哪些好用的电商API数据采集接口？

电商API接口主要用于帮助开发者将电商功能集成到自己的应用程序中&#xff0c;实现诸如商品检索、商品价格数据获取、订单处理、支付、物流跟踪等功能。以下是一些常用的电商API接口提供商&#xff1a; 主流电商平台API&#xff1a; 淘宝开放平台&#xff1a;提供淘宝、天猫、…
阅读更多...
探索Ollama——入门：如何在本地环境中搭建和自定义大型语言模型

探索Ollama——入门：如何在本地环境中搭建和自定义大型语言模型

探索Ollama——入门&#xff1a;如何在本地环境中搭建和自定义大型语言模型 介绍Ollama 在当今快速发展的人工智能时代&#xff0c;大型语言模型&#xff08;LLMs&#xff09;已经成为技术前沿的热点话题。Ollama&#xff0c;作为一个开创性的工具&#xff0c;使得开发者能够…
阅读更多...
ngnix 入门 二，docker启动nginx, 安装ssl 证书，使用配置文件，映射后端服务 ，提供给前端项目访问

ngnix 入门 二，docker启动nginx, 安装ssl 证书，使用配置文件，映射后端服务 ，提供给前端项目访问

搭建生产环境真不是人做的事&#xff0c;特别是对于一知半解的人。仅以此文献给各位技术人 说一下背景&#xff1a;项目前后端分离&#xff0c;前端 vue3 、小程序端 &#xff0c;后端 go 提供服务。 微信小程序需要使用 https 请求。 这就必须让我们想到nginx 了 想要达到的…
阅读更多...
MySQL学习之DQL语句（数据查询语言）

MySQL学习之DQL语句（数据查询语言）

准备SQL CREATE TABLE student ( id int, -- 编号 name varchar(20), -- 姓名 age int, -- 年龄 sex varchar(5), -- 性别 address varchar(100), -- 地址 math int, -- 数学 english int -- 英语 );INSERT INTO student(id,NAME,age,sex,address,math,english) VALUES (1,…
阅读更多...
LeetCode88.合并两个有序数组

LeetCode88.合并两个有序数组

题目链接&#xff1a; 88. 合并两个有序数组 - 力扣&#xff08;LeetCode&#xff09; 分析&#xff1a;普通的数组合并&#xff0c;这里还可以提供两个其它思路。可以用最笨的办法&#xff0c;把nums2的每个元素都移动到nums1里面&#xff0c;然后做排序&#xff0c;直接用s…
阅读更多...
【UE5.1 角色练习】02-添加慢走、快速跑、蹲伏功能

【UE5.1 角色练习】02-添加慢走、快速跑、蹲伏功能

目录 前言 步骤 一、慢走 二、快速跑 三、蹲伏 前言 在上一篇文章基础上&#xff08;【UE5.1 角色练习】01-使用小白人蓝图控制商城角色移动&#xff09;继续实现角色的慢走、快速跑以及蹲伏功能 步骤 一、慢走 1. 打开项目设置&#xff0c;添加一个操作映射&#x…
阅读更多...
思维导图-VPN

思维导图-VPN

浏览器集成了受信任的机构的证书
阅读更多...
linux---信号的捕捉和处理

linux---信号的捕捉和处理

提示&#xff1a;以下是本篇文章正文内容&#xff0c;下面案例可供参考 一、信号 可以简单理解为信号是一个进程给另一个信号发消息&#xff0c;进程收到对应的信号就执行对应的方法&#xff0c;linux信号可以分为实时信号和非实时信号 1-31为非实时信号&#xff0c;34-64为…
阅读更多...
猫狗分类识别④滤波去噪

猫狗分类识别④滤波去噪

一、依赖库 pip install opencv-python 二、滤波去噪说明 中值滤波和高斯滤波各有优缺点&#xff0c;哪种滤波方法更好取决于具体的应用场景和图像中的噪声类型。中值滤波对于去除椒盐噪声&#xff08;即黑白点噪声&#xff09;特别有效&#xff0c;因为它通过取邻域像素的中…
阅读更多...
最新文章

Copyright @ 2022~2023