飞天班第51节：数据切分设计方案Mycat-1

# 自定义一个mysql集群网络
[root@alibaba ~]# docker network create --subnet 172.18.0.0/16 --gateway 172.18.0.1 mysql-net

# mysql的配置文件挂载: /opt/mysql213/conf
# mysql的数据存储目录挂载: /opt/mysql213/data
# mysql的日志文件目录挂载: /opt/mysql213/logs
[root@alibaba mysql-slave]# docker run -d -p 3306:3306 
-v /opt/mysql213/conf:/etc/mysql/mysql.conf.d 
-v /opt/mysql213/data:/var/lib/mysql 
-v /opt/mysql213/logs:/var/log/mysql
--net mysql-net --ip 172.18.0.213
-e MYSQL_ROOT_PASSWORD=mysql123456 --name mysql213 mysql:5.7.30

# 再安装另一个mysql实例
[root@alibaba mysql-slave]# docker run -d -p 3307:3306 
-v /opt/mysql214/conf:/etc/mysql/mysql.conf.d 
-v /opt/mysql214/data:/var/lib/mysql 
-v /opt/mysql214/logs:/var/log/mysql
--net mysql-net --ip 172.18.0.214
-e MYSQL_ROOT_PASSWORD=mysql123456 --name mysql214 mysql:5.7.30

# 需要提前安装两个数据库：这两个数据库是独立，不能是主从关系
# 0.下载mycat
wget http://dl.mycat.org.cn/1.6.7.3/20190927161129/Mycat-server-1.6.7.3-release-20190927161129-linux.tar.gz
# 1、解压
tar -xvf Mycat-server-1.6.7.3-release-20190927161129-linux.tar.gz
# 2、Mycat依赖java,服务器要先安装好java环境

cd /opt/mycat/conf
vi server.xml

# mycat根目录下启动
[root@helloworld bin]# pwd
/opt/mycat/bin
[root@helloworld bin]# ./mycat --help
Usage: ./mycat { console | start | stop | restart | status | dump }
# 控制台输出
[root@helloworld bin]# ./mycat console

# 报错
jvm 1    | Caused by: io.mycat.config.util.ConfigException: Illegal table conf : table [ USER_INFO ] rule function [ rang-long ] partition size : 3 > table datanode size : 2, please make sure table datanode size = function partition size

[root@helloworld conf]# vim rule.xml 
# 找到这个规则 auto-sharding-long
# columns 物理表的列名，根据这个id列进行数据切分，分到不同的dataNode
# algorithm 分片策略 rang-long，范围long值
<tableRule name="auto-sharding-long">
	<rule>
	<columns>id</columns>
	<algorithm>rang-long</algorithm>
	</rule>
</tableRule>

# 在conf/rule.xml 搜索 rang-long，它是一个function,有一个属性文件autopartition-long.txt,里面就是一下策略的配置
<function name="rang-long"
	class="io.mycat.route.function.AutoPartitionByLong">
	<property name="mapFile">autopartition-long.txt</property>
</function>

# 修改策略配置
[root@helloworld conf]# vi autopartition-long.txt
# range start-end ,data node index
# K=1000,M=10000.
0-500M=0
500M-1000M=1
#1000M-1500M=2
# K=1000 (千),M=10000 （万）
# 需要根据dataNode设置节点数，0，1，2说明有三个节点，但实际上我们只陪配置dn213,dn214两个节点，所以只配0，1两个节点
# 按顺序，0就是dn213,1就是dn214

# 控制台输出
[root@helloworld bin]# ./mycat console

# id 0-500的数据分到分片0上，501-100的数据分到分片1上
[root@helloworld mycat]# vi conf/autopartition-long.txt 
0-500=0
500-1000=1
# 重启mycat
[root@helloworld mycat]# ./bin/mycat console

# 命令行连接-p 是密码，-P是端口，就像平常mysql数据库一样使用
[root@alibaba ~]# mysql -ujude -p -h139.199.13.139 -P8066
mysql> show databases;
+-------------+
| DATABASE    |
+-------------+
| user_module |
+-------------+
1 row in set (0.00 sec)
mysql> use user_module;
mysql> select * from user_info
    -> ;
+-----+----------+----------+
| id  | username | password |
+-----+----------+----------+
|   1 | arry     | 123456   |
| 500 | gavin    | 123456   |
| 501 | coding   | 123456   |
+-----+----------+----------+

<dataHost name="DB214" maxCon="1000" minCon="10" balance="0" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
# name：主机名，自己命名即可
# maxCon：最大连接
# minCon：最小链接
# dbDriver: native，不用自己配置数据库驱动类 

# balance：负载均衡策略，值有4个
# 1、balance="0"，不开启读写分离，所有的操作都在writeHost上操作
# 2、balance="1"，全部的readHost与stand by writeHost(第2个，第3个writehost)参与select数据的负载均衡
# 3、balance="2" 所有的读操作随机分发到全部writeHost和全部readHost
# 4、balance="3" 所有的读操作随机分发到readHost，全部writeHost不参与读操作
双主也需要我们自己进行replica，mycat平时只写入一个主机

# writeType 写数据类型
# 1、writeType="0"，所有写操作都会发送到配置的第一个writeHost，如果第一个挂了就会自动切到第二个writeHost配置上
# 2、writeType="1"，所有的写操作会随机到writeHost上，1.5版本后不推荐

# switchType 切换类型配套我我们的writeType来进行操作的
# -1 表示写操作不自动进行切换
# 1 默认值，自动切换，从第一个到第二个writeHost
# 2 基于MySQL的主从同步的状态决定是否切换，如果从库是延时复制的话那mycat就暂时切换，此writehost1挂了，就不能写入数据

<dataNode name="dn213" dataHost="DB213" database="user_213" />
# name:节点名
# dataHost：对应dataHost的名字
# database：是物理数据库的名称

<schema name="user_module" checkSQLschema="true" sqlMaxLimit="100">
		<table name="user_info" dataNode="dn213,dn214" rule="auto-sharding-long" />
</schema>
# name:在server配置里定义的逻辑库名
# checkSQLschema：如果是true会自动去掉数据库前缀
# sqlMaxLimit：为了减轻数据库压力，做的输出限制，默认限制100行
# sqlMaxLimit仅对分片表有效
# table name：物理表名
# rule就是分片规则

Usage: ./mycat { console | start | stop | restart | status | dump }

# 更改一些基本配置可以使用脚本操作
# 比如更改了limit就可以使用
reload @@config;
# 比如更新了数据源就需要通过config_all来进行操作了，但这里是更新所有配置，比较慢，需要多一点时间生效
reload @@config_all;

# 同样也可以通过命令行连接mycat管理端
[root@alibaba ~]# mysql -ujude -p -h139.199.13.139 -P9066

[root@alibaba mysql-slave]# docker run -d -p 3308:3306 
-v /opt/mysql211/conf:/etc/mysql/conf.d 
-v /opt/mysql211/data:/var/lib/mysql 
-v /opt/mysql211/logs:/var/log/mysql
--net mysql-net --ip 172.18.0.211
-e MYSQL_ROOT_PASSWORD=mysql123456 --name mysql211 mysql:5.7.30

# 注意要修改balance
# 1、balance="0"，不开启读写分离，所有的操作都在writeHost上操作
# 2、balance="1"，全部的readHost与stand by writeHost(第2个，第3个writehost)参与select数据的负载均衡
# 3、balance="2" 所有的读操作随机分发到全部writeHost和全部readHost
<dataHost name="DB213" maxCon="1000" minCon="10" balance="2" writeType="0" dbType="mysql" dbDriver="native" switchType="1"  slaveThreshold="100">
	<heartbeat>select user()</heartbeat>
	<!-- can have multi write hosts -->
	<writeHost host="M1" url="192.168.0.213:3306" user="gavin" password="123456">
		<readHost host="S1" url="192.168.0.211:3306" user="gavin" password="123456"/>
	</writeHost>	
</dataHost>

mysql> reload @@config_all

# 修改schema.xml
# balance 为1 会从readHost和satand by writeHost读取数据
<dataHost name="DB213" 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="M1" url="192.168.0.213:3306" user="gavin" password="123456">
	</writeHost>
	<writeHost host="M2" url="192.168.0.211:3306" user="gavin" password="123456"/> 
</dataHost>

# 重新加载所有配置，不用重启mycat
mysql> reload @@config_all

<dataHost name="DB213" 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="172.18.0.213:3306" user="root" password="mysql123456">
		<readHost host="S1" url="172.18.0.211:3306" user="root" password="mysql123456"/>
	</writeHost>
	<writeHost host="hostM2" url="172.18.0.217:3306" user="root" password="mysql123456">
		<readHost host="S2" url="172.18.0.215:3306" user="root" password="mysql123456"/>
	</writeHost>
</dataHost>