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

2013-02-04 23:00 数据库狂奔的蜗牛

首先说明一下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>
	   
	   <property name="ipAddress">192.168.0.1</property>
	  </factoryConfig>
	 </dbServer>

<dbServer name="virtualSlave" virtual="true">4 <poolConfig class="com.meidusa.amoeba.server.MultipleServerPool">
	   
	   <property name="loadbalance">1</property>5 
	   <property name="poolNames">Slave1,Slave2</property>6 </poolConfig>
	 </dbServer>
	...
	</amoeba:dbServers>

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

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

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

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>

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

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

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

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>

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

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

作者：狂奔的蜗牛 出处： http://www.host900.com/

本文版权归作者所有，欢迎转载。未经作者同意下，必须在文章页面明显标出原文链接及作者，否则保留追究法律责任的权利。

如果您认为这篇文章还不错或者有所收获，可以分享给您的小伙伴，因为你的支持是我继续写作，分享的最大动力！

上一篇使用Amoeba for mysql实现mysql读写分离

下一篇discuz on amoeba 乱码问题解决