mysql实现读写分离自带java驱动

绝地灬酷狼 2022-07-14 08:47 209阅读 0赞

MySQL 数据库的读写分离和负载均衡一般是通过第三方软件来实现的。 也可以通过mysql驱动程序来实现，如com.mysql.jdbc.ReplicationDriver。

官网网址：

[多主机连接配置][Link 1]

1.[主备配置][Link 2] 2.[负载连接配置][Link 3] 3.[主从复制链接配置][Link 4] 4.[高级负载和主备配置][Link 5]

如下为java实现读写分离demo

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

</dependency>

package jdbc;

import java.sql.Connection;

import java.sql.ResultSet;

import java.util.Properties;

import com.mysql.jdbc.ReplicationDriver;

public class MasterSlaveTest \{

public static void main(String\[\] aa) throws Exception\{

ReplicationDriver driver = new ReplicationDriver();

Properties props = new Properties();

// 对slave自动重连

props.put("autoReconnect", "true");

//slaves 负载

props.put("roundRobinLoadBalance", "true");

//用户 密码

props.put("user", "root");

props.put("password", "abc123");

//jdbc:mysql:replication://master,slave1,slave2,slave3/test

Connection conn =driver.connect("jdbc:mysql:replication://192.168.0.109:3306,192.168.0.110:3306/test\_db",props);

//master 进行读写

conn.setReadOnly(false);

conn.setAutoCommit(false);

conn.createStatement().executeUpdate("insert into tmp(a,b)values(11,22)");

conn.commit();

//slave 只读

conn.setReadOnly(true);

ResultSet rs = conn.createStatement().executeQuery("SELECT count(1) FROM tmp");

if(rs.next())\{

System.out.println(rs.getInt(1));

rs.close();

conn.close();

原理： 使用mysql驱动自带的replicationDriver来实现，replicationDriver简单来说就是存在两个Connection，一个masterConnection，一个slaveConnection；当setReadonly(true)就把currentConnection=slaveConnection，反之设置为masterConnection

除此之外，ReplicationDriver还提供负载均衡，双master，下面我们通过代码演示。

<groupId>commons-dbcp</groupId>

<artifactId>commons-dbcp</artifactId>

</dependency>

package jdbc;

import java.sql.Connection;

import java.sql.ResultSet;

import org.apache.commons.dbcp.BasicDataSource;

public class LoadbalanceTest \{

public static void main(String\[\] aa) throws Exception\{

//数据库连接池

BasicDataSource ds = new BasicDataSource();

ds.setUrl("jdbc:mysql:loadbalance://192.168.0.109:3306,192.168.0.110:3306/test\_db");

ds.setDriverClassName("com.mysql.jdbc.ReplicationDriver");

ds.setUsername("root");

ds.setPassword("abc123");

ds.setInitialSize(3); // 初始的连接数；

ds.setMaxActive(10);

ds.setMinIdle(3);

ds.setMaxIdle(5);

ds.setMaxWait(3000);

ds.setRemoveAbandoned(true);

ds.setRemoveAbandonedTimeout(2000);

for(int i=0;i<20;i++)\{

Connection connection = ds.getConnection();

connection.setReadOnly(true);//设置为只读，代理类将会获取Slave数据库连接，否则设置Master连接

ResultSet rs = connection.createStatement().executeQuery("SELECT count(1) FROM tmp");

if(rs.next())\{

System.out.println(rs.getInt(1));

rs.close();

connection.close();

针对于replicationDriver spring和mybatis集成配置如下

## 使用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

<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> 
      
      
       <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"/>  
              
            <tx:method name="get*" read-only="true"/>  
        </tx:attributes>  
    </tx:advice>  
      
      
    <aop:config>  
          
        <aop:pointcut expression="execution (* com.test.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>

[Link 1]: http://dev.mysql.com/doc/connector-j/5.1/en/connector-j-multi-host-connections.html
[Link 2]: http://dev.mysql.com/doc/connector-j/5.1/en/connector-j-config-failover.html
[Link 3]: http://dev.mysql.com/doc/connector-j/5.1/en/connector-j-usagenotes-j2ee-concepts-managing-load-balanced-connections.html
[Link 4]: http://dev.mysql.com/doc/connector-j/5.1/en/connector-j-master-slave-replication-connection.html
[Link 5]: http://dev.mysql.com/doc/connector-j/5.1/en/connector-j-usagenotes-j2ee-concepts-load-balancing-failover.html