带你了解mybatis如何实现读写分离

如何实现MyBatis的读写分离

MyBatis是一款优秀的ORM框架，支持多种数据库，本文将介绍如何使用MyBatis实现读写分离。

读写分离是指将读和写请求分流到不同的数据库节点，以提高数据库系统的性能和可用性。将写操作集中在主数据库节点上，而读操作则分流到多个从数据库节点上处理。

下面，我们将介绍MyBatis的两种读写分离实现方法：第一种是使用MyBatis提供的插件，第二种是使用数据库中间件进行读写分离。

使用MyBatis提供的插件实现读写分离

MyBatis提供了一个名为"Read/Write Splitting Plugin"的插件，用于实现读写分离。该插件拦截MyBatis执行的SQL语句，根据SQL类型判断是否为读操作，如果是读操作，则将其路由到可用的从节点；如果是写操作，则路由到主节点。

下面是该插件的maven依赖：

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis</artifactId>
    <version>${mybatis.version}</version>
</dependency>

<dependency>
    <groupId>org.mybatis</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>${mybatis.spring.boot.version}</version>
</dependency>

<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>${hikari.version}</version>
</dependency>

<dependency>
    <groupId>com.github.mybatissupport</groupId>
    <artifactId>read-write-splitting-plugin</artifactId>
    <version>${read.write.splitting.version}</version>
</dependency>

使用示例：

配置主从数据库信息

@Bean
@ConfigurationProperties("mysql.datasource.master")
public DataSource master() {
    return DataSourceBuilder.create().build();
}

@Bean
@ConfigurationProperties("mysql.datasource.slave")
public DataSource slave() {
    return DataSourceBuilder.create().build();
}

配置读写分离插件

@Bean
public SqlSessionFactory sqlSessionFactory() throws Exception {
    SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
    sqlSessionFactoryBean.setDataSource(cluster());
    // 配置读写分离插件
    sqlSessionFactoryBean.setPlugins(new ReadWriteSplittingPlugin());
    return sqlSessionFactoryBean.getObject();
}

示例2：使用数据库中间件实现读写分离

另一种读写分离实现方法是使用数据库中间件。 MyBatis的读写分离插件只能在应用程序内置实现，而数据库中间件会在数据库服务器上进行路由，更具灵活性和可扩展性。常用的数据库中间件有MySQL Proxy、TDDL和Cobar等。

下面是使用TDDL中间件进行读写分离的示例：

安装TDDL中间件
配置TDDL数据源

<property name="url" value="jdbc:mysql://127.0.0.1:8066,127.0.0.1:8067/test?useUnicode=true&amp;characterEncoding=utf-8" />
<property name="username" value="test" />
<property name="password" value="test" />

配置MyBatis

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="plugins">
        <array>
            <bean class="com.alibaba.tddl.interact.adapter.mybatis.TStatementInterceptor" />
        </array>
    </property>
</bean>

代码说明：