MyCat
MyCAT是一款由阿里Cobar演变而来的用于支持数据库,读写分离、分表分库的分布式中间件MyCAT原理MyCAT主要是通过对SQL的拦截,然后经过一定规则的分片解析、路由分析、读写分离分析、缓存分析等,然后将SQL发给后端真实的数据块,并将返回的结果做适当处理返回给客户端
使用
- server.xml
<!-- 读写都可用的用户 --><user name="root" defaultAccount="true"> <property name="password">123</property> <property name="schemas">mycat_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">123</property> <property name="schemas">mycat_testdb</property> <property name="readOnly">true</property></user>
- schema.xml
<!-- TESTDB1 是mycat的逻辑库名称,链接需要用的 --> <schema name="mycat_testdb" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1"></schema> <!-- database 是MySQL数据库的库名 --> <dataNode name="dn1" dataHost="localhost1" database="test" /> <!-- dataNode节点中各属性说明: name:指定逻辑数据节点名称; dataHost:指定逻辑数据节点物理主机节点名称; database:指定物理主机节点上。如果一个节点上有多个库,可使用表达式db$0-99, 表示指定0-99这100个数据库; dataHost 节点中各属性说明: name:物理主机节点名称; maxCon:指定物理主机服务最大支持1000个连接; minCon:指定物理主机服务最小保持10个连接; writeType:指定写入类型; 0,只在writeHost节点写入; 1,在所有节点都写入。慎重开启,多节点写入顺序为默认写入根据配置顺序,第一个挂掉切换另一个; dbType:指定数据库类型; dbDriver:指定数据库驱动; balance:指定物理主机服务的负载模式。 0,不开启读写分离机制; 1,全部的readHost与stand by writeHost参与select语句的负载均衡,简单的说,当双主双从模式(M1->S1,M2->S2,并且M1与 M2互为主备),正常情况下,M2,S1,S2都参与select语句的负载均衡; 2,所有的readHost与writeHost都参与select语句的负载均衡,也就是说,当系统的写操作压力不大的情况下,所有主机都可以承担负载均衡;--> <dataHost name="localhost1" maxCon="1000" minCon="10" balance="3" writeType="0" dbType="mysql" dbDriver="native" switchType="1" slaveThreshold="100"> <heartbeat>select user()</heartbeat> <!-- 可以配置多个主从 --> <writeHost host="hostM1" url="192.168.182.131:3306" user="root" password="123"> <!-- 可以配置多个从库 --> <readHost host="hostS2" url="192.168.182.132:3306" user="root" password="123" /> </writeHost> </dataHost>
分片枚举
分片枚举算法就是根据不同的枚举(常量),分类存储。
- schema.xml
<schema name="mycat_testdb" checkSQLschema="false" sqlMaxLimit="100" dataNode="dn1"> <table name="order_info" dataNode="dn1,dn2,dn3" rule="role2" /> </schema><!-- database 是MySQL数据库的库名 --><dataNode name="dn1" dataHost="localhost1" database="db1" /><dataNode name="dn2" dataHost="localhost1" database="db2" /><dataNode name="dn3" dataHost="localhost1" database="db3" />
- rule.xml
<tableRule name="role2"> <rule> <columns>name</columns> <algorithm>hash-int</algorithm> </rule></tableRule><function name="hash-int" class="io.mycat.route.function.PartitionByFileMap"> <property name="mapFile">partition-hash-int.txt</property> <property name="type">1</property> <!-- 如果mapfile没有满足的条件,则使用节点 --> <property name="defaultNode">1</property></function>
- partition-hash-int.txt
wuhan=0shanghai=1suzhou=2
取模
使用根据ID对节点数量取余,得到存放节点这种方式数据库节点一开始就是固定的,如果节点数量发生变更,需要迁移数据rehash
查询原理
如果含有分片字段,则根据字段计算出数据所在DB,向DB发送查询请求并返回给客户端
否则向所有DB节点发送查询请求,汇总结果后拼接返回给客户端所以如果没有排序,会发现同样的条件查询,会有不同的顺序