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日

相关文章

  • C#、ASP.NET通用工具类IsWhat？（可以判断数字、身份证、数据类型等等）

    首先，IsWhat是一个通用工具类，包含多个方法用于判断不同类型的数据。下面将介绍其中的一些方法及其使用示例。 IsNumber 判断一个字符串是否为数字。 public static bool IsNumber(string str) { return Regex.IsMatch(str, @"^[+-]?\d*[.]?\d*$"); …

    Java 2023年5月19日
    00

  • 浅谈hibernate中懒加载禁用操作

    浅谈Hibernate中懒加载禁用操作 什么是懒加载 Hibernate中的懒加载指的是对象的延迟加载，在对象被使用时才进行加载操作，目的是为了提高系统的性能。 在默认情况下，Hibernate使用懒加载来查询和加载与主对象相关的所有集合关系和属性。因此，在需要使用这些集合和属性时，才会进行加载操作，减少了对数据库的查询次数，提高了系统性能。 为什么需要禁用…

    Java 2023年5月31日
    00

  • 消息推送平台的实时数仓？！flink消费kafka消息入到hive

    大家好，3y啊。好些天没更新了，并没有偷懒，只不过一直在安装环境，差点都想放弃了。 上一次比较大的更新是做了austin的预览地址，把企业微信的应用和机器人消息各种的消息类型和功能给完善了。上一篇文章也提到了，austin常规的功能已经更新得差不多了，剩下的就是各种细节的完善。 不知道大家还记不记得我当时规划austin时，所画出的架构图： 现在就剩下aus…

    Java 2023年5月11日
    00

  • 解决springboot整合cxf启动报错,原因是版本问题

    确认版本兼容性 在整合 Spring Boot 和 CXF 的过程中，经常会遇到版本兼容性问题，此时需要确认 Spring Boot 和 CXF 的版本兼容性是否一致。 建议使用 Maven 进行管理，使用 Maven 的 Dependency Management 协调版本。在 pom.xml 中添加 Spring Boot Starter Parent …

    Java 2023年5月19日
    00

  • JSP输出HTML时产生的大量空格和换行的去除方法

    请看下面的完整攻略： JSP输出HTML时产生的大量空格和换行的去除方法 在JSP中输出HTML代码时，由于JSP代码与HTML代码的交错使用，很容易产生大量的空格和换行，这会导致HTML页面的体积增大，加载速度变慢，同时也不符合优化的要求。因此，我们需要对JSP输出HTML的过程进行优化，去除这些空格和换行。 下面是两种去除JSP输出HTML空格和换行的方…

    Java 2023年6月15日
    00

  • 阿里云发布 Spring Boot 新脚手架工程

    阿里云发布了Spring Boot新脚手架工程，使用脚手架可以快速创建Spring Boot项目，省去很多繁琐的配置工作，让开发人员能够迅速地开始项目开发。 步骤一：选择脚手架 首先，打开阿里云开发者中心官网，搜索“Spring Boot脚手架”，选择第一个来自官方的结果“Spring Boot 2.x 脚手架”，进入项目首页。 步骤二：创建工程 在页面上方…

    Java 2023年5月15日
    00

  • Spring Boot webflux使用方法解析

    下面是关于“Spring Boot webflux使用方法解析”的完整攻略，包含两个示例说明。 Spring Boot webflux使用方法解析 Spring Boot webflux是Spring Boot框架的一部分，它提供了一种基于响应式编程的方式来构建Web应用程序。本文将详细介绍如何使用Spring Boot webflux来构建Web应用程序。…

    Java 2023年5月17日
    00

  • spring 整合JDBC和AOP事务的方法

    下面是详细讲解“spring 整合 JDBC 和 AOP 事务的方法”的完整攻略： 一、准备工作 引入 Spring 和 JDBC 的依赖 在 pom.xml 中添加以下依赖： <!– Spring –> <dependency> <groupId>org.springframework</groupId>…

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