spring MVC、mybatis配置讀寫分離

第一種方法:
當後端MYSQL服務器羣是master-master雙向同步機制時,前端應用使用JDBC連接數據庫可使用loadbalance方式,以下所示:
jdbc:mysql:loadbalance://dbnode_1:port,dbnode_2:port,dbnode_3:port,dbnode_n:port/dbname?user=xxxx;password=xxxxxxx;loadBalanceBlacklistTimeout=3000;&characterEncoding=utf-8
loadbalance方式有兩種負載均衡算法,一種是隨機式的輪詢算法,另外一種是最短響應時間算法,具體會使用哪種算法、怎 人為指定使用哪種算法目前還不太清楚。。官方網站上也沒看到很明確的說明。前端

第二種方法:
當後端MYSQL服務器羣是master-slave單向一主N 從的同步複製機制時,再使用loadbalance方式就會有問題了,因為若是有insert、update等寫操做改變了從機的數據就麻煩了,從機不會 將變化複製到主機,所以這種情況下須要實現「主讀寫、從只讀」的模式,為了達到這個目的可使用replication方式,以下所示:
jdbc:mysql:replication://dbnode_1:port,dbnode_2:port,dbnode_3:port,dbnode_n:port/dbname?user=xxxx;password=xxxxxxxx;&characterEncoding=utf-8
replication方式能夠很安全的實現寫操做只發送到主機執行,而從機只會接收到讀操做。java

 

 

 

.環境:node

   3臺數據庫機器,一個master,二臺slave,分別爲slave1,slave2mysql

    

2.要實現的目標:算法

   ①使數據寫入到masterspring

   ②讀數據時,從slave1和slave2中讀取sql

    以此來實現數據庫的讀寫分離數據庫

3.原理:express

   使用mysql驅動自帶的replicationDriver來實現,replicationDriver簡單來講就是存在兩個Connection,一個masterConnection,一個slaveConnection;編程

   當setReadonly(true)就把currentConnection=slaveConnection,反之設置爲masterConnection

4.實現步驟:

①jdbc.properties

 

[java]  view plain copy 在CODE上查看代碼片 派生到個人代碼片
 
  1. ## 使用ReplicationDriver而不是driver  
  2. jdbc.driverClassName=com.mysql.jdbc.ReplicationDriver   
  3. ## 使用的是jdbc:mysql:replication://  
  4. jdbc.url=jdbc:mysql:replication://master:3306,slave1:3306,slave2:3306/test2?characterEncoding=utf8   
  5. jdbc.username=root  
  6. jdbc.password=123456  

②使用spring的事物,把讀操做設置爲readonly=true

 

 

 

jdbc.connection.driver=com.mysql.jdbc.ReplicationDriver
jdbc.connection.url=jdbc:mysql:replication://192.168.202.190,192.168.202.190/job?useUnicode=true&characterEncoding=utf-8

 

 

 

[java]  view plain copy 在CODE上查看代碼片 派生到個人代碼片
 
  1. <!-- 配置dataSource -->  
  2.   <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource"  
  3.         id="dataSource">  
  4.         <property name="driverClassName" value="${jdbc.driverClassName}"/>  
  5.         <property name="username" value="${jdbc.username}"/>  
  6.         <property name="password" value="${jdbc.password}"/>  
  7.         <property name="url" value="${jdbc.url}"></property>  
  8.   </bean>   
  9.     
  10.   <!-- transaction configuration-->  
  11.    <bean id="transactionManager"  
  12.     class="org.springframework.jdbc.datasource.DataSourceTransactionManager">  
  13.     <property name="dataSource" ref="dataSource" />  
  14.   </bean>   
  15.     
  16.   <!-- 定義事務通知 -->    
  17.     <tx:advice id="txAdvice" transaction-manager="transactionManager">    
  18.         <!-- 定義方法的過濾規則 -->    
  19.         <tx:attributes>    
  20.             <!-- 全部方法都使用事務 -->    
  21.             <tx:method name="*" propagation="REQUIRED"/>    
  22.             <!-- 定義全部get開頭的方法都是隻讀的 -->    
  23.             <tx:method name="get*" read-only="true"/>    
  24.         </tx:attributes>    
  25.     </tx:advice>    
  26.         
  27.     <!-- 定義AOP配置 -->    
  28.     <aop:config>    
  29.         <!-- 定義一個切入點 -->    
  30.         <aop:pointcut expression="execution (* com.most.service.*.*(..))" id="services"/>    
  31.         <!-- 對切入點和事務的通知,進行適配 -->    
  32.         <aop:advisor advice-ref="txAdvice" pointcut-ref="services"/>    
  33.     </aop:config>    
  34.     
  35.   <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">  
  36.     <property name="dataSource" ref="dataSource" />  
  37.     <property name="configLocation" value="/WEB-INF/conf/mybatis-config.xml" />  
  38.   </bean>  


全部以get開頭的方法被調用時,readonly = true

 

 

ps:這個只是實現了讀寫分離,master與slave之間的數據同步使用mysql replication便可

 

 

 

昨晚看了一夜的MySQL文檔,主要是關於MySQL的複製方面的文檔,用的工具是MySQL的幫助文檔+金山詞霸。

終於比較大概的瞭解瞭如何經過複製來提高MySQL數據庫的高可用性和處理能力,不過尚未通過實際的試驗,但總體的思想是清楚了,下面把思路大概的描述一下,有機會再進行實驗。

首先在服務器端採用1+N的模型來安裝和配置MySQL數據庫。1就是一個master數據庫,N就是一至多個slave數據庫。master數據 庫必須啓用binlog模式,關於這兩種數據庫的配置參見MySQL的文檔。配置完成後就造成了一個1+N的複製集羣,當對master進行修改時會自動 把修改的數據更新到N個slave數據庫上。可是有一個注意的是,全部的修改操做包括添加、刪除、修改等語句必須做用在master數據庫上,這樣才能使 數據可靠的複製到其餘slave服務器上。另外,因爲slave服務器只用做查詢,所以選用MyISAM的存儲引擎能夠提升查詢的速度。

而在客戶端呢?如何使客戶端程序能均衡的使用這些可用的服務器呢?並且更新操做只能對master進行處理。這個豈不是應用程序對數據庫的操做邏輯很是的複雜?

其實沒有那麼複雜,MySQL爲咱們提供了接口能夠將這些複雜的操做透明化。下面主要介紹採用JDBC的客戶端如何工做在基於複製的集羣環境中,其餘編程語言請參照mysql的文檔。

MySQL最新的JDBC驅動程序包中提供了一個驅動類就是 com.mysql.jdbc.ReplicationDriver 。這個驅動類容許在url中設置多個mysql主機地址,例如:

jdbc:mysql://master1,slave1,slave2/dlog?autoReconnect=true&roundRobinLoadBalance=true

在上面的url中,有三個主機地址分別是master1,slave1,slave2,其中ReplicationDriver 規定第一個主機是master主機地址,剩下的所有是slave主機。另外有兩個參數必須指定爲true,就是autoReconnect和roundRobinLoadBalance。

使用這個驅動和配置後還不能立刻解決全部的問題,咱們還須要對程序作一些小改動。

咱們必須告訴驅動程序,哪些語句的執行是做用在master數據庫,而哪些語句的執行做用在slave數據庫上。

ReplicationDriver 是經過Connection對象的readOnly屬性來判斷該操做是否爲更新操做。所以咱們在執行一個sql語句的時候必須調用一下 setReadOnly告訴驅動程序當前執行的操做是不是隻讀。若是你是使用hibernate操做數據庫的,那能夠調用 Query.setReadOnly方法。

以上就是整個思路的大概描述,猜測確定還有存在一些問題,例如由於數據的複製過程是異步的,也是說有可能執行了某個更新操做,可是查詢的時候查不到的狀況出現。固然這些問題只能在實際的過程當中進行解決。

另外關於最新版本的MySQL 5.1有一個集羣的功能,不過通過研究發現這個東西簡直就是兒戲,實在搞不懂MySQL怎麼會作這麼不負責任的設計,由於這個特性要求數據庫是整個 load到內存中的,也就是說你的數據有多大,內存就得有多大,怎麼說呢? 若是你真的內存足夠大,你去試試吧,反正這種方案已經被我否決了,但願MySQL能改進一下。

相關文章
相關標籤/搜索