1. Python技术站首页
  2. 其他
  3. Java

SpringBoot整合sharding-jdbc实现分库分表与读写分离的示例

• Java

下面我将为您介绍如何通过Spring Boot整合sharding-jdbc实现分库分表和读写分离。

一、概述

sharding-jdbc是一个基于JDBC规范的分布式数据库中间件，它提供了易于使用、高度定制化的分片、读写分离、柔性事务等功能。Spring Boot是一款开发快速的Java企业开发框架，在分布式项目中得到广泛应用。

对于需要进行数据分片和读写分离的应用，可以通过Spring Boot集成sharding-jdbc来轻松实现。下面我们就来讲解如何使用Spring Boot整合sharding-jdbc实现分库分表和读写分离。

二、示例1：实现分库分表

  1. 引入相关依赖：
<dependency>
    <groupId>io.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>${sharding-jdbc.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.ibatis</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>${mybatis.version}</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>
  1. 在application.yml中配置数据源和分片规则，示例如下：
spring:
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    username: root
    password: root
    hikari:
      maximum-pool-size: 10
      minimum-idle: 5
      connection-test-query: SELECT 1

sharding:
  jdbc:
    # 数据源分片数量
    datasource-names: ds0, ds1
    # 分片规则
    # 分库规则
    sharding:
      databases:
        # 分库策略
        # 采用user_id取模来确定分库策略
        # 这里表示以user_id % 2的值作为分库键，分到ds0或ds1中
        # user_id为分表键，例表规则在下面配置
        algorithm-expression: ds$->{user_id % 2}
        # 分库数据源配置
        ds0:
          url: jdbc:mysql://localhost:3306/test0?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&useSSL=false
          username: root
          password: root
          type: com.zaxxer.hikari.HikariDataSource
        ds1:
          url: jdbc:mysql://localhost:3306/test1?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&useSSL=false
          username: root
          password: root
          type: com.zaxxer.hikari.HikariDataSource
    # 分表规则
    sharding:
      tables:
        user:
          # 分表策略
          # 采用user_id取模来确定分表策略
          # 这里表示以user_id % 2的值作为分表键，分到user_0或user_1表中
          # user_id为分库键，分库规则在上面配置
          actual-data-nodes: ds$->{0..1}.user_$->{0..1}
          table-strategy:
            inline:
              sharding-column: user_id
              algorithm-expression: user_$->{user_id % 2}
          key-generator-column-name: id
  1. 编写实体类和Mapper接口，示例代码如下：
@Data
@Builder
@NoArgsConstructor
@AllArgsConstructor
public class User {
    private Long id;
    private Long userId;
    private String name;
    private Integer age;
}

@Mapper
public interface UserMapper {
    @Insert("insert into user (id,user_id,name,age) values(#{id},#{userId},#{name},#{age})")
    void insert(User user);

    @Select("select id,user_id,name,age from user where id = #{id}")
    User selectById(Long id);

    @Select("select id,user_id,name,age from user where user_id = #{userId}")
    List<User> selectByUserId(Long userId);
}
  1. 编写测试类，测试分库分表效果，示例代码如下：
@SpringBootTest
class ShardingJdbcApplicationTests {
    private static final int USER_NUM = 3;

    @Autowired
    private UserMapper userMapper;

    @Test
    public void testInsert() {
        for (int i = 1; i <= USER_NUM; i++) {
            long userId = i;
            User user = User.builder().id(i).userId(userId).name("User" + i).age(18).build();
            userMapper.insert(user);
        }
    }

    @Test
    public void testSelectById() {
        for (int i = 1; i <= USER_NUM; i++) {
            User user = userMapper.selectById(Long.valueOf(i));
            System.out.println(user);
        }
    }

    @Test
    public void testSelectByUserId() {
        for (int i = 1; i <= USER_NUM; i++) {
            List<User> userList = userMapper.selectByUserId(Long.valueOf(i));
            System.out.println(userList);
        }
    }

}

三、示例2：实现读写分离

  1. 引入相关依赖：
<dependency>
    <groupId>io.shardingsphere</groupId>
    <artifactId>sharding-jdbc-core</artifactId>
    <version>${sharding-jdbc.version}</version>
</dependency>
<dependency>
    <groupId>org.apache.ibatis</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>${mybatis.version}</version>
</dependency>
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>${mysql.version}</version>
</dependency>
<dependency>
    <groupId>com.zaxxer</groupId>
    <artifactId>HikariCP</artifactId>
    <version>${hikari.version}</version>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
    <version>${spring.boot.version}</version>
</dependency>
  1. 在application.yml中配置数据源和分片规则，示例如下：
spring:
  datasource:
    # 主库配置（写数据操作）
    master:
      type: com.zaxxer.hikari.HikariDataSource
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&useSSL=false
      username: root
      password: root
      hikari:
        maximum-pool-size: 10
        minimum-idle: 5
        connection-test-query: SELECT 1
    # 从库配置（读数据操作）
    slave:
      type: com.zaxxer.hikari.HikariDataSource
      driver-class-name: com.mysql.cj.jdbc.Driver
      url: jdbc:mysql://localhost:3307/test?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8&useSSL=false
      username: root
      password: root
      hikari:
        maximum-pool-size: 10
        minimum-idle: 5
        connection-test-query: SELECT 1
  # 读写分离配置
  shardingsphere:
    datasource:
      # 数据库的名称，这里是rule
      name: rule
      # 数据库类型
      type: MySQL
      # 主备数据源分别指向主从数据源
      master-slave-rule:
        master-data-source-name: master
        slave-data-source-names: slave
    # 分片策略按照id分库，不分表
    sharding:
      tables:
        user:
          key-generator:
            type: SNOWFLAKE
            column: id
            worker-id:
            max-vibration-offset:
          database-strategy:
            inline:
              sharding-column: id
              algorithm-expression: rule_${id % 2}
  1. 编写实体类和Mapper接口，示例代码如下：
@Data
@NoArgsConstructor
@AllArgsConstructor
@Builder
public class User {
    private Long id;
    private String name;
    private Integer age;
}

@Mapper
public interface UserMapper {
    @Insert("insert into user(id,name,age) values(#{id},#{name},#{age})")
    void insert(User user);

    @Select("select id,name,age from user where id = #{id}")
    User selectById(Long id);

    @Select("select id,name,age from user")
    List<User> selectAll();
}
  1. 编写测试类，测试主从库读写效果，示例代码如下：
@SpringBootTest
class ShardingJdbcApplicationTests {
    @Autowired
    private UserMapper userMapper;

    @Test
    public void testInsert() {
        User user = User.builder().id(1L).name("User1").age(18).build();
        userMapper.insert(user);
    }

    @Test
    public void testSelectById() {
        User user = userMapper.selectById(1L);
        System.out.println(user);
    }

    @Test
    public void testSelectAll() {
        List<User> userList = userMapper.selectAll();
        System.out.println(userList);
    }
}

这样我们就完成了分库分表和读写分离的实现，开发者可以根据自己的实际需求进行调整。

本站文章如无特殊说明，均为本站原创，如若转载，请注明出处：SpringBoot整合sharding-jdbc实现分库分表与读写分离的示例 - Python技术站

赞 (0)
0 0 打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023年5月20日
下一篇 2023年5月20日

相关文章

  • Spring Boot 优雅整合多数据源

    接下来我将为您详细讲解“Spring Boot 优雅整合多数据源”的完整攻略。 一、前置知识 在学习 Spring Boot 优雅整合多数据源之前，需要掌握以下知识点： Spring Boot 和 Spring Data JPA 的基础知识。 数据库连接池的使用，例如 HikariCP、Druid 等。 多数据源的基本概念。 二、多数据源的基本概念 在 Sp…

    Java 2023年6月2日
    00

  • Java中常用的Lambda表达式案例解析

    首先我们来介绍Lambda表达式。Lambda表达式是Java 8中引入的新特性，可以使得代码更加简洁、易读、易维护、可重用性更高，是一种将行为作为方法参数传递的方法。Lambda表达式由参数、箭头和函数体组成，语法结构如下： (parameter1, parameter2, …) -> { // 参数列表，可以为空，如果不为空则必须要使用括号 // …

    Java 2023年5月26日
    00

  • 关于maven使用过程中无法导入依赖的一些总结

    针对“关于maven使用过程中无法导入依赖的一些总结”的问题，我将提供完整的攻略，包括以下几个方面： 确认Maven仓库地址是否正确 在使用Maven构建项目的过程中，很多时候会遇到无法导入依赖的情况。一种情况就是Maven的依赖仓库地址不正确，导致无法下载到所需的依赖。这时候需要确认Maven仓库地址是否正确。可以在maven的settings.xml中修…

    Java 2023年5月20日
    00

  • maven打包web项目时同时打包为war和jar文件的方法

    以下是在maven项目中同时打包为war和jar文件的方法的攻略： 1. 创建Maven Web项目 首先创建一个Maven Web项目，使用webapp的目录结构，结构如下： └── src ├── main │ ├── java │ ├── resources │ └── webapp │ ├── WEB-INF │ └── index.html └──…

    Java 2023年5月19日
    00

  • Java8优雅的字符串拼接工具类StringJoiner实例代码

    下面是关于“Java8优雅的字符串拼接工具类StringJoiner实例代码”的完整攻略。 什么是StringJoiner StringJoiner是Java 8中提供的一个字符串拼接工具类。它可以将多个字符串按照指定的分隔符连接起来，并可以指定前缀和后缀，从而生成一个完整的字符串。 StringJoiner的构造方法 public StringJoiner…

    Java 2023年5月26日
    00

  • Java反射(Class类,Class对象获取)

    Java反射机制指程序可以在运行时（程序运行时而不是在编译期间），获取或修改该程序在运行状态下的某个类的各种属性，方法和构造方法。Java反射机制在框架的设计和实现中使用广泛。 在Java中，反射机制主要通过Class类和Class对象来实现。Class类表示类的一个实例，每个类都有一个Class实例。Class对象是在运行时从类载入的数据类型，它保存着与类…

    Java 2023年5月26日
    00

  • 你要的Java并发面试题都在这里，20000字答案解析(小结)

    “你要的Java并发面试题都在这里，20000字答案解析(小结)”攻略 简介 “你要的Java并发面试题都在这里，20000字答案解析(小结)”是一篇非常详细而全面的关于Java并发编程的面试题和答案解析的文章。对于准备Java并发编程相关面试的开发者来说，这篇文章是一份非常有价值的参考资料。 内容概述 本文主要包括以下内容： Java并发基础知识：Java…

    Java 2023年5月26日
    00

  • 基于Security实现OIDC单点登录的详细流程

    下面是基于Security实现OIDC单点登录的详细流程： 1. 环境准备 首先，要在项目中添加Spring Security和Spring Security OAuth2依赖： <dependency> <groupId>org.springframework.security</groupId> <artifac…

    Java 2023年5月20日
    00
合作推广
合作推广
分享本页
返回顶部