同事喜歡叫我遠哥,所以我把這個筆記稱為遠哥系列,今天有興趣分析一下Amoeba的源碼,並且在此記錄一下,並且隨時更新。
Amoeba目前一共有三個項目產品,分別是:
Amoeba for MySQL:
為MySQL提供了一種數據庫代理的解決方案,可以實現多台MySQL之間的讀寫分離,具有負載均衡、高可用性、Query過濾、讀寫分離、可路由相關的query到目標數據庫、可並發請求多台數據庫合並結果。 在Amoeba上面你能夠完成多數據源的高可用、負載均衡、數據切片的功能。
Amoeba for Aladdin:
類似“Amoeba for MySQL”,不同的是“Amoeba for MySQL”只支持MySQL數據庫,“Amoeba for Aladdin”支持多種數據庫,同時還可以在后台使用多種混合數據庫。
Amoeba for MongoDB:
實現對NoSQL數據庫MongoDB的代理功能,具備心跳檢測、負載均衡、故障轉移、查詢聚合等功能。
從目前Amoeba的系列產品來看,都是針對數據庫存儲應用在分布式群集負載場景下的解決方案,覆蓋了常用的數據庫種類。
本系列源碼分析都是真對Amoeba for MySQL的,其它兩個項目其實都是基於Amoeba for MySQL之后,改變而來的,所以,讀懂了Amoeba for MySQL,也就讀懂了其他兩個項目。
如何獲得源碼:
Amoeba的源碼目前放在Google上,可以使用SVN拉下來,地址為:http://amoeba.googlecode.com/svn/trunk
首先看一下源碼的項目列表:
注意:自己建立Maven項目,然后把項目代碼用Maven關聯起來,上圖是我自己加好之后的,如果需要,我可以將我加好的Maven項目提供下載,你只要導入就可以了。
主要的幾個類:
包名:com.meidusa.amoeba.server
類名:AmoebaProxyServer
職責:Amoeba啟動主入口,注意,為了很好的擴展性,這個類在Amoeba核心項目中,而不是在amoeba-mysql項目中(不管是Amoeba for MySQL還是Amoeba for Aladdin,主入口都是這個類)
包名:com.meidusa.amoeba.mysql.handler
類名:QueryCommandMessageHandler (繼承 com.meidusa.amoeba.mysql.handler.CommandMessageHandler)
職責:SQL的查詢命令處理者,對於分庫分表查詢結果的合並邏輯,在其父類 CommandMessageHandler.mergeMessages 方法中
包名:com.meidusa.amoeba.mysql.parser
類名:MysqlQueryRouter
職責:MySQL的路由解析器,根據SQL語句來獲得符合路由規則中的線程池對象
包名:com.meidusa.amoeba.mysql.handler
類名:MySqlCommandDispatcher (實現接口 com.meidusa.amoeba.net.MessageHandler)
職責:SQL命令分發者,將客戶端請求的SQL指令根據Amoeba路由配置規則分發到對應的連接池中
包名:com.meidusa.amoeba.mysql.handler
類名:CommandQueue
職責:SQL命令執行隊列,客戶端向Amoeba發送的語句全部先進入該隊列
包名:com.meidusa.amoeba.mysql.context
類名:MysqlRuntimeContext
職責:Amoeba運行時上下文信息,包括Amoeba版本號、SQL緩存大小、緩存過期時間等
包名:com.meidusa.amoeba.mysql.net
類名:MysqlClientConnection
職責:封裝客戶端連接到Amoeba的連接對象
包名:com.meidusa.amoeba.mysql.net
類名:MysqlServerConnection
職責:封裝Amoeba連接到物理MySQL數據庫的連接對象
包名:com.meidusa.amoeba.net.poolable
類名:MultipleLoadBalanceObjectPool
職責:實現了一個可以負載均衡的對象池,用到了Apache下面的一個開源項目commons-pool,在Amoeba中,該對象池用來存放Amoeba配置中的 Server Pool 對象
包名:com.meidusa.amoeba.route
類名:AbstractQueryRouter
職責:實現讀寫分離的邏輯就在該抽象類中