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日

相关文章

  • Java中的字节,字符输出流与字节和字符输入流的简单理解

    Java中的 IO 流可以分为字节流和字符流。字节流以字节（8 位二进制数）为单位，而字符流以字符为单位，每个字符包含若干个字节。Java 中字符采用 Unicode 编码，每个字符占 2 个字节。 在 Java 中，字节输出流有两个主要的类：OutputStream 和 FileOutputStream。OutputStream 是字节输出流的抽象基类，可…

    Java 2023年5月26日
    00

  • Spark JDBC操作MySQL方式详细讲解

    Spark JDBC操作MySQL方式详细讲解 简介 Spark可以使用JDBC访问关系型数据库，包括MySQL，Oracle，PostgreSQL等等。Spark的JDBC操作支持读写功能，本篇文章将为大家详细讲解如何使用Spark JDBC操作MySQL数据库。 步骤 1. 导入MySQL JDBC驱动 在使用Spark JDBC操作MySQL之前，需要…

    Java 2023年6月2日
    00

  • 微信小程序template模板与component组件的区别和使用详解

    微信小程序template模板与component组件的区别和使用详解 在微信小程序开发过程中，template和component是两个经常用到的概念。它们可以用来复用一些公共的代码和样式，也能使代码更加简洁易读。本文将详细讲解template模板和component组件的相关概念、特点、用法以及注意事项，并通过示例代码进行说明和实践。 template模…

    Java 2023年5月23日
    00

  • Java实现登录和注册案例

    下面我将为您详细讲解Java实现登录和注册案例的完整攻略。我们分为以下几个步骤进行讲解： 搭建开发环境 创建用户实体类 创建用户数据访问对象（DAO） 创建用户服务（Service） 创建控制器（Controller） 配置数据库连接 创建用户表 实现注册功能 实现登录功能 接下来，我将为您详细讲解每一步的具体操作流程。 每个开发者需要有一台配有Java开发…

    Java 2023年5月19日
    00

  • Java实现多线程聊天室

    实现多线程聊天室，在Java中可以通过使用Socket和Thread来实现。 具体步骤如下： 1.创建服务器端- 创建ServerSocket对象，并设置端口号- 创建Socket对象，以接受客户端请求- 使用Thread创建一个线程，以接受客户端发来的消息，并将消息广播给其他客户端- 使用ArrayList存储客户端（每个客户端都对应一个Socket对象）…

    Java 2023年5月18日
    00

  • 关于JSP用户登录连接数据库详情

    下面是关于JSP用户登录连接数据库的完整攻略： 1. 数据库准备 首先，我们需要准备一个数据库用来存储用户的信息。可以使用MySQL、Oracle等关系型数据库，也可以使用MongoDB等非关系型数据库。假设我们使用MySQL数据库，那么我们需要： 安装MySQL数据库 创建一个名为“user”的数据库 在“user”数据库中创建一个名为“user_info…

    Java 2023年6月15日
    00

  • 小程序实现授权登陆的解决方案

    小程序实现授权登录的解决方案是比较复杂的，需要涉及到小程序端和服务端两个方面。在授权登录的过程中，小程序端需要获取用户的授权信息，并将授权信息发送给服务端进行校验，服务端校验成功之后再将返回的用户信息返回给小程序端。以下是实现授权登录的完整攻略： 步骤一：获取用户授权 在小程序中调用 wx.login() 方法获取 code，这个 code 会在后续用来获取…

    Java 2023年5月23日
    00

  • java 制作验证码并进行验证实例详解

    Java 制作验证码并进行验证实例详解 验证码（CAPTCHA）是一种人机识别技术，用于区分网站的访问者是否为真实的人类用户。在 Java 中，开发者可以通过以下步骤来生成验证码并进行验证： 1. 生成验证码 生成验证码的方法有很多，流行的方法包括使用 Jigsaw 插图、数学公式等等，本文介绍如何使用 Java 的内置工具类来生成随机字符的验证码。 pub…

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