当前位置：首页 > news >正文

《Mycat核心技术》第17章：实现MySQL的读写分离

news 来源：原创 2025/9/15 19:18:36

作者：冰河
星球：http://m6z.cn/6aeFbs
博客：https://binghe.gitcode.host
文章汇总：https://binghe.gitcode.host/md/all/all.html
星球项目地址：https://binghe.gitcode.host/md/zsxq/introduce.html

沉淀，成长，突破，帮助他人，成就自我。

本章难度：★★☆☆☆
本章重点：介绍Myca实现MySQL的读写分离案例，掌握Mycat在实际案例场景中的应用，能够结合自身实际项目将Mycat灵活应用到自身实际项目中。

大家好，我是冰河~~

今天给大家介绍《Mycat核心技术》的第17章：给大家简单介绍下Mycat实现MySQL的读写分离的案例，好了，开始今天的内容。

一、服务规划

在MySQL中间件出现之前，对于MySQL主从集群，如果要实现其读写分离，一般是在程序端实现，这样就带来一个问题，即数据库和程序的耦合度太高，如果我数据库的地址发生改变了，那么我程序端也要进行相应的修改，如果数据库不小心挂掉了，则同时也意味着程序的不可用，而这对很多应用来说，并不能接受。

引入MySQL中间件能很好的对程序端和数据库进行解耦，这样，程序端只需关注数据库中间件的地址，而无需知晓底层数据库是如何提供服务。

作为当前炙手可热的MySQL中间件，MyCAT实现MySQL主从集群的读写分离自是应有之义，其配置也相当简单。

在这里，我用三个实例组成MySQL主从集群，来验证MyCAT的读写分离功能，其实，一主一从就可以满足，之所以用三个，是为了验证MyCAT的分片功能。

集群组成如下：

角色	主机名	主机IP
master	mysql-server1	192.168.244.145
slave	mysql-server2	192.168.244.146
slave	mysql-server3	192.168.244.144

在这里，还是使用Travelrecord表进行测试。

首先编辑MyCAT的配置文件schema.xml，关于dataHost的配置信息如下：

<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1" writeType="0" dbType="mysql" dbDriver="native" switchType="-1"  slaveThreshold="100"><heartbeat>select user()</heartbeat><!-- can have multi write hosts --><writeHost host="hostM1" url="localhost:3306" user="root" password="123456"></writeHost><writeHost host="hostS1" url="192.168.244.146:3306" user="root" password="123456"/><writeHost host="hostS2" url="192.168.244.144:3306" user="root" password="123456"/>
</dataHost>

这里面，有两个参数需要注意，balance和 switchType。

其中，balance指的负载均衡类型，目前的取值有4种：

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不负担读压力

switchType指的是切换的模式，目前的取值也有4种：

switchType=‘-1’ 表示不自动切换
switchType=‘1’ 默认值，表示自动切换
switchType=‘2’ 基于MySQL主从同步的状态决定是否切换,心跳语句为 show slave status
switchType='3’基于MySQL galary cluster的切换机制（适合集群）（1.4.1），心跳语句为 show status like ‘wsrep%’。

因此，该配置文件中的balance="1"意味着作为stand by writeHost的hostS1和hostS2将参与select语句的负载均衡，这就实现了主从的读写分离，switchType='-1’意味着当主挂掉的时候，不进行自动切换，即hostS1和hostS2并不会被提升为主，仍只提供读的功能。这就避免了将数据读进slave的可能性，毕竟，单纯的MySQL主从集群并不允许将数据读进slave中，除非配置的是双master。

二、验证读写分离

下面来验证一下，创建Travelrecord表

create table travelrecord (id bigintnotnullprimarykey,user_idvarchar(100),traveldate DATE, fee decimal,days int);

插入数据

mysql>insertinto travelrecord(id,user_id,traveldate,fee,days)  values(1,@@hostname,20160101,100,10);
Query OK, 1 row affected, 1 warning (0.02 sec)mysql>insertinto travelrecord(id,user_id,traveldate,fee,days)  values(5000001,@@hostname,20160102,100,10);
Query OK, 1 row affected, 1 warning (0.01 sec)

在这里，用了一个取巧的方法，即对user_id插入了当前实例的主机名，这样可直观的观察读写是否分离以及MyCAT的分片功能。能这样做的原因在于我当前的MySQL版本-5.6.26默认是基于statement的复制，如果是基于row的复制，则这个方法将不可取。
查询数据

mysql>select * from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|1| mysql-server2 |2016-01-01|100|10||5000001| mysql-server3 |2017-02-02|100|10|+---------+---------------+------------+------+------+2 rows inset (0.01 sec)mysql>select * from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|5000001| mysql-server3 |2016-01-02|100|10||1| mysql-server2 |2017-02-01|100|10|+---------+---------------+------------+------+------+2 rows inset (0.02 sec)mysql>select * from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|5000001| mysql-server3 |2016-01-02|100|10||1| mysql-server3 |2017-02-01|100|10|+---------+---------------+------------+------+------+2 rows inset (0.01 sec)mysql>select * from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|5000001| mysql-server3 |2016-01-02|100|10||1| mysql-server3 |2017-02-01|100|10|+---------+---------------+------------+------+------+2 rows inset (0.01 sec)mysql>select * from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|1| mysql-server2 |2016-01-01|100|10||5000001| mysql-server2 |2017-02-02|100|10|+---------+---------------+------------+------+------+

从上面的输出结果，可以得出以下两点：

（1）该配置已实现读写分离，读出来的数据没有master节点的。

（2）MyCAT的随机分发不是基于statement的，即一个select语句查询其中一个节点，另外一个select语句查询另外一个节点。它分发针对的是片的，同一个select语句的结果是有不同dataNode返回的。

不仅如此，从MyCAT日志中也可以获取读写分离的相关信息，当然，前提是MyCAT的日志级别是debug。日志相关信息如下：

在这里插入图片描述

三、验证mater挂了，slave还能提供读的功能

对于MySQL主从集群，我们的需求是master挂了，slave还能提供读的功能。

下面来测试一下

首先，人为的关闭主库

[root@mysql-server1 ~]# /etc/init.d/mysqld stop

登录MyCAT

[root@mysql-server1 ~]# mysql -utest -ptest -h127.0.0.1 -P8066 -DTESTDB

插入数据

mysql>insertinto travelrecord(id,user_id,traveldate,fee,days)  values(10000001,@@hostname,20170213,100,10);
ERROR 1184 (HY000): Connection refused
mysql>select*from travelrecord;
+---------+---------------+------------+------+------+| id      |user_id| traveldate | fee  | days |+---------+---------------+------------+------+------+|1| mysql-server2 |2017-02-01|100|10||5000001| mysql-server3 |2017-02-02|100|10|+---------+---------------+------------+------+------+2 rows inset (0.02 sec)

可见无法插入数据，但不影响读取数据。

至此，MyCAT实现MySQL的读写分离部署测试完毕。

四、总结

其实，刚开始配置的是readHost节点，配置如下：

<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"  writeType="0" dbType="mysql" dbDriver="native" switchType="-1"  slaveThreshold="100"><heartbeat>select user()</heartbeat><!-- can have multi write hosts --><writeHost host="hostM1" url="localhost:3306" user="root" password="123456"><!-- can have multi read hosts --><readHost host="hostS1" url="192.168.244.146:3306" user="root" password="123456"/></writeHost>
</dataHost>

但这种方式有个问题，即master挂了以后，slave也不能提供服务，而这违反了MySQL主从集群的初衷。

如果开启了事务模式，即set autocommit=0，则事务内的读走的是master节点，而不是从节点。

好了，今天就到这儿吧，我是冰河，我们下期见~~

《Mycat核心技术》第17章：实现MySQL的读写分离

作者：冰河星球：http://m6z.cn/6aeFbs 博客：https://binghe.gitcode.host 文章汇总：https://binghe.gitcode.host/md/all/all.html 星球项目地址：https://binghe.gitcode.host/md/zsxq/introduce.html 沉淀&#xff0c…...

编程日记 2025/9/15 19:18:36

区块链（14）：FISCO BCOS配置及使用控制台

1 获取控制台并回到fisco目录 cd ~/fisco && curl -LO https://github.com/FISCO-BCOS/console/releases/download/v2.9.2/download_console.sh && bash download_console.sh 2 拷贝控制台配置文件若节点未采用默认端口，请将文件中的20200替换成节点对应的…...

编程日记 2025/9/15 12:44:36

react路由总结

目录一、脚手架基础语法(16~17) 1.1、hello react 1.2、组件样式隔离(样式模块化) 1.3、react插件二、React Router v5 2.1、react-router-dom相关API 2.1.1、内置组件 2.1.1.1、BrowserRouter 2.1.1.2、HashRouter 2.1.1.3、Route 2.1.1.4、Redirect 2.1.1.5、L…...

编程日记 2025/9/12 1:17:16

Python爬虫处理网页中的动态内容

文章目录前言一、Python环境搭建1.Python安装2.选择Python开发环境二、Python爬虫处理网页中的动态内容1. 使用 Selenium 库2. 使用 Pyppeteer 库3. 分析 API 请求前言在网页中，动态内容通常是指那些通过 JavaScript 在页面加载后动态生成或更新的内容&#xf…...

编程日记 2025/9/13 14:20:31

Lineageos 22.1(Android 15)Launcer简单调整初始化配置

一、前言 Launcer的初始化配置主要在如下的xml文件夹下，默认读取的5x5 这里我们把device_profiles调整一下，然后新建一个default_workspace_my.xml作为我们自己的配置就行。二、配置注意Lineageos 的Launcer是在lineageos/packages/apps/Trebuchet…...

编程日记 2025/9/11 17:38:20

计算机毕业设计SpringBoot+Vue.js教师工作量管理系统(源码+LW文档+PPT+讲解)

温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 温馨提示：文末有 CSDN 平台官方提供的学长联系方式的名片！ 作者简介：Java领…...

编程日记 2025/9/10 1:41:49

【Scrapy】Scrapy教程7——存储数据

上一节我们对爬虫程序的默认回调函数parse做了改写，提取的数据可以在Scrapy的日志中打印出来了，光打印肯定是不行的，还需要把数据存储，数据可以存到文件，也可以存到数据库，我们一一来看。存储数据到文件首先我们看看如何将数据存储到文件，在讲[[【Scrapy】Scrapy教程…...

编程日记 2025/9/8 20:42:59

使用Socket编写超牛的http服务器和客户端(一）

实现一个高性能的基于 IOCP（I/O Completion Ports）的 HTTP 服务器，支持多线程、动态线程池调整和路由处理。主要功能和特性 IOCP 模型：使用多个 IOCP 句柄（IOCP_COUNT），将客户端连接均匀分配到不同的 IOCP 上，减少线程竞争。工作线程使用 GetQueuedCompletionStatu…...

编程日记 2025/9/10 11:28:34

centos服务器巡检脚本

服务器巡检脚本系统负载shell脚本python将txt文件转换成excel，不正常巡检结果标记红色系统负载shell脚本 #!/bin/bash#文件路径 path"/root/monitor.txt"#yum -y install bc sysstat net-tools lrzsz #获取主机名 system_hostname$(hostname | awk {pr…...

编程日记 2025/9/10 20:10:30

Linux-Ansible模块完结

文章目录 User和GroupHostname、Cron、Yum和Service 🏡作者主页：点击！ 🤖Linux专栏：点击！ ⏰️创作时间：2025年02月23日19点59分 User和Group User和Group模块实践 ansible 192.168.1.100 -m …...

编程日记 2025/9/8 16:21:21

厦大团队：DeepSeek大模型概念、技术与应用实践 140页PDF完整版下载

DeepSeek使用教程系列： 厦门大学： DeepSeek大模型概念、技术与应用实践 140页PDF完整版文件厦大团队：DeepSeek大模型概念、技术与应用实践（140页PPT读懂大模型）.pdf https://pan.baidu.com/s/1de4UIxqPsvMBIYcpen_M-…...

编程日记 2025/9/13 1:05:50

跟据spring boot版本，查看对应的tomcat，并查看可支持的tomcat的版本范围

一查看springboot自带的tomcat版本： 可直接在项目中找到Maven Dependencies中找到tomcat版本二、查看SpringBoot内置tomcat版本的支持范围我这边是跟据maven仓库查看的首先跟据链接打开maven仓库：https://mvnrepository.com/ 然后搜索&#xff1a…...

编程日记 2025/9/10 3:09:59

小米AX3000T 路由器如何开启 SSH 安装 OpenWRT 系统，不需要降级 v1.0.91 （2025）

小米AX3000T 路由器如何开启 SSH 安装 OpenWRT 系统，不需要降级 v1.0.91 （2025） 本文内容需要你有一定的 Linux 操作基础，最好是程序员那种，英文水平足够用才行。一般人不需要使用这么复杂的路由器操作系统&#xff0c…...

编程日记 2025/9/13 16:34:13

跳格子游戏

跳格子游戏真题目录: 点击去查看 E 卷 100分题型题目描述地上共有N个格子，你需要跳完地上所有的格子，但是格子间是有强依赖关系的，跳完前一个格子后，后续的格子才会被开启，格子间的依赖关系由多组steps数组给出，steps[0]表示前一个格子，steps[1]表示steps[0]可以开…...

编程日记 2025/9/9 20:30:38

抓包工具是什么？

抓包工具是一种用于捕获和分析网络数据包的软件或硬件设备。它可以帮助用户监控网络通信过程，查看网络中传输的数据内容、协议类型、源地址、目的地址等信息。以下是关于抓包工具的一些详细解释： 1. 主要功能捕获数据包：抓包工具能够实时捕…...

编程日记 2025/9/11 10:44:34

【用deepseek和chatgpt做算法竞赛】——还得DeepSeek来 -Minimum Cost Trees_5

往期【用deepseek和chatgpt做算法竞赛】——华为算法精英实战营第十九期-Minimum Cost Trees_0：介绍了题目和背景【用deepseek和chatgpt做算法竞赛】——华为算法精英实战营第十九期-Minimum Cost Trees_1：题目输入的格式说明，选择了邻接表…...

编程日记 2025/9/11 14:28:18

edge浏览器将书签栏顶部显示

追求效果，感觉有点丑，但总归方便多了操作路径：设置-外观-显示收藏夹栏-始终...

编程日记 2025/9/15 19:55:40

[漏洞篇]文件上传漏洞详解

[漏洞篇]文件上传漏洞详解一、介绍 1. 概念文件上传漏洞是指用户上传了一个可执行的脚本文件，并通过此脚本文件获得了执行服务器端命令的能力。这种攻击方式是最为直接和有效的，“文件上传” 本身没有问题，有问题的是文件上传后&#xf…...

编程日记 2025/9/15 21:44:51

计算机毕业设计SpringBoot+Vue.js企业客户管理系统(源码+LW文档+PPT+讲解+开题报告)

编程日记 2025/9/15 14:29:47

【多模态处理篇三】【DeepSeek语音合成：TTS音色克隆技术揭秘】

最近帮某明星工作室做AI语音助手时遇到魔幻需求——要求用5秒的咳嗽声克隆出完整音色！传统TTS系统直接翻车，生成的语音像得了重感冒的电音怪物。直到祭出DeepSeek的TTS音色克隆黑科技，才让AI语音从"机器朗读"进化到"声临其境"。今天我们就来扒开这个声音…...

编程日记 2025/9/8 14:42:56

华为网络安全认证

🍅 点击文末小卡片 ，免费获取网络安全全套资料，资料在手，涨薪更快华为网络安全认证：保障信息安全的重要一环在数字化时代的今天，网络安全成为了企业和个人都需要高度重视的问题。尤其是在企业信息化的…...

编程日记 2025/9/12 16:08:29

计算机视觉：经典数据格式(VOC、YOLO、COCO)解析与转换(附代码)

第一章：计算机视觉中图像的基础认知第二章：计算机视觉：卷积神经网络(CNN)基本概念(一) 第三章：计算机视觉：卷积神经网络(CNN)基本概念(二) 第四章：搭建一个经典的LeNet5神经网络(附代码) 第五章&#xff1…...

编程日记 2025/9/14 20:52:55

开源嵌入式实时操作系统uC/OS-II介绍

一、uC/OS-II的诞生：从开源实验到行业标杆背景与起源 uC/OS-II（Micro-Controller Operating System Version II）诞生于1992年，由嵌入式系统先驱Jean J. Labrosse开发。其前身uC/OS（1991年）最初作为教学工…...

编程日记 2025/9/15 12:03:18

QT基础八、与时间相关的UI控件

目录一、时间类：QTime 1. 创建 QTime 对象 2. 获取当前时间 3. 设置时间 4. 时间格式化 5. 时间加减操作 6. 时间比较 7. 计算时间间隔 8. 判断时间是否有效 9. 使用 QElapsedTimer 测量时间间隔二、日期类：QDate 1. 创建 QDate 对象 2. 获…...

编程日记 2025/9/16 19:10:44

大道至简少字全意易经的方式看缓存 mybatis缓存 rendis缓存场景案例

目录介绍 mybatis缓存一级缓存 1.是什么 2.特点 3.场景 mybatis 二级缓存 1.是什么 2.特点 3.配置步骤注意一级缓存问题二级缓存问题扩展 1.MyBatis集成 Redis 2.直接使用Redis redis 缓存一、String 字符串二、Llst 列表三、Hash 哈希四、Set…...

编程日记 2025/9/15 0:09:53

Python爬虫selenium验证-中文识别点选+图片验证码案例

1.获取图片 import re import time import ddddocr import requests from selenium import webdriver from selenium.webdriver.common.by import By from selenium.webdriver.chrome.service import Service from selenium.webdriver.support.wait import WebDriverWait from …...

编程日记 2025/9/14 13:42:29

一、服务规划

二、验证读写分离

三、验证mater挂了，slave还能提供读的功能

四、总结

相关文章：