Amoeba for MySQL 位于Client、Database Server(s)之間,具有負(fù)載均衡、高可用性、sql過濾、可承受高并發(fā)、讀寫分離、Query Route(解析sql query語句,并且根據(jù)條件與預(yù)先設(shè)定的規(guī)則,請求到指定的目標(biāo)數(shù)據(jù)庫。可并發(fā)請求多臺數(shù)據(jù)庫合并結(jié)果)、對客戶端透明,能降低數(shù)據(jù)切分帶來的復(fù)雜多數(shù)據(jù)庫結(jié)構(gòu)、數(shù)據(jù)切分規(guī)則給應(yīng)用帶來的影響。適用mysql 4.1或者以上版本(mysql 協(xié)議版本:10)暫時不支持事務(wù)、DDL語句目前只會分配給默認(rèn)的數(shù)據(jù)庫執(zhí)行,運行環(huán)境至少需要運行 mysql 4.1以上服務(wù), Java 1.5或以上版本。
Amoeba與mysql proxy存在一些區(qū)別。在mysql proxy上面如果想要讀寫分離并且讀集群、寫集群機器比較多情況下,用mysql proxy 需要自己寫一個LUA腳本,目前mysql proxy沒有現(xiàn)成的比較好的lua腳本。amoeba只需要進行相關(guān)的配置就可以滿足需求。
一、Mysql Master/Slave 結(jié)構(gòu)之下的讀寫分離:
Master: serverM (主庫,接收寫操作)
slaves:serverA、serverB、serverC(3個輔庫,只讀操作)
amoeba提供讀寫分離pool相關(guān)配置,可配置serverA、serverB、serverC形成一個虛擬的virtualSlave,該配置提供LB,failover/failbackup功能.
<dbServer name="virtualSlave" virtual="true">
<poolConfig>
<className>com.meidusa.amoeba.server.MultipleServerPool</className>
<!-- 負(fù)載均衡參數(shù) 1=ROUNDROBIN , 2=WEIGHTBASED -->
<property name="loadbalance">1</property>
<!-- 參與該pool負(fù)載均衡的poolName列表以逗號分割 -->
<property name="poolNames">serverA,serverB,serverC</property>
</poolConfig>
</dbServer>
<dbServer name="virtualSlave" virtual="true">
<poolConfig>
<className>com.meidusa.amoeba.server.MultipleServerPool</className>
<!-- 負(fù)載均衡參數(shù) 1=ROUNDROBIN , 2=WEIGHTBASED -->
<property name="loadbalance">1</property>
<!-- 參與該pool負(fù)載均衡的poolName列表以逗號分割 -->
<property name="poolNames">serverA,serverB,serverC</property>
</poolConfig>
</dbServer>
如果不啟用數(shù)據(jù)切分功能,那么只需要配置QueryRouter屬性
wirtePool=serverM
readPool=virtualSlave
<queryRouter>
<className>com.meidusa.amoeba.mysql.parser.MysqlQueryRouter</className>
<property name="LRUMapSize">1500</property>
<property name="defaultPool">serverM</property>
<property name="writePool">serverM</property>
<property name="readPool">virtualSlave</property>
<property name="needParse">true</property>
</queryRouter>
<queryRouter>
<className>com.meidusa.amoeba.mysql.parser.MysqlQueryRouter</className>
<property name="LRUMapSize">1500</property>
<property name="defaultPool">serverM</property>
<property name="writePool">serverM</property>
<property name="readPool">virtualSlave</property>
<property name="needParse">true</property>
</queryRouter>
client發(fā)送過來的update/insert/delete語句被發(fā)送到wirtePool,將select語句發(fā)送到readPool機器執(zhí)行。
二、數(shù)據(jù)切分方面:
這方面amoeba顯然也很容易,舉個數(shù)據(jù)切分例子:
select * from user_event where user_id='test' and gmt_create between Sysdate() -1 and Sysdate()
如果根據(jù)gmt_create 時間進行數(shù)據(jù)切分,比如6個月進行切分一次,amoeba提供利用類似sql表達式進行數(shù)據(jù)切分:
規(guī)則1:GMT_CREATE > to_date('2008-01-01','yyyy-mm-dd') and GMT_CREATE < to_date('2008-05-31','yyyy-mm-dd')
規(guī)則1對應(yīng)服務(wù)器1
規(guī)則2:GMT_CREATE > to_date('2008-06-01','yyyy-mm-dd') and GMT_CREATE < to_date('2008-12-31','yyyy-mm-dd')
規(guī)則2對應(yīng)服務(wù)器2
上面的sql的條件 gmt_create 與規(guī)則里面的的gmt_create 進行交集判斷,如果存在交集則表示符合規(guī)則,則會將sql轉(zhuǎn)移到 規(guī)則1 的相應(yīng)的服務(wù)器上面執(zhí)行。
利用amoeba寫出這種類似規(guī)則很容易,但是要想做到數(shù)據(jù)切分以后可線性擴容,那么這樣的規(guī)則需要自己根據(jù)業(yè)務(wù)實際情況進行設(shè)置。amoeba可同時將 sql并發(fā)分發(fā)到多臺服務(wù)器、然后將結(jié)果合并再反饋給客戶端,而且amoeba內(nèi)部采用無阻塞模式,工作線程是不會等待的,并發(fā)請求多臺 database server情況下,客戶端等待的時間基本上面是性能最差的那臺database server+amoeba內(nèi)部解析協(xié)議時間。
中文文檔地址: http://amoeba.sourceforge.net/amoeba.pdf
amoeba 未來發(fā)展方向: http://amoeba.sourceforge.net/amoeba-big-picture.pdf
文件下載: http://www.sourceforge.net/projects/amoeba
amoeba 開發(fā)者博客: http://amoeba.meidusa.com