《Mycat核心技术》第19章：基于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

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

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

大家好，我是冰河~~

今天给大家介绍《Mycat核心技术》的第19章：以图文的形式给大家介绍下Myca基于MySQL实现读写分离的案例，好了，开始今天的内容。

一、环境

  • 操作系统：CentOS-6.5-x86_64-bin-DVD1.iso
  • JDK版本：jdk1.7.0_80
  • MyCat版本：Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz (下载源码自行编译的)
  • MyCat节点IP：192.168.209.133 主机名：liuyazhuang133 主机配置：4核CPU、4G内存
  • MySQL版本：mysql-5.6.32.tar.gz
  • 主节点IP：192.168.209.131 主机名：liuyazhuang131 主机配置：4核CPU、4G内存
  • 从节点IP：192.168.209.132 主机名：liuyazhuang132 主机配置：4核CPU、4G内存

二、MyCat介绍 （ MyCat官网：http://mycat.io/ ）

MyCat的读写分离是基于后端MySQL集群的主从同步来实现的，而MyCat提供语句的分发功能。MyCat1.4开始支持MySQL主从复制状态绑定的读写分离机制，让读更加安全可靠。

编辑

三、MyCat的安装

1、设置MyCat的主机名和IP与主机名的映射
# vi /etc/sysconfig/network
NETWORKING=yes
HOSTNAME=liuyazhuang133

# vi /etc/hosts
127.0.0.1 liuyazhuang133
192.168.209.131 liuyazhuang131
192.168.209.132 liuyazhuang132
192.168.209.133 liuyazhuang133
2、配置Java环境变量

因为MyCat是用Java开发的，因此MyCat运行需要安装JDK（准确来说是JRE就够了），并且需要JDK1.7或以上版本

# vi /etc/profile
## java env
export JAVA_HOME=/usr/local/java/jdk1.7.0_80
export JRE_HOME=$JAVA_HOME/jre
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib/rt.jar
export PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin
# source /etc/profile
# java -version
3、上传安装包

上传Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz 到 MyCat服务器中的/home/mycat目录，并解压并移动到 /usr/local/mycat目录

$ tar -zxvf Mycat-server-1.5.1-RELEASE-20170717215510-linux.tar.gz

# mv /home/mycat/mycat  /usr/local/
# cd /usr/local/mycat/
# ll

编辑

4、设置Mycat的环境变量
# vi /etc/profile
## mycat env
export MYCAT_HOME=/usr/local/mycat
export PATH=$PATH:$MYCAT_HOME/bin
# source /etc/profile

四、配置MyCat

1、确认MySQL主从复制正常

在配置MyCat前，请确认MySQL的主从复制安装配置已完成并正常运行。MySQL主从数据的同步在MySQL中配置，MyCat不负责数据同步的问题。

补充：
(1) MySQL主从复制配置中，如果涉及到函数或存储过程的同步复制，需要在/etc/my.cnf中的[mysqld]段中增加配置log_bin_trust_function_creators=true 或在客户端中设置 set global log_bin_trust_function_creators = 1;
(2) 如果要做读写分离下的主从切换，那么从节点也有可能会变为写节点，因此从节点就不能设置为只读 read_only=1 。
(3) Linux版本的MySQL，需要设置为MySQL大小写不敏感，否则可能会发生找不到表的问题。可在/etc/my.cnf的[mysqld]段中增加lower_case_table_names=1 。

2、配置MyCat的schema.xml

schema.xml是MyCat最重要的配置文件之一，用于设置MyCat的逻辑库、表、数据节点、dataHost等内容，

[root@liuyazhuang133 conf]$ cd /usr/local/root/conf/
[root@liuyazhuang133 conf]$ vi schema.xml

<?xml version="1.0"?><!DOCTYPE mycat:schema SYSTEM "schema.dtd"><mycat:schema xmlns:mycat="http://org.opencloudb/"><!-- 定义MyCat的逻辑库，逻辑库的概念与MySQL中的 database 概念相同 --><!-- schema name="rc_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="rc_dn1"></schema --><!--schema name="pay_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="pay_dn1"></schema--><schema name="lyz_schema1" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn1"></schema><schema name="lyz_schema2" checkSQLschema="false" sqlMaxLimit="100" dataNode="lyz_dn2"></schema><!-- 其中checkSQLschema表明是否检查并过滤SQL中包含schema的情况，如逻辑库为 TESTDB，则可能写为select * from TESTDB.edu_user，此时会自动过滤TESTDB，SQL变为select * from edu_user，若不会出现上述写法，则可以关闭属性为false --><!--sqlMaxLimit默认返回的最大记录数限制，MyCat1.4版本里面，用户的Limit参数会覆盖掉MyCat的sqlMaxLimit默认设置--><!-- 定义MyCat的数据节点 --><dataNode name="lyz_dn1" dataHost="dtHost2" database="lyzdb1" /><dataNode name="lyz_dn2" dataHost="dtHost2" database="lyzdb2" /><!-- dataNode 中的 name 数据表示节点名称， dataHost表示数据主机名称， database表示该节点要路由的数据库的名称 --><!-- dataHost配置的是实际的后端数据库集群（当然，也可以是非集群） --><!-- 注意：schema中的每一个dataHost中的host属性值必须唯一，否则会出现主从在所有dataHost中全部切换的现象 --><!-- 定义数据主机dtHost1，只连接到MySQL读写分离集群中的Master节点，不使用MyCat托管MySQL主从切换 --><!--<dataHost name="dtHost1" maxCon="500" minCon="20" balance="0"writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100"><heartbeat>select user()</heartbeat><writeHost host="hostM1" url="192.168.1.205:3306" user="root" password="lyz" /></dataHost>--><!-- 使用MyCat托管MySQL主从切换 --><!-- 定义数据主机dtHost2，连接到MySQL读写分离集群，并配置了读写分离和主从切换 --><dataHost name="dtHost2" maxCon="500" minCon="20" balance="1"writeType="0" dbType="mysql" dbDriver="native" switchType="2" slaveThreshold="100"><!-- 通过show slave status检测主从状态，当主宕机以后，发生切换，从变为主，原来的主变为从，这时候show slave status就会发生错误，因为原来的主没有开启slave，不建议直接使用switch操作，而是在DB中做主从对调。 --><heartbeat>show slave status</heartbeat><!-- can have multi write hosts --><writeHost host="hostM2" url="192.168.209.131:3306" user="root" password="root" /><writeHost host="hostS2" url="192.168.209.132:3306" user="root" password="root" /></dataHost><!-- 参数balance决定了哪些MySQL服务器参与到读SQL的负载均衡中 --><!-- balance="0"，为不开启读写分离，所有读操作都发送到当前可用的writeHost上--><!-- balance="1"，全部的readHost与stand by writeHost参与select语句的负载均衡--><!-- balance="2"，所有读操作都随机的在writeHost、readHost上分发--><!-- MyCat1.4版本中，若想支持MySQL一主一从的标准配置，并且在主节点宕机的情况下，从节点还能读取数据，则需要在MyCat里配置为两个writeHost并设置balance="1" --><!-- writeType="0"，所有写操作都发送到可用的writeHost上 --><!-- writeType="1"，仅仅对于galera for mysql集群这种多主多节点都能写入的集群起效，此时Mycat会随机选择一个writeHost并写入数据，对于非galera for mysql集群，请不要配置writeType=1，会导致数据库不一致的严重问题 --></mycat:schema>

MyCat1.4开始支持MySQL主从复制状态绑定的读写分离机制，让读更加安全可靠，配置如下：
MyCat心跳检查语句配置为 show slave status ，dataHost 上定义两个新属性：switchType=“2” 与 slaveThreshold=“100”，此时意味着开启MySQL主从复制状态绑定的读写分离与切换机制，MyCat心跳机制通过检测 show slave status 中的
“Seconds_Behind_Master”, “Slave_IO_Running”, “Slave_SQL_Running” 三个字段来确定当前主从同步的状态以及Seconds_Behind_Master主从复制时延，当Seconds_Behind_Master 大于slaveThreshold时，读写分离筛选器会过滤掉此Slave机器，防止读到很久之前的旧数据，而当主节点宕机后，切换逻辑会检查Slave上的Seconds_Behind_Master是否为0，为0时则表示主从同步，可以安全切换，否则不会切换。

3、配置 server.xml

server.xml 主要用于设置系统变量、管理用户、设置用户权限等。

[root@liuyazhuang133 conf]$ vi server.xml

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mycat:server SYSTEM "server.dtd"><mycat:server xmlns:mycat="http://org.opencloudb/"><system><property name="defaultSqlParser">druidparser</property><property name="charset">utf8mb4</property><!-- <property name="useCompression">1</property>--><!--1为开启mysql压缩协议--><!-- <property name="processorBufferChunk">40960</property> --><!--<property name="processors">1</property><property name="processorExecutor">32</property>--><!--默认是65535 64K 用于sql解析时最大文本长度 --><!--<property name="maxStringLiteralLength">65535</property>--><!--<property name="sequnceHandlerType">0</property>--><!--<property name="backSocketNoDelay">1</property>--><!--<property name="frontSocketNoDelay">1</property>--><!--<property name="processorExecutor">16</property>--><!-- <property name="mutiNodeLimitType">1</property> 0：开启小数量级（默认） ；1：开启亿级数据排序<property name="mutiNodePatchSize">100</property> 亿级数量排序批量<property name="processors">32</property> <property name="processorExecutor">32</property><property name="serverPort">8066</property> <property name="managerPort">9066</property><property name="idleTimeout">300000</property> <property name="bindIp">0.0.0.0</property><property name="frontWriteQueueSize">4096</property><property name="processors">32</property>--></system><!-- 用户1，对应的MyCat逻辑库连接到的数据节点对应的主机为MySQL主从复制配置中的Master节点，没实现读写分离，读写都在该Master节点中进行  --><!--<user name="user1"><property name="password">roncoo.1</property><property name="schemas">rc_schema1,pay_schema1</property></user>--><!-- 用户2，对应的MyCat逻辑库连接到的数据节点对应的主机为主从复制集群，并通过MyCat实现了读写分离 --><user name="lyz"><property name="password">lyz.123</property><property name="schemas">lyz_schema1,lyz_schema2</property></user><!-- 用户3，只读权限--><user name="userlyz"><property name="password">lyz.123</property><property name="schemas">lyz_schema1,lyz_schema2</property><property name="readOnly">true</property></user></mycat:server>
4、防火墙中打开8066和9066端口

MyCat的默认数据端口为8066，mycat通过这个端口接收数据库客户端的访问请求。
管理端口为9066，用来接收mycat监控命令、查询mycat运行状况、重新加载配置文件等。

[root@liuyazhuang133 mycat]# vi /etc/sysconfig/iptables

增加：

## MyCat
-A INPUT -m state --state NEW -m tcp -p tcp --dport 8066 -j ACCEPT
-A INPUT -m state --state NEW -m tcp -p tcp --dport 9066 -j ACCEPT

重启防火墙：

[root@liuyazhuang133 mycat]# service iptables restart
5、修改log日志级别为debug

修改log日志级别为debug，以便通过日志确认基于MyCat的MySQL数据库集群读写分离的数据操作状态（可以在正式上生产前改成info级别）

[root@liuyazhuang133 conf]$ vi /usr/local/mycat/conf/log4j.xml

6、启动root
[root@liuyazhuang133 bin]$ cd /usr/local/root/bin/

(1) 控制台启动，这种启动方式在控制台关闭后，root服务也将关闭，适合调试使用：

[root@liuyazhuang133 bin]$ ./root console

(2) 可以采用以下后台启动的方式：

[root@liuyazhuang133 bin]$ ./root start
Starting root-server...

（对应的，重启: root restart ， 关闭: root stop ）
7、MyCat连接测试

(1) 如果本地Windows安装有MySQL，可以使用已有的mysql客户端远程操作Mycat
​

​

(2) Nativecat连接Mycat

编辑

编辑

编辑

8、读写分离测试

(1) 监听MyCat日志

[root@liuyazhuang133 ~]$ cd /usr/local/mycat/logs/
[root@liuyazhuang133 logs]$ tail -f mycat.log

(2) 读测试

$ mysql -uuserlyz -plyz.123 -h192.168.209.233 -P8066
mysql> show databases;


mysql> use lyz_schema2;


mysql> show tables;


mysql> select * from lyz_user_02;

执行上面的查询语句，此时对应的MyCat日志信息如下：

多次执行 select * from lyz_user_02 语句，Mycat打印出来的日志信息显示读操作请求都是路由到Slave节点（192.168.209.132）

(2) 写测试

mysql> insert into lyz_user_02 (userName, pwd) values('liuyazhuang', 'lyz。123');

执行上面的新增插入语句后，此时对应的Mycat日志信息如下：

多次执行以上插入语句，发现新增数据都是从 Master节点（192.168.209.131）插进入的，并且Slave节点通过Binlog同步了Master节点中的数据。

综上，基于MyCat的读写分离集群配置成功。

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

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

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

相关文章

【安卓逆向】安卓病毒介绍及其简单案例分析

【安卓逆向】安卓病毒介绍及其简单案例分析

目录 引言 一、Android 病毒介绍及分析方法 1.1 Android 病毒预览 1.2 Android 病毒分析必备知识 1.3 Android 病毒的常见类型及恶意行为 1.3.1 常见病毒类型 1.3.2 常见病毒行为 1.4 病毒激活条件 1.5 Android 病毒的传播方式 1.6 Android 病毒分析的一般方法 二…
阅读更多...
基于LabVIEW的脚本化子VI动态生成

基于LabVIEW的脚本化子VI动态生成

该示例展示了一种利用LabVIEW VI脚本&#xff08;VI Scripting&#xff09;技术&#xff0c;通过程序化方式动态生成并替换子VI的解决方案。核心逻辑为&#xff1a;基于预定义的模板VI&#xff0c;根据用户选择的数学操作&#xff08;加法或乘法&#xff09;&#xff0c;自动生…
阅读更多...
机器学习之超参数优化（Hyperparameter Optimization）

机器学习之超参数优化（Hyperparameter Optimization）

超参数优化（Hyperparameter Optimization） 1. 简介 在机器学习和深度学习中，超参数（Hyperparameters） 是在训练之前需要设定的参数，例如学习率（learning rate）、批量大小（batch size）、神经网络的层数等。与训练过程中自动学习的模型参数（如权重和偏置）不同，超参…
阅读更多...
Manus 演示案例：谷歌公司运营模拟器游戏体验

Manus 演示案例：谷歌公司运营模拟器游戏体验

一、项目背景与愿景 在科技行业蓬勃发展的当下&#xff0c;谷歌作为行业巨头&#xff0c;其成长历程充满了无数值得深入探究的决策智慧。这些决策不仅塑造了谷歌的辉煌&#xff0c;也为全球企业的发展提供了宝贵的借鉴。本项目旨在打造一款以谷歌公司发展为蓝本的运营模拟器游戏…
阅读更多...
es-索引详解

es-索引详解

在 Elasticsearch 中&#xff0c;**索引&#xff08;Index&#xff09;**是核心概念之一&#xff0c;类似于关系型数据库中的“表”。索引用于存储、组织和检索文档&#xff08;Document&#xff09;。以下是关于 Elasticsearch 索引的详细解析&#xff1a; 1. 索引的基本概念 …
阅读更多...
基于策略模式的智能提示语生成器设计与实现——以Tkinter GUI开发为例

基于策略模式的智能提示语生成器设计与实现——以Tkinter GUI开发为例

基于策略模式的智能提示语生成器设计与实现——以Tkinter GUI开发为例 一、引言&#xff1a;智能化时代的提示工程工具 在人工智能技术广泛应用的时代背景下&#xff0c;如何与AI模型进行有效交互已成为关键技能。本文介绍的"AI任务需求与提示语策略生成器"正是基于…
阅读更多...
01 | Go 项目开发极速入门课介绍

01 | Go 项目开发极速入门课介绍

提示&#xff1a; 所有体系课见专栏&#xff1a;Go 项目开发极速入门实战课。 你好&#xff0c;欢迎学习本课程。本课程是一个 Go 项目开发极速入门课程。旨在帮助刚学习完 Go 基础语法的 Go 开发者&#xff0c;快速掌握如何开发一个功能相对全面的 Go 项目。 根据课程设计目标…
阅读更多...
密闭空间可燃气体监测终端：守护城市命脉，智驭燃气安全！

密闭空间可燃气体监测终端：守护城市命脉，智驭燃气安全！

近年来&#xff0c;陕西省高度重视燃气安全&#xff0c;出台了一系列政策文件&#xff0c;旨在全面加强城镇燃气安全监管&#xff0c;防范化解重大安全风险。2023年&#xff0c;陕西省安委会印发《全省城镇燃气安全专项整治工作方案》&#xff0c;明确要求聚焦燃气经营、输送配…
阅读更多...
大白话react第十八章React 与 WebGL 项目的高级拓展与优化

大白话react第十八章React 与 WebGL 项目的高级拓展与优化

大白话react第十八章React 与 WebGL 项目的高级拓展与优化 1. 实现 3D 模型的导入与动画 在之前的基础上&#xff0c;我们可以导入更复杂的 3D 模型&#xff0c;并且让这些模型动起来&#xff0c;就像在游戏里看到的角色和场景一样。这里我们使用 GLTF 格式的模型&#xff0c…
阅读更多...
有关Java中的多线程

有关Java中的多线程

学习目标 ● 掌握线程相关概念 ● 掌握线程的基本使用 ● 掌握线程池的使用 ● 了解解决线程安全方式 1.为什么要学习线程? ● 从1946年2月14日世界上第一台计算机在美国宾夕法尼亚大学诞生到今天&#xff0c;计算和处理的模式早已从单用户单任务的串行模式发展到了多用户多…
阅读更多...
Spring Boot集成EasyExcel

Spring Boot集成EasyExcel

1. 初始化Spring Boot项目 首先&#xff0c;使用Spring Initializr&#xff08;https://start.spring.io/&#xff09;生成一个基本的Spring Boot项目。选择以下依赖项&#xff1a; Spring WebLombok (用于减少样板代码)SLF4J (用于日志记录) 2. 添加依赖 在你的pom.xml文件…
阅读更多...
（2025|ICLR|厦大华为，LoSA，基于表示互信息的动态层级稀疏率，基于重构误差的秩分配）LLM 的动态低秩稀疏自适应

（2025|ICLR|厦大华为，LoSA，基于表示互信息的动态层级稀疏率，基于重构误差的秩分配）LLM 的动态低秩稀疏自适应

Dynamic Low-Rank Sparse Adaptation for Large Language Models 目录 1. 引言 1.1 关键词 2. 方法 2.1 预备知识 2.2 层级稀疏率确定 2.3 稀疏感知的秩分配 2.4 动态稀疏与适配 3. 实验 3.1 实验设置 3.2 语言建模 3.3 零样本任务 3.4 N:M 稀疏性 3.5 消融实验 …
阅读更多...
p5.js：sound（音乐）可视化，动画显示音频高低变化

p5.js：sound（音乐）可视化，动画显示音频高低变化

本文通过4个案例介绍了使用 p5.js 进行音乐可视化的实践&#xff0c;包括将音频振幅转化为图形、生成波形图。 承上一篇&#xff1a;vite&#xff1a;初学 p5.js demo 画圆圈 cd p5-demo copy .\node_modules\p5\lib\p5.min.js . copy .\node_modules\p5\lib\addons\p5.soun…
阅读更多...
linux 进程和计划管理

linux 进程和计划管理

查看进程 在Linux系统中&#xff0c;有多个命令可以用来查看进程 以下是一些常用的命令&#xff1a; ps命令&#xff1a;用于查看当前系统中的进程状态。 基本用法&#xff1a;ps -ef&#xff0c;该命令会以完整格式显示所有进程的详细信息&#xff0c;包括用户ID、进程ID、父…
阅读更多...
DeepSeek 多模态大模型 Janus-Pro 本地部署教程

DeepSeek 多模态大模型 Janus-Pro 本地部署教程

下载模型仓库 git clone https://github.com/deepseek-ai/Janus.git 国内下载仓库失败时&#xff0c;可以使用以下代理&#xff1a; git clone https://github.moeyy.xyz/https://github.com/deepseek-ai/Janus.git 准备 Conda 3.12 虚拟环境 conda create --name deepseek7B p…
阅读更多...
Qt开源控件库（qt-material-widgets）的编译及使用

Qt开源控件库（qt-material-widgets）的编译及使用

项目简介 qt-material-widgets是一个基于 Qt 小部件的 Material Design 规范实现。 项目地址 项目地址&#xff1a;qt-material-widgets 本地构建环境 Win11 家庭中文版 VS2019 Qt5.15.2 (MSVC2019) 本地构建流程 克隆后的目录结构如图&#xff1a; 直接使用Qt Crea…
阅读更多...
ARM 嵌入式处理器内核与架构深度剖析(2)： ARM 处理器架构剖析

ARM 嵌入式处理器内核与架构深度剖析(2)： ARM 处理器架构剖析

目录 一、ARM处理器架构剖析 1.1. 指令集架构&#xff08;ISA&#xff09; 1.2. 寄存器集 1.3. 存储模型 1.4. 异常模型 二、架构设计精要 2.1 处理器模式与特权分级 2.2 寄存器银行化技术 2.3 指令集演化 三、微架构核心技术 3.1 流水线创新 3.2 内存子系统 3.3 …
阅读更多...
Flutter 按钮组件 TextButton 详解

Flutter 按钮组件 TextButton 详解

目录 1. 引言 2. TextButton 的基本用法 3. 主要属性 4. 自定义按钮样式 4.1 修改文本颜色 4.2 添加背景色 4.3 修改按钮形状和边距 4.4 样式定制 5. 高级应用技巧 5.1 图标文本组合 5.2 主题统一配置 5.3 动态交互 6. 性能优化与注意事项 6.1 点击区域优化 6.…
阅读更多...
std::ranges::views::split, lazy_split, std::ranges::split_view, lazy_split_view

std::ranges::views::split, lazy_split, std::ranges::split_view, lazy_split_view

std::ranges::views::split, std::ranges::split_view C20 中引入的用于分割范围&#xff08;range&#xff09;的组件&#xff0c;允许将输入范围按特定分隔符或条件分割成多个子范围。以下是详细说明和示例&#xff1a; 基本概念 1. 功能 分割范围&#xff1a;将输入范围&…
阅读更多...
c++ constraints与concepts使用笔记

c++ constraints与concepts使用笔记

c constraints与concepts使用笔记 1. 模板参数缺乏约束的问题2. Concepts 基本概念3. Concept 的定义与使用4. requires 表达式详解5. requires 从句 vs requires 表达式完整示例&#xff1a;约束矩阵运算 1. 模板参数缺乏约束的问题 问题分析&#xff1a; 传统模板参数没有语…
阅读更多...
最新文章

Copyright @ 2022~2023