在Master/Slave结构下的读写分离

首先说明一下amoeba 跟 MySQL proxy在读写分离的使用上面的区别:

在MySQL proxy 6.0版本 上面如果想要读写分离并且 读集群、写集群 机器比较多情况下,用mysql proxy 需要相当大的工作量,目前mysql proxy没有现成的 lua脚本。mysql proxy根本没有配置文件, lua脚本就是它的全部,当然lua是相当方便的。那么同样这种东西需要编写大量的脚本才能完成一 个复杂的配置。而Amoeba只需要进行相关的配置就可以满足需求。

假设有这样的使用场景,有三个数据库节点分别命名为Master、Slave1、Slave2如下:

Master: Master (可读写)

Slaves:Slave1、Slave2 (2个平等的数据库。只读/负载均衡)

针对这样的使用方式,首先在dbServers.xml中将Slave1和Slave2配置在一个虚拟的dbServer节点中,使他们组成一个数据库池。

Example 4.3. 数据库池在dbServers.xml的定义与配置

<?xml version="1.0" encoding="gbk"?>

<!DOCTYPE amoeba:dbServers SYSTEM "dbserver.dtd">
<amoeba:dbServers xmlns:amoeba="http://amoeba.meidusa.com/">
...
 <dbServer name="Master"  parent="abstractServer">1
  <factoryConfig>
   <!-- mysql ip -->
   <property name="ipAddress">192.168.0.1</property>
  </factoryConfig>
 </dbServer>
 
 <dbServer name="Slave1"  parent="abstractServer">2
  <factoryConfig>
   <!-- mysql ip -->
   <property name="ipAddress">192.168.0.2</property>
  </factoryConfig>
 </dbServer>

 <dbServer name="Slave2"  parent="abstractServer">3
  <factoryConfig>
   <!-- mysql ip -->
   <property name="ipAddress">192.168.0.3</property>
  </factoryConfig>
 </dbServer>
  
 <dbServer name="virtualSlave" virtual="true">4
  <poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">
   <!-- Load balancing strategy: 1=ROUNDROBIN , 2=WEIGHTBASED , 3=HA-->
   <property name="loadbalance">1</property>5
   
   <!-- Separated by commas,such as: server1,server2,server1 -->
   <property name="poolNames">Slave1,Slave2</property>6
  </poolConfig>
 </dbServer>
...
</amoeba:dbServers>

1

定义了Master节点,parent为abstractServer,关于abstractServer的定义方式参照第三章。

2 3

定义了Slave1和Slave2节点。

4

定义了virtualSlave的虚拟节点,这是由Slave1和Slave2组成的一个数据库池。

5

loadbalance元素设置了loadbalance策略的选项,这里选择第一个“ROUNDROBIN”轮询策略,该配置提供负载均衡、failOver、故障恢复功能。

6

poolNames定义了其中的数据库节点配置(当然也可以是虚拟的节点)。此外对于轮询策略,poolNames还定义了其轮询规则,比如设置成“Slave1,Slave1,Slave2”那么Amoeba将会以两次Slave1,一次Slave2的顺序循环对这些数据库节点转发请求。


如果不需要配置规则那么可以不使用rule.xml而直接配置amoeba.xml中的queryRouter,配置如下:

Example 4.4. 配置amoeba.xml不使用切分功能直接配置queryRouter以读写分离

<?xml version="1.0" encoding="gbk"?>

<!DOCTYPE amoeba:configuration SYSTEM "amoeba.dtd">
<amoeba:configuration xmlns:amoeba="http://amoeba.meidusa.com/">
...
<queryRouter class=”com.meidusa.amoeba.mysql.parser.MysqlQueryRouter”>  
   <property name="LRUMapSize">1500</property>1
   <property name="defaultPool">Master</property>2  
   <property name="writePool">Master</property>3
   <property name="readPool">virtualSlave</property>4
   <property name="needParse">true</property>  
</queryRouter>  
...
</amoeba:configuration>

1

LRUMapSize属性定义了Amoeba缓存的SQL语句解析的条数。

2

defaultPool配置了默认的数据库节点,一些除了SELECT\UPDATE\INSERT\DELETE的语句都会在defaultPool执行。

3

writePool配置了数据库写库,通常配为Master,如这里就配置为之前定义的Master数据库。

4

readPool配置了数据库读库,通常配为Slave或者Slave组成的数据库池,如这里就配置之前的virtualSlave数据库池。


当同时需要配置切分规则以及读写分离时,这里以本章节的“基于Amoeba的数据水平切分”小节的场景与本小节的场景合并可以使用这样的配置方法:

Example 4.5. 通过使用isReadStatement在rule.xml配置中指定读库和写库

<?xml version="1.0" encoding="gbk"?>
<!DOCTYPE amoeba:rule SYSTEM "rule.dtd">

<amoeba:rule xmlns:amoeba="http://amoeba.meidusa.com/">
...
   <tableRule name="MESSAGE" schema="test" defaultPools="blogdb-1-write,blogdb-2-write">
      <rule name="rule1" ruleResult="POOLNAME">1
         <parameters>ID</parameters>
         <expression><![CDATA[
           var hashid = abs(hash(id)) mod 2;
           case hashid when 0 then (isReadStatement?'blogdb-1-read':'blogdb-1-write');2
                       when 1 then (isReadStatement?'blogdb-2-read':'blogdb-2-write');
         ]]></expression>
         <defaultPools>blogdb-1</defaultPools>
      </rule>
   </tableRule>
...
</amoeba:rule>

1

这里的规则配置设置ruleResult为“POOLNAME”这意味着操作的数据库节点名称是由expression的返回结果得到的。

2

这里使用了isReadStatement来确定操作语句是读语句还是写语句,在这个例子中,读语句会路由到blogdb-1-read数据库节点,而写语句会路由到blogdb-1-write数据库节点。这里blogdb-1-read等几个数据库节点都必须在dbServers.xml中配置。