Spring Boot 结合 MyBatis、Sharding-JDBC 和 Guava 实现主从分离

本文链接：https://blog.csdn.net/blog_programb/article/details/106262649

本文介绍了如何在SpringBoot项目中利用Mybatis和Sharding-JDBC实现数据库的读写分离。读写分离可以有效提高系统性能，将DML操作交由主库处理，并通过同步确保主从数据一致。DQL查询则分发到从库执行，减轻单机数据库压力。Sharding-JDBC作为轻量级Java框架，提供数据分片、读写分离等功能，且兼容JDBC和ORM框架。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

Spring Boot 结合 MyBatis、Sharding-JDBC 和 Guava 实现主从分离

配置类设计

为了实现主从分离，可以通过配置 MasterSlaveRule 来指定数据源的主库和从库。以下是基于 Spring Boot 的配置示例：

package com.ckj.sharding.sphere.jdbc.lwh.config;

import com.google.common.collect.Lists;
import org.apache.shardingsphere.api.config masterslave.MasterSlaveRuleConfiguration;
import org.apache.shardingsphere.api.config.datasource.DataSourceConfiguration;
import org.apache.shardingsphere.masterslave.SpringBootStarterMasterSlaveAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import javax.sql.DataSource;
import java.util.HashMap;
import java.util.Map;

@Configuration
public class DataSourceConfig {
   

    @Bean
    public DataSource dataSource() {
   
        Map<String, DataSourceConfiguration> dataSourceMap = new HashMap<>();
        
        // 主库配置
        DataSourceConfiguration masterDataSourceConfig = DataSourceConfiguration.newInstance("com.zaxxer.hikari.HikariDataSource");
        masterDataSourceConfig.getProps().put("jdbcUrl", "jdbc:mysql://master_host:3306/db_name?serverTimezone=UTC&useSSL=false");
        masterDataSourceConfig.getProps().put("username", "root");
        masterDataSourceConfig.getProps().put("password", "password");

        // 从库配置
        DataSourceConfiguration slaveDataSourceConfig1 = DataSourceConfiguration.newInstance("com.zaxxer.hikari.HikariDataSource");
        slaveDataSourceConfig1.getProps().put("jdbcUrl", "jdbc:mysql://slave_host_1:3306/db_name?serverTimezone=UTC&useSSL=false");
        slaveDataSourceConfig1.getProps().put("username", "root");
        slaveDataSourceConfig1.getProps().put("password", "password");

        DataSourceConfiguration slaveDataSourceConfig2 = DataSourceConfiguration.newInstance("com.zaxxer.hikari.HikariDataSource");
        slaveDataSourceConfig2.getProps().put("jdbcUrl", "jdbc:mysql://slave_host_2:3306/db_name?serverTimezone=UTC&useSSL=false");
        slaveDataSourceConfig2.getProps().put("username", "root");
        slaveDataSourceConfig2.getProps().put("password", "password");

        dataSourceMap.put("master_ds", masterDataSourceConfig);
        dataSourceMap.put("slave_ds_1", slaveDataSourceConfig1);
        dataSourceMap.put("slave_ds_2", slaveDataSourceConfig2);

        MasterSlaveRuleConfiguration masterSlaveRuleConfig = new MasterSlaveRuleConfiguration();
        masterSlaveRuleConfig.setName("ds_master_slave");
        masterSlaveRuleConfig.setMasterDataSourceName("master_ds");
        masterSlaveRuleConfig.setSlaveDataSourceNames(Lists.newArrayList("slave_ds_1", "slave_ds_2"));

        return ShardingSphereDataSourceFactory.createDataSource(dataSourceMap, Collections.singletonList(masterSlaveRuleConfig), new Properties());
    }
}

上述代码展示了如何通过 MasterSlaveRuleConfiguration 定义主从规则，并将多个从库加入到配置中。

使用 Guava 缓存优化查询性能

Guava 提供了高效的缓存机制，可以用于减少数据库访问次数并提升应用性能。以下是一个简单的 Guava 缓存集成示例：

package com.ckj.sharding.sphere.jdbc.lwh.service;

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;
import org.springframework.stereotype.Service;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;

@Service
public class CacheService {
   

    private final LoadingCache<Long, Object> cache = CacheBuilder.newBuilder()
            .maximumSize(1000)
            .expireAfterWrite(10, TimeUnit.MINUTES)
            .build(new CacheLoader<>() {
   
                @Override
                public Object load(Long key) throws Exception {
   
                    // 这里可以根据实际需求加载数据
                    return fetchDataFromDatabase(key);
                }
            });

    public Object getFromCache(Long id) throws ExecutionException {
   
        return cache.get(id);
    }

    private Object fetchDataFromDatabase(Long id) {
   
        // 模拟从数据库获取数据的过程
        System.out.println("Fetching data from database for ID: " + id);
        return new Object(); // 替换为实际的数据对象
    }
}

此部分实现了基于 Guava 的缓存逻辑，能够有效降低高频次的数据库请求压力。

启动类定义

启动类需标注必要的注解以支持 MyBatis 和 Sharding-JDBC 功能：

package com.ckj.sharding.sphere.jdbc.lwh;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan(basePackages = "com.ckj.sharding.sphere.jdbc.lwh.dao")
public class ShardingsphereJdbcLwhApplication {
   

    public static void main(String[] args) {
   
        SpringApplication.run(ShardingsphereJdbcLwhApplication.class, args);
    }
}