摘要 :
文章目录 1. 什么是MyCat 2. 主要作用 3. MyCAT的基本元素 4. 安装MyCAT 下载命令 安装1.8jdk环境 mycat环境配置步骤 server.xml配置 schema.xml配置 总结 本文主要……
文
章
目
录
- 1. 什么是MyCat
- 2. 主要作用
- 3. MyCAT的基本元素
- 4. 安装MyCAT
- 下载命令
- 安装1.8jdk环境
- mycat环境配置步骤
- server.xml配置
- schema.xml配置
- 总结
本文主要讲解如何安装MyCat并管理MySQL集群，让我们来一起学习下吧！
1. 什么是MyCat
MyCat是一个彻底开源的，面向企业应用开发的大数据库集群。它是一个实现了MySQL协议的服务器，前端用户可以把它看作是一个数据库代理，用MySQL客户端工具和命令行访问，而其后端可以用MySQL原生协议与多个MySQL服务器通信，也可以用JDBC协议与大多数主流数据库服务器通信，其核心功能是分表分库，即将一个大表水平分割为N个小表，存储在后端MySQL服务器里或者其他数据库里。
2. 主要作用
- 作为分布式数据库中间层使用
- 实现后端数据库的读写分离及负载均衡
- 对业务数据库进行垂直切分
- 对业务数据库进行水平切分
- 控制数据库连接的数量
3. MyCAT的基本元素
逻辑库
- 对应用来说相当于MySQL中的数据库
- 逻辑库可对应后端多个物理数据库
- 逻辑库中并不保存数据
逻辑表的类别
- 分片表与非分片表按是否被分片划分
- 全局表，在所有分片中都存在的表
- ER关系表，按ER关系进行分片的表
4. 安装MyCAT
下载命令
大家可以试试，不过写这篇的时候网站已经挂了
wget http://dl.mycat.io/1.6.5/Mycat-server-1.6.5-release-20180122220033-linux.tar.gz
wget http://dl.mycat.org.cn/1.6.7.6/20201104174609/Mycat-server-1.6.7.6-test-20201104174609-linux.tar.gz
如果上面的指令不行，可以从github下载mycat地址或者国内其它地址下载
安装1.8jdk环境
yum install java-1.8.0-openjdk* -y
mycat环境配置步骤
# 把mycat移动到/usr/local
mv mycat/ /usr/local/
#创建新的用户mycat
adduser mycat
#修改mycat文件夹只能mycat用户使用
chown mycat:mycat -R mycat/
#修改config目录下的wrapper.conf
vi wrapper.conf
#根据自身服务器的内存大小进行修改
wrapper.java.additional.4=-XX:MaxDirectMemorySize=1G
#修改服务器环境变量
vim /etc/profile
export PATH=$PATH:/usr/local/mycat/bin
export JAVA_HOME=/usr/bin/java
export CLASSPATH=.:$JAVA_HOME/jre/lib/rt.jar:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export MyCAT_HOME=/usr/local/mycat
#更新配置
source /etc/profile
#使用mycat命令启动
mycat start
#使用mycat命令关闭
mycat stop
修改conf目录中两个文件server.xml、schema.xml
注意这里的配置基于上文《Docker如何搭建双主四从MySQL集群》演示相关配置，大家可以作为参考即可！
server.xml配置
<?xml version=\"1.0\" encoding=\"UTF-8\"?>
<!-- - - Licensed under the Apache License, Version 2.0 (the \"License\");
- you may not use this file except in compliance with the License. - You
may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0
- - Unless required by applicable law or agreed to in writing, software -
distributed under the License is distributed on an \"AS IS\" BASIS, - WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the
License for the specific language governing permissions and - limitations
under the License. -->
<!DOCTYPE mycat:server SYSTEM \"server.dtd\">
<mycat:server xmlns:mycat=\"http://io.mycat/\">
<system>
<property name=\"nonePasswordLogin\">0</property> <!-- 0为需要密码登陆、1为不需要密码登陆 ,默认为0，设置为1则需要指定默认账户-->
<property name=\"ignoreUnknownCommand\">0</property><!-- 0遇上没有实现的报文(Unknown command:),就会报错、1为忽略该报文，返回ok报文。
在某些mysql客户端存在客户端已经登录的时候还会继续发送登录报文,mycat会报错,该设置可以绕过这个错误-->
<property name=\"useHandshakeV10\">1</property>
<property name=\"removeGraveAccent\">1</property>
<property name=\"useSqlStat\">0</property> <!-- 1为开启实时统计、0为关闭 -->
<property name=\"useGlobleTableCheck\">0</property> <!-- 1为开启全加班一致性检测、0为关闭 -->
<property name=\"sqlExecuteTimeout\">300</property> <!-- SQL 执行超时 单位:秒-->
<property name=\"sequenceHandlerType\">1</property>
<!--<property name=\"sequnceHandlerPattern\">(?:(\\s*next\\s+value\\s+for\\s*MYCATSEQ_(\\w+))(,|\\)|\\s)*)+</property>
INSERT INTO `travelrecord` (`id`,user_id) VALUES (\'next value for MYCATSEQ_GLOBAL\',\"xxx\");
-->
<!--必须带有MYCATSEQ_或者 mycatseq_进入序列匹配流程 注意MYCATSEQ_有空格的情况-->
<property name=\"sequnceHandlerPattern\">(?:(\\s*next\\s+value\\s+for\\s*MYCATSEQ_(\\w+))(,|\\)|\\s)*)+</property>
<property name=\"subqueryRelationshipCheck\">false</property> <!-- 子查询中存在关联查询的情况下,检查关联字段中是否有分片字段 .默认 false -->
<property name=\"sequenceHanlderClass\">io.mycat.route.sequence.handler.HttpIncrSequenceHandler</property>
<!-- <property name=\"useCompression\">1</property>--> <!--1为开启mysql压缩协议-->
<!-- <property name=\"fakeMySQLVersion\">5.6.20</property>--> <!--设置模拟的MySQL版本号-->
<!-- <property name=\"processorBufferChunk\">40960</property> -->
<!--
<property name=\"processors\">1</property>
<property name=\"processorExecutor\">32</property>
-->
<!--默认为type 0: DirectByteBufferPool | type 1 ByteBufferArena | type 2 NettyBufferPool -->
<property name=\"processorBufferPoolType\">0</property>
<!--默认是65535 64K 用于sql解析时最大文本长度 -->
<!--<property name=\"maxStringLiteralLength\">65535</property>-->
<!--<property name=\"sequenceHandlerType\">0</property>-->
<!--<property name=\"backSocketNoDelay\">1</property>-->
<!--<property name=\"frontSocketNoDelay\">1</property>-->
<!--<property name=\"processorExecutor\">16</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=\"dataNodeIdleCheckPeriod\">300000</property> 5 * 60 * 1000L; //连接空闲检查
<property name=\"frontWriteQueueSize\">4096</property> <property name=\"processors\">32</property> -->
<!--分布式事务开关，0为不过滤分布式事务，1为过滤分布式事务（如果分布式事务内只涉及全局表，则不过滤），2为不过滤分布式事务,但是记录分布式事务日志-->
<property name=\"handleDistributedTransactions\">0</property>
<!--
off heap for merge/order/group/limit 1开启 0关闭
-->
<property name=\"useOffHeapForMerge\">0</property>
<!--
单位为m
-->
<property name=\"memoryPageSize\">64k</property>
<!--
单位为k
-->
<property name=\"spillsFileBufferSize\">1k</property>
<property name=\"useStreamOutput\">0</property>
<!--
单位为m
-->
<property name=\"systemReserveMemorySize\">384m</property>
<!--是否采用zookeeper协调切换 -->
<property name=\"useZKSwitch\">false</property>
<!-- XA Recovery Log日志路径 -->
<!--<property name=\"XARecoveryLogBaseDir\">./</property>-->
<!-- XA Recovery Log日志名称 -->
<!--<property name=\"XARecoveryLogBaseName\">tmlog</property>-->
<!--如果为 true的话 严格遵守隔离级别,不会在仅仅只有select语句的时候在事务中切换连接-->
<property name=\"strictTxIsolation\">false</property>
<!--如果为0的话,涉及多个DataNode的catlet任务不会跨线程执行-->
<property name=\"parallExecute\">0</property>
</system>
<!-- 全局SQL防火墙设置 -->
<!--白名单可以使用通配符%或着*-->
<!--例如<host host=\"127.0.0.*\" user=\"root\"/>-->
<!--例如<host host=\"127.0.*\" user=\"root\"/>-->
<!--例如<host host=\"127.*\" user=\"root\"/>-->
<!--例如<host host=\"1*7.*\" user=\"root\"/>-->
<!--这些配置情况下对于127.0.0.1都能以root账户登录-->
<!--
<firewall>
<whitehost>
<host host=\"1*7.0.0.*\" user=\"root\"/>
</whitehost>
<blacklist check=\"false\">
</blacklist>
</firewall>
-->
<user name=\"root\" defaultAccount=\"true\">
<property name=\"password\">abc123456</property>
<property name=\"schemas\">shop</property>
<property name=\"defaultSchema\">shop</property>
<!--No MyCAT Database selected 错误前会尝试使用该schema作为schema，不设置则为null,报错 -->
<!-- 表级 DML 权限设置 -->
<!--
<privileges check=\"false\">
<schema name=\"TESTDB\" dml=\"0110\" >
<table name=\"tb01\" dml=\"0000\"></table>
<table name=\"tb02\" dml=\"1111\"></table>
</schema>
</privileges>
-->
</user>
<!--
<user name=\"user\">
<property name=\"password\">user</property>
<property name=\"schemas\">TESTDB</property>
<property name=\"readOnly\">true</property>
<property name=\"defaultSchema\">TESTDB</property>
</user>
-->
</mycat:server>
schema.xml配置
<?xml version=\"1.0\"?>
<!DOCTYPE mycat:schema SYSTEM \"schema.dtd\">
<mycat:schema xmlns:mycat=\"http://io.mycat/\">
<schema name=\"shop\" checkSQLschema=\"true\" sqlMaxLimit=\"100\" randomDataNode=\"dn1\">
<table name=\"product_info\" primaryKey=\"id\" dataNode=\"dn1\" type=\"global\" />
</schema>
<dataNode name=\"dn1\" dataHost=\"ds_1\" database=\"shop\" />
<dataHost name=\"ds_1\" maxCon=\"1000\" minCon=\"10\" balance=\"1\"
writeType=\"0\" dbType=\"mysql\" dbDriver=\"native\" switchType=\"1\" slaveThreshold=\"100\">
<heartbeat>select 1</heartbeat>
<writeHost host=\"w1\" url=\"172.19.0.2:3306\" user=\"root\" password=\"abc123456\">
<readHost host=\"w1r1\" url=\"172.19.0.3:3306\" user=\"root\" password=\"abc123456\" />
<readHost host=\"w1r1\" url=\"172.19.0.4:3306\" user=\"root\" password=\"abc123456\" />
</writeHost>
<writeHost host=\"w2\" url=\"172.19.0.5:3306\" user=\"root\" password=\"abc123456\">
<readHost host=\"w2r1\" url=\"172.19.0.6:3306\" user=\"root\" password=\"abc123456\" />
<readHost host=\"w2r1\" url=\"172.19.0.7:3306\" user=\"root\" password=\"abc123456\" />
</writeHost>
</dataHost>
</mycat:schema>
最后再次启动后使用数据库图形工具连接8066端口的数据库即可。
总结
以上就是如何安装MyCat并管理MySQL集群的全部内容，希望对你有帮助。欢迎持续关注潘子夜个人博客，学习愉快哦！
还没有评论呢，快来抢沙发~