1.環境:mysql
3臺數據庫機器,一個master,二臺slave,分別爲slave1,slave2spring
2.要實現的目標:sql
①使數據寫入到master數據庫
②讀數據時,從slave1和slave2中讀取express
以此來實現數據庫的讀寫分離mybatis
3.原理:url
使用mysql驅動自帶的replicationDriver來實現,replicationDriver簡單來講就是存在兩個Connection,一個masterConnection,一個slaveConnection;spa
當setReadonly(true)就把currentConnection=slaveConnection,反之設置爲masterConnectioncode
4.實現步驟:orm
①jdbc.properties
## 使用ReplicationDriver而不是driver jdbc.driverClassName=com.mysql.jdbc.ReplicationDriver ## 使用的是jdbc:mysql:replication:// jdbc.url=jdbc:mysql:replication://master:3306,slave1:3306,slave2:3306/test2?characterEncoding=utf8 jdbc.username=root jdbc.password=123456
②使用spring的事物,把讀操做設置爲readonly=true
<!-- 配置dataSource --> <bean class="org.springframework.jdbc.datasource.DriverManagerDataSource" id="dataSource"> <property name="driverClassName" value="${jdbc.driverClassName}"/> <property name="username" value="${jdbc.username}"/> <property name="password" value="${jdbc.password}"/> <property name="url" value="${jdbc.url}"></property> </bean> <!-- transaction configuration--> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <!-- 定義事務通知 --> <tx:advice id="txAdvice" transaction-manager="transactionManager"> <!-- 定義方法的過濾規則 --> <tx:attributes> <!-- 全部方法都使用事務 --> <tx:method name="*" propagation="REQUIRED"/> <!-- 定義全部get開頭的方法都是隻讀的 --> <tx:method name="get*" read-only="true"/> </tx:attributes> </tx:advice> <!-- 定義AOP配置 --> <aop:config> <!-- 定義一個切入點 --> <aop:pointcut expression="execution (* com.most.service.*.*(..))" id="services"/> <!-- 對切入點和事務的通知,進行適配 --> <aop:advisor advice-ref="txAdvice" pointcut-ref="services"/> </aop:config> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <property name="dataSource" ref="dataSource" /> <property name="configLocation" value="/WEB-INF/conf/mybatis-config.xml" /> </bean>
全部以get開頭的方法被調用時,readonly = true
ps:這個只是實現了讀寫分離,master與slave之間的數據同步使用mysql replication便可