mycat读写分离

Mycat是数据库中间件，所谓数据库中间件是连接Java应用程序和数据库中间的软件。
		
			一个彻底开源的，面向企业应用开发的大数据库集群
			支持事务、ACID
			一个可以视为MySQL集群的中间件，用来替代昂贵的Oracle集群
			一个融合内存缓存技术、NoSQL技术、HDFS大数据的新型SQL调度服务
			满足数据库数据大量存储场景，提高查询性能

编译打包mycat(可以跳过)

安装maven
yum -y install maven
下载mycat源代码
wget https://github.com/MyCATApache/Mycat-Server/archive/refs/tags/1.6.76-release-2020-11-2.tar.gz
解压
tar zxvf 1.6.76-release-2020-11-2.tar.gz
打包
cd Mycat-Server-1.6.76-release-2020-11-2

mvn package -Dmaven.test.skip=true
打好的包移动到root目录下
cp target/Mycat-server-1.6.7.6-release-yyyymmddHHMMSS-linux.tar.gz /root/

准备工作

创建mycat要用到的MySQL账号
CREATE USER 'mycat'@'%' IDENTIFIED BY '123456';
授予账号权限，*.* 可以替换为具体的某个库，比如 db1.*
GRANT ALL PRIVILEGES ON *.* TO 'mycat'@'%';

安装使用mycat

配置Java环境
yum -y install java-1.8.0-openjdk
解压mycat包mycat包
tar -xzvf mycat-1.6.7.6-release-linux.tar.gz
将mycat移动到/usr/local目录下
mv mycat /usr/local/

编辑配置文件vim /usr/local/mycat/conf/schema.xml

<?xml version="1.0"?>
<!DOCTYPE mycat:schema SYSTEM "schema.dtd">
<mycat:schema xmlns:mycat="http://io.mycat/">
		<!-- name-逻辑库名，checkSQLschema-是否开启mycat对sql语句的检查，sqlMaxLimit-结果集的最大行数，超过会被mycat截掉 -->
		<!-- dataNode-指定数据节点，randomDataNode-配置该属性后，在没有指定数据节点的情况下，mycat将随机选择一个数据节点执行SQL -->
		<schema name="testdb" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1">
				<!-- auto sharding by id (long) -->
				<!-- splitTableNames 启用 name 属性使用逗号分割配置多个表,即多个表使用这个配置 -->
				<!-- fetchStoreNodeByJdbc 启用ER表使用JDBC方式获取DataNode -->
				<!-- <table name="customer" primaryKey="id" dataNode="dn1,dn2" rule="sharding-by-intfile" autoIncrement="true" fetchStoreNodeByJdbc="true">
						<childTable name="customer_addr" primaryKey="id" joinKey="customer_id" parentKey="id"> </childTable>
				</table> -->
				<!-- <table name="oc_call" primaryKey="ID" dataNode="dn1$0-743" rule="latest-month-calldate" /> -->
		</schema>
		<!-- name-数据节点名称，dataHost-指定数据库配置名称，database-真实的数据库名称 -->
		<dataNode name="dn1" dataHost="localhost1" database="db1" />
		<dataNode name="dn2" dataHost="localhost2" database="db2" />
		<dataNode name="dn3" dataHost="localhost3" database="db3" />
		<!-- name-数据库配置名称，maxCon-最大连接数，minCon-最小空闲连接数 -->
		<!-- balance-指定读操作的负载策略：0-不启用，所有读写发送到第一个writeHost； -->
		<!-- 1-启用读写分离，读从第一个writeHost下的所有readHost和所有可读的writeHost中随机选择一个 -->
		<!-- 2-启用读写分离，读从所有writeHost及其下面的所有readHost中随机选择一个 -->
		<!-- 3-启用读写分离，读从所有readHost中随机选择一个 -->
		<!-- writeType-指定写操作的负载策略：0-写发送到第一个writeHost，第一个宕机则发送到第二个；1-随机选择一个writeHost发送 -->
		<!-- dbType-指定数据库类型，可选：Mysql、Oracle、SQLServer等 -->
		<!-- dbDriver-指定连接数据库的驱动类 -->
		<!-- switchType-指定数据源的切换策略，-1表示不自动切换 -->
		<!-- 0-主机宕机时切换至可用从机，可能因数据同步延迟导致短暂服务异常 -->
		<!-- 1-所有主机宕机时切换至可用从机，适用于双主互备场景，切换后需要手动配置主从并同步不一致的数据 -->
		<!-- 2-基于延迟切换，心跳语句为show slave status;，通过检测Slave_IO_Running状态和Seconds_Behind_Master延迟值，自动选择数据最新的节点 -->
		<!-- 3-基于MySQL Galera Cluster(集群)的切换机制，心跳语句为show status like 'wsrep%'; -->
		<!-- slaveThreshold，从属延迟阈值，心跳检测语句为show status时，当同步延迟大于slaveThreshold值，mycat将不会读取该从库，防止读到旧数据 -->
		<dataHost name="localhost1" maxCon="1000" minCon="10" balance="1"
				writeType="0" dbType="mysql" dbDriver="jdbc" switchType="1" slaveThreshold="100">
				<!-- 指定心跳检测语句 -->
				<heartbeat>select user()</heartbeat>
				<!-- host-指定一个名字，url-数据库连接地址，user-数据库账号，password-数据库密码 -->
				<writeHost host="hostM1" url="jdbc:mysql://localhost:3306" user="mycat" password="123456">
						<readHost host="read1" url="jdbc:mysql://192.168.112.145:3306" user="mycat" password="123456" />
				</writeHost>
				<writeHost host="hostM2" url="jdbc:mysql://192.168.112.145:3306" user="mycat" password="123456" />
		</dataHost>
		
		<!-- 
		<dataHost name="sequoiadb1" maxCon="1000" minCon="1" balance="0" dbType="sequoiadb" dbDriver="jdbc">
				<heartbeat></heartbeat>
				<writeHost host="hostM1" url="sequoiadb://1426587161.dbaas.sequoialab.net:11920/SAMPLE" user="jifeng" password="jifeng"></writeHost>
		</dataHost>
		<dataHost name="oracle1" maxCon="1000" minCon="1" balance="0" writeType="0" dbType="oracle" dbDriver="jdbc">
				<heartbeat>select 1 from dual</heartbeat>
				<connectionInitSql>alter session set nls_date_format='yyyy-mm-dd hh24:mi:ss'</connectionInitSql>
				<writeHost host="hostM1" url="jdbc:oracle:thin:@127.0.0.1:1521:nange" user="base" password="123456"></writeHost>
		</dataHost>
		<dataHost name="jdbchost" maxCon="1000" minCon="1" balance="0" writeType="0" dbType="mongodb" dbDriver="jdbc">
				<heartbeat>select user()</heartbeat>
				<writeHost host="hostM" url="mongodb://192.168.0.99/test" user="admin" password="123456"></writeHost>
		</dataHost>
		<dataHost name="sparksql" maxCon="1000" minCon="1" balance="0" dbType="spark" dbDriver="jdbc">
				<heartbeat></heartbeat>
				<writeHost host="hostM1" url="jdbc:hive2://feng01:10000" user="jifeng" password="jifeng"></writeHost> 
		</dataHost>
		--> 
</mycat:schema>

编辑配置文件vim /usr/local/mycat/conf/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>
				<!-- 0为需要密码登陆、1为不需要密码登陆 ,默认为0，设置为1则需要指定默认账户 -->
				<property name="nonePasswordLogin">0</property>
				<!-- 0遇上没有实现的报文(Unknown command:),就会报错、1为忽略该报文，返回ok报文。
				在某些mysql客户端存在客户端已经登录的时候还会继续发送登录报文,mycat会报错,该设置可以绕过这个错误 -->
				<property name="ignoreUnknownCommand">0</property>
				<property name="useHandshakeV10">1</property>
				<property name="removeGraveAccent">1</property>
				<!-- 1为开启实时统计、0为关闭 -->
				<property name="useSqlStat">0</property>
				<!-- 1为开启全加班一致性检测、0为关闭 -->
				<property name="useGlobleTableCheck">0</property>
				<!-- SQL 执行超时 单位:秒-->
				<property name="sqlExecuteTimeout">300</property>
				<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>
				<!-- 子查询中存在关联查询的情况下,检查关联字段中是否有分片字段 .默认 false -->
				<property name="subqueryRelationshipCheck">false</property>
				<property name="sequenceHanlderClass">io.mycat.route.sequence.handler.HttpIncrSequenceHandler</property>
				<!-- 1为开启mysql压缩协议 -->
				<!-- <property name="useCompression">1</property> -->
				<!--设置模拟的MySQL版本号-->
				<!-- <property name="fakeMySQLVersion">8.0.43</property> -->
				<!-- <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>
				// 连接空闲检查,5 * 60 * 1000L
				<property name="dataNodeIdleCheckPeriod">300000</property>
				<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>
		-->
		<!-- No MyCAT Database selected 错误前会尝试使用该schema作为schema，不设置则为null,报错 -->
		<!-- <user name="root" defaultAccount="true">
				<property name="password">123456</property>
				<property name="schemas">TESTDB</property>
				<property name="defaultSchema">TESTDB</property> -->
				<!-- 表级 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">123456</property>
				<property name="schemas">testdb</property>
				<property name="readOnly">false</property>
				<property name="defaultSchema">testdb</property>
		</user>
</mycat:server>

创建日志目录
mkdir /usr/local/mycat/logs
启动mycat服务
/usr/local/mycat/bin/mycat start
查看日志
tail -10f /usr/local/mycat/logs/wrapper.log
连接mycat
mysql -h[本机IP] -P8066 -u mycat -p123456
查看数据源状态
show @@datasource;
查看心跳
show @@heartbeat;
查看sql执行情况
show @@sql;

show @@sql.execute;