1、 安裝和運行Amoeba
1. Amoeba for MySQL 架構:
2. 驗證Java的安裝
Amoeba框架是基於Java SE1.5開發的,建議使用Java SE1.5以上的版本。
# java -version
java version "1.6.0_35"
Java(TM) SE Runtime Environment (build 1.6.0_35-b10)
Java HotSpot(TM) 64-Bit Server VM (build 20.10-b01, mixed mode)
注:JDK的安裝方法再也不闡述,不會的能夠參考:http://www.minunix.com/2013/05/install_tomcat/ 安裝JDK部分。
3. 安裝MySQL數據庫及配置主從複製部分此處再也不闡述,不會者可參考:http://www.minunix.com/2013/05/mysql-slave/。
4. 下載Amoeba
本例使用版本:amoeba-mysql-3.0.5-RC-distribution.zip
下載地址:http://pan.baidu.com/s/1fkno
5. 安裝Amoeba
把下載的壓縮包解壓完了以後放到 /usr/local/ 目錄下便可。
# mkdir /usr/local/amoeba
# unzip amoeba-mysql-3.0.5-RC-distribution.zip
# /bin/cp –rf amoeba-mysql-3.0.5-RC/* /usr/local/amoeba
2、 配置Amoeba for MySQL:
Amoeba for MySQL的使用是很簡單的,主要是經過xml文件來實現的。
1. 配置文件介紹:
(1.) dbServers.xml 想象Amoeba做爲數據庫代理層,它必定會和不少數據庫保持通訊,所以它必須知道由它代理的數據庫如何鏈接,好比最基礎的:主機IP、端口、Amoeba使用的用戶名和密碼等等。這些信息存儲在$AMOEBA_HOME/conf/dbServers.xml中。
(2.) rule.xml Amoeba爲了完成數據切分提供了完善的切分規則配置,爲了瞭解如何分片數據、如何將數據庫返回的數據整合,它必須知道切分規則。與切分規則相關的信息存儲在$AMOEBA_HOME/conf/rule.xml中。
(3.) functionMap.xml 當咱們書寫SQL來操做數據庫的時候,經常會用到不少不一樣的數據庫函數,好比:UNIX_TIMESTAMP()、SYSDATE()等等。這些函數如何被Amoeba解析呢?$AMOEBA_HOME/conf/functionMap.xml描述了函數名和函數處理的關係。
(4.) ruleFunctionMap.xml 對$AMOEBA_HOME/conf/rule.xml進行配置時,會用到一些咱們本身定義的函數,好比咱們須要對用戶ID求HASH值來切分數據,這些函數在$AMOEBA_HOME/conf/ruleFunctionMap.xml中定義。
(5.) access_list.conf Amoeba能夠制定一些可訪問以及拒絕訪問的主機IP地址,這部分配置在$AMOEBA_HOME/conf/access_list.conf中。
(6.) log4j.xml Amoeba容許用戶配置輸出日誌級別以及方式,配置方法使用log4j的文件格式,文件是$AMOEBA_HOME/conf/log4j.xml。
其中,咱們主要用到dbServer.xml 和 amoeba.xml 。
2. dbServer.xml 的配置:
<dbServer name=」abstractServer」 abstractive=」true」>
<factoryConfig class=」com.meidusa.amoeba.mysql.net.MysqlServerConnectionFactory」>
<property name=」connectionManager」>${defaultManager}</property>
<property name=」sendBufferSize」>64</property>
<property name=」receiveBufferSize」>128</property>
<!—mysql port --><!—代理鏈接數據庫使用的端口號-->
<property name=」port」>3306</property>
<!—mysql schema --><!—代理鏈接數據庫所使用的數據庫-->
<property name=」schema」>test</property>
<!—mysql user --><!—代理鏈接數據庫使用的用戶名-->
<property name=」user」>minunix</property>
<!—代理鏈接數據庫使用的密碼-->
<property name=」password」>minunix.com</property>
</factoryConfig>
<poolConfig class=」com.meidusa.toolkit.common.poolable.PoolableObjectPool」>
<property name=」maxActive」>500</property>
<property name=」maxIdle」>500</property>
<property name=」minIdle」>1</property>
<property name=」minEvictableIdleTimeMillis」>600000</property>
<property name=」timeBetweenEvictionRunsMillis」>600000</property>
<property name=」testOnBorrow」>true</property>
<property name=」testOnReturn」>true</property>
<property name=」testWhileIdle」>true</property>
</poolConfig>
</dbServer>
<!--- 配置真實的數據庫的地址-->
<!--- 配置主從服務器及服務器鏈接池-->
<dbServer name="server1" parent="abstractServer">
<factoryConfig>
<!-- mysql ip -->
<property name="ipAddress">192.168.0.162</property>
</factoryConfig>
</dbServer>
<dbServer name=」server2」 parent=」abstractServer」>
<factoryConfig>
<!—mysql ip -->
<property name=」ipAddress」>192.168.0.171</property>
</factoryConfig>
</dbServer>
<dbServer name=」multiPool」 virtual=」true」>
<poolConfig class=」com.meidusa.amoeba.server.MultipleServerPool」>
<!—Load balancing strategy: 1=ROUNDROBIN , 2=WEIGHTBASED , 3=HA-->
<property name=」loadbalance」>1</property>
<!—Separated by commas,such as: server1,server2,server1 -->
<property name=」poolNames」>server1,server2</property>
</poolConfig>
</dbServer>
3. amoeba.xml 配置:
客戶端鏈接Amoeba時所綁定的IP地址、端口、用戶名和密碼。及IP訪問限制。
<service name="Amoeba for Mysql" >
<!-- port -->
<property name="port">8066</property>
<!-- bind ipAddress -->
<!--
<property name="ipAddress">127.0.0.1</property>
-->
<property name="connectionFactory">
<bean >
<property name="sendBufferSize">128</property>
<property name="receiveBufferSize">64</property>
</bean>
</property>
<property name="authenticateProvider">
<bean >
<property name="user">root</property>
<property name="password">minunix</property>
<property name="filter">
<bean>
<property name="ipFile">${amoeba.home}/conf/access_list.conf</property>
</bean>
</property>
</bean>
</property>
</service>
如下內容是定義讀寫分離:
<queryRouter >
<property name="ruleLoader">
<bean >
<property name="ruleFile">${amoeba.home}/conf/rule.xml</property>
<property name="functionFile">${amoeba.home}/conf/ruleFunctionMap.xml</property>
</bean>
</property>
<property name="sqlFunctionFile">${amoeba.home}/conf/functionMap.xml</property>
<property name="LRUMapSize">1500</property>
<property name="defaultPool">multiPool</property>
<property name="writePool">server1</property>
<property name="readPool">server2</property>
<property name="needParse">true</property>
</queryRouter>
經過以上簡單配置,已經能夠實現數據庫的讀寫分離了。
3、 測試
# cd /usr/local/bin/
# ./launcher \\ (也可經過nohup後臺啓動,或者本身寫一個腳原本啓動。 )
啓動的Amoeba默認端口爲8066
在客戶端鏈接Amoeba測試:
# mysql -uroot –pminunix -h192.168.0.161 --port 8066
mysql> show databases;
mysql> CREATE DATABASE minunix; \\ 建立數據庫,以後在主從庫分別查看
經過Amoeba登陸,進行數據的查詢及插入更新等操做,並查看mysql-log日誌,可發現所執行的INSERT 、UPDATE、DELETE等操做在主庫server1上操做,SELECT查詢語句在從庫server2上執行。java