编程开源技术交流,分享技术与知识

网站首页 > 开源技术 正文

shardingsphere-jdbc实现读写分离

wxchong 2025-01-07 16:24:51 开源技术 35 ℃ 0 评论

Sharding-JDBC

官网:https://shardingsphere.apache.org/document/legacy/4.x/document/cn/overview/

定位为轻量级Java框架,在Java的JDBC层提供的额外服务。 它使用客户端直连数据库,以jar包形式提供服务,无需额外部署和依赖,可理解为增强版的JDBC驱动,完全兼容JDBC和各种ORM框架。

  • 适用于任何基于JDBC的ORM框架,如:JPA, Hibernate, Mybatis, Spring JDBC Template或直接使用JDBC。
  • 支持任何第三方的数据库连接池,如:DBCP, C3P0, BoneCP, Druid, HikariCP等。
  • 支持任意实现JDBC规范的数据库。目前支持MySQL,Oracle,SQLServer,PostgreSQL以及任何遵循SQL92标准的数据库。


Maven依赖

<!-- 测试库 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>

<!-- web容器 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>


<!-- shardingsphere  common 库 -->
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>shardingsphere-common</artifactId>
    <version>4.1.0</version>
</dependency>


<!-- shardingsphere  jdbc spring 集成库 -->
<dependency>
    <groupId>org.apache.shardingsphere</groupId>
    <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
    <version>4.1.0</version>
</dependency>

<!-- 阿里巴连接池 druid-->
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid-spring-boot-starter</artifactId>
    <version>1.1.9</version>
</dependency>

<!-- lombok -->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <version>${lombok}</version>
</dependency>

<!-- mysql 驱动 -->
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <scope>runtime</scope>
</dependency>

<!--  mybatis plus 引用 -->
<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>mybatis-plus-boot-starter</artifactId>
    <version>3.0.6</version>
</dependency>

<!-- velocity 自动生成模板引擎, 默认 -->
<dependency>
    <groupId>org.apache.velocity</groupId>
    <artifactId>velocity-engine-core</artifactId>
    <version>2.0</version>
</dependency>

<!-- freemarker 自动生成 模板引擎 -->
<dependency>
    <groupId>org.freemarker</groupId>
    <artifactId>freemarker</artifactId>
    <version>2.3.28</version>
</dependency>

读写分离配置

spring:
  profiles:
    active: test
  shardingsphere:
    props:
      sql:
        show: true ## 打印sql信息
    # 配置真实数据源
    dataSource:
      names: ds0,ds1
      ds0:   # 配置写数据源
        type: com.alibaba.druid.pool.DruidDataSource ##使用Druid连接池
        driver-class-name: com.mysql.jdbc.Driver # 配置mysql驱动
        url: jdbc:mysql://xxx-xxx-xxx.xxx.xxx:3306/ds0?characterEncoding=utf-8&useSSL=false
        username: root  ##mysql用户名
        password: xxx ##mysql密码
      # 配置第 2 个数据源
      ds1:
        type: com.alibaba.druid.pool.DruidDataSource # 配置读数据源
        driver-class-name: com.mysql.jdbc.Driver # 使用Druid连接池
        url: jdbc:mysql://xxx-xxx-xxx.xxx.xxx:3306/ds1?characterEncoding=utf-8&useSSL=false
        username: root ##mysql用户名
        password: xxx mysql密码
    masterslave:
      load-balance-algorithm-type: round_robin ##使用轮训算法
      name: ds0 ##
      master-data-source-name: ds0 #写库
      slave-data-source-names: ds1 #读库

启动类配置

import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceAutoConfigure;
import lombok.extern.slf4j.Slf4j;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@Slf4j
//加载mapper文件包
@MapperScan(basePackages = { "com.xxx.xxx.jdbc.business.user.mapper" })
//取消数据源自动配置,我们使用shardingsphere-jdbc配置数据源
@SpringBootApplication(exclude = DruidDataSourceAutoConfigure.class)
public class JdbcApplication {

    public static void main(String[] args) {
        SpringApplication.run(JdbcApplication.class, args);
        log.info( "启动成功" );
    }


}

运行结果

核心概念

主库

添加、更新以及删除数据操作所使用的数据库,目前仅支持单主库。

从库

查询数据操作所使用的数据库,可支持多从库。

主从同步

将主库的数据异步的同步到从库的操作。由于主从同步的异步性,从库与主库的数据会短时间内不一致。

负载均衡策略

通过负载均衡策略将查询请求疏导至不同从库。

Tags:

本文暂时没有评论,来添加一个吧(●'◡'●)

欢迎 发表评论:

最近发表
标签列表