理解數據庫連接池底層原理之手寫實現
數據庫連接池的基本思想是:為數據庫連接建立一個“緩沖池”,預先在池中放入一定數量的數據庫連接管道,需要時,從池子中取出管道進行使用,操作完畢後,在將管道放入池子中,從而避免了頻繁的向數據庫申請資源,釋放資源帶來的性能損耗。在如今的分布式系統當中,系統的QPS瓶頸往往就在數據庫,所以理解數據庫連接池底層構造原理與設計思想是很有益處的。我們常用的數據庫連接池有C3P0,DBCP,Druid等,下面我們就來分析下數據庫連接池應該有些什麽,以及手寫一個迷你版的數據庫連接池!
對數據庫連接池的一點思考
第一,數據庫連接池中存放的就是數據庫操作管道,不僅僅是存放,而且應該是管理這些管道;
第二,應該提供外部配置文件去初始化數據庫連接池;
第三,如果一個數據庫操作管道已經被占用,那麽其他請求是否應該得到這個管道,也就是說我們要考慮多線程並發下,管道的分配問題;
第四,如果做到管道的復用?放回池子中,標示可用,並不是真正的關閉管道;
寫一個迷你版數據庫連接池
IMyPool是一個接口,對外提供數據庫連接池的基本服務,比如得到一個數據庫操作管道。
MyDefaultPool是IMyPool的實現。
MyPooledConnection代表數據庫操作管道,它可以執行SQL,關閉管道等。
MyPoolFactory是一個工廠,單例模式,用於得到IMyPool實現。
DBConfigXML代表外部配置文件。
Test用於測試。
DBConfigXML
我們在實際中使用數據庫連接池,需要在Spring的配置文件中,進行一些參數配置。這裏,為了簡化解析,直接提供。
MyPooledConnection
所謂數據庫連接管道,就是對JDBC Connection進行封裝而已,但是需要註意isBusy的這個標示。對管道的關閉,實際上只是標示的改變而已!
IMyPool
MyDefaultPool
需要註意到是,MyDefaultPool持有一個管道集合,基於多線程的考慮,這裏使用了Vector。
MyDefaultPool需要初始化
數據庫連接池需要根據外部配置文件完成數據庫驅動加載以及初始化管道的建立。
createMyPooledConnection接口實現
數據庫連接池在創建管道時,應該去看一下是否達到上限,如果沒有,則可以創建。
不僅僅要創建出來,還要標示每一個管道的isBusy標誌。
getMyPooledConnection接口實現
這裏需要註意的是:如果得不到操作管道,需要去創建管道!
getRealConnectionFromPool
第一,這裏使用了synchronized,就是為了避免多線程下產生問題。
第二,要知道Connection是有超時機制的,如果我們得到的管道的Connection已經超時了怎麽辦呢?
第三,得到管道後,一定註意isBusy的設置。
MyPoolFactory
Test測試
運行結果
好了,到這裏,一個迷你版的數據庫連接池就有模有樣了!
理解數據庫連接池底層原理之手寫實現