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);
    }
}

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

阅读剩余 83%

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

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

相关文章

  • Java SpringBoot 中，动态执行 bean 对象中的方法

    根据不同的条件，调用不同的 bean 对象，执行对象中的方法 SpringUtils 工具类 package com.vipsoft.web.utils; import cn.hutool.core.util.ArrayUtil; import org.springframework.aop.framework.AopContext; import org.…

    Java 2023年4月17日
    00

  • 基于Java实现简单的邮件群发功能

    实现邮件群发功能需要借助Java的Java Mail API和Java Activation Framework，接下来将为您详细讲解实现过程： 安装Java Mail API和Java Activation Framework Java Mail API和Java Activation Framework是Java EE的标准库之一，它们需要被单独下载并安…

    Java 2023年5月23日
    00

  • java单链表实现书籍管理系统

    为了实现“java单链表实现书籍管理系统”，我们需要完成以下步骤： 定义Book类，包括属性：书名、作者、出版社、ISBN编号等 定义Node类，包括属性：存储的Book对象、指向下一个节点的引用Next等 定义LinkedList类，包括属性：链表长度、头节点引用head等 实现LinkedList类的各种操作方法，例如增加、删除、修改、查找、遍历等 下面…

    Java 2023年5月24日
    00

  • 什么是堆内存和栈内存？

    以下是关于堆内存和栈内存的完整使用攻略： 什么是堆内存和栈内存？ 堆内存和栈内都是计算机内存中的部分，但它们的使用方式和特不同。 堆内存是指由程序员手动分配和释放的内存空间，通常于存储动态分配的数据结构，如数组和对象等。堆内存的大小通常比栈内存大，但是它的分配和释放速度较慢。 栈存是指由编译器自动分配和释放的内存空间，通常用于存储局部变和函数调用的上下文信息…

    Java 2023年5月12日
    00

  • java实现简单的搜索引擎

    一、准备工作 在开始实现搜索引擎之前，需要准备以下工作： 编译环境：需要在本地安装JDK环境，并配置好对应的环境变量。 Maven管理工具：Maven是一个Java项目管理工具，能够自动下载所需的依赖库，并管理项目的编译、测试、打包等过程。 Lucene搜索引擎库：Lucene是一种高效的文本搜索引擎库，它提供了全文检索、模糊搜索、分词等功能，是实现搜索引擎…

    Java 2023年5月18日
    00

  • SpringBoot项目集成日志的实现方法

    Spring Boot项目集成日志的实现方法 在Spring Boot项目中，我们可以使用日志模块来记录应用程序的运行状态和错误信息。本文将详细讲解Spring Boot项目集成日志的实现方法的完整攻略，并提供两个示例。 1. 集成日志模块 以下是集成日志模块的基本流程： 在pom.xml文件中添加以下依赖： <dependency> <g…

    Java 2023年5月15日
    00

  • Java数组常见应用详解【创建、遍历、排序、查找】

    Java数组常见应用详解 数组是一种非常常见的数据结构，它可以用于存储一组数据，并且支持快速的遍历、排序和查找等操作。在Java中，数组是一个容器对象，可以存储相同类型的元素，并且在创建后其大小是不可改变的。本文将详细介绍Java数组的创建、遍历、排序和查找等常见应用，让大家对Java数组有更深入的了解。 创建数组 在Java中，可以通过以下方式来创建数组：…

    Java 2023年5月26日
    00

  • Java 如何实现照片转化为回忆中的照片

    要实现将现有照片转化为回忆中的照片，可以考虑使用 Java 中的图像处理库，例如 Java Advanced Imaging (JAI)。下面是实现该过程的具体攻略： 准备工作 首先需要在项目中引入 Java Advanced Imaging API。JAI 支持的文件格式包括 JPEG、BMP、PNG、TIFF 等常见的图片格式。如果需要支持其他格式，可以…

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