SpringBoot整合Sharding-JDBC實現(xiàn)MySQL8讀寫分離

更新時間：2021年07月29日 14:54:55 作者：張紅塵

本文是一個基于SpringBoot整合Sharding-JDBC實現(xiàn)讀寫分離的極簡教程，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的可以了解一下

一.前言

這是一個基于SpringBoot整合Sharding-JDBC實現(xiàn)讀寫分離的極簡教程，筆者使用到的技術及版本如下：

SpringBoot 2.5.2
MyBatis-Plus 3.4.3
Sharding-JDBC 4.1.1
MySQL8集群（看筆者前一篇文章有部署教程）

二.項目目錄結構

三.pom文件

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.5.2</version>
        <relativePath/> <!-- lookup parent from repository -->
    </parent>
    <groupId>xyz.hcworld</groupId>
    <artifactId>sharding-jdbc-demo</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <name>sharding-jdbc-demo</name>
    <description>多數(shù)據(jù)源切換實例</description>
    <properties>
        <java.version>1.8</java.version>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--   mybatis-plus依賴     -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.4.3</version>
        </dependency>
        <!--    mysql驅動    -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!--  sharding-jdbc（多數(shù)據(jù)源切換）     -->
        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>sharding-jdbc-spring-boot-starter</artifactId>
            <version>4.1.1</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <excludes>
                        <exclude>
                            <groupId>org.projectlombok</groupId>
                            <artifactId>lombok</artifactId>
                        </exclude>
                    </excludes>
                </configuration>
            </plugin>
        </plugins>
    </build>

</project>

四.配置文件（基于YAML）及SQL建表語句

spring:
  main:
    allow-bean-definition-overriding: true
  #顯示sql
  shardingsphere:
    props:
      sql:
        show: true
    masterslave:
      #配置主從名稱
      name: ms
      #置主庫master,負責數(shù)據(jù)的寫入
      master-data-source-name: ds1
      #配置從庫slave節(jié)點
      slave-data-source-names: ds2,ds3
      #配置slave節(jié)點的負載均衡均衡策略,采用輪詢機制，有兩種算法：round_robin(輪詢)和random(隨機)
      load-balance-algorithm-type: round_robin
    sharding:
      #配置默認數(shù)據(jù)源ds1 默認數(shù)據(jù)源,主要用于寫
      default-data-source-name: ds1
    # 配置數(shù)據(jù)源
    datasource:
      names: ds1,ds2,ds3
      #master-ds1數(shù)據(jù)庫連接信息
      ds1:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://192.168.2.142:3307/sharding-jdbc-db?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
        maxPoolSize: 100
        minPoolSize: 5
      #slave-ds2數(shù)據(jù)庫連接信息
      ds2:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://192.168.2.142:3308/sharding-jdbc-db?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
        maxPoolSize: 100
        minPoolSize: 5
      #slave-ds3數(shù)據(jù)庫連接信息
      ds3:
        type: com.zaxxer.hikari.HikariDataSource
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://192.168.2.142:3309/sharding-jdbc-db?useUnicode=true&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: 123456
        maxPoolSize: 100
        minPoolSize: 5
#mybatis-plus配置
mybatis-plus:
  type-aliases-package: xyz.hcworld.demo.model
  mapper-locations: classpath*:/mapper/**Mapper.xml

CREATE TABLE `t_user` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `nickname` varchar(100) DEFAULT NULL,
  `password` varchar(100) DEFAULT NULL,
  `sex` int(11) DEFAULT NULL,
  `birthday` varchar(50) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4;

五.Mapper.xml文件及Mapper接口

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="xyz.hcworld.demo.mapper.UserMapper">

    <update id="addUser">
        INSERT INTO t_user(nickname,PASSWORD,sex,birthday) VALUES(#{nickname},#{password},#{sex},#{birthday})
    </update>

    <select id="findUsers" resultType="xyz.hcworld.demo.model.User">
        SELECT
            id,
            nickname,
            PASSWORD,
            sex,
            birthday
        FROM t_user;
    </select>

</mapper>

package xyz.hcworld.demo.mapper;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.springframework.stereotype.Component;
import xyz.hcworld.demo.model.User;

import java.util.List;

/**
 * @ClassName: UserMapper
 * @Author: 張紅塵
 * @Date: 2021-07-20
 * @Version： 1.0
 */
@Component
public interface UserMapper  extends BaseMapper<User> {


    void addUser(User user);


    List<User> findUsers();
}

六 .Controller及Mocel文件

package xyz.hcworld.demo.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import xyz.hcworld.demo.mapper.UserMapper;
import xyz.hcworld.demo.model.User;

import java.security.SecureRandom;
import java.util.List;

/**
 * @ClassName: UserController
 * @Author: 張紅塵
 * @Date: 2021-07-20
 * @Version： 1.0
 */
@RestController
@RequestMapping("/api/user")
public class UserController {
    @Autowired
    private UserMapper userMapper;

    @PostMapping("/save")
    public String addUser() {
        User user = new User();
        user.setNickname("zhangsan" + new SecureRandom().nextInt());
        user.setPassword("123456");
        user.setSex(1);
        user.setBirthday("1997-12-03");
        userMapper.addUser(user);
        return user.toString();
    }

    @GetMapping("/findUsers")
    public List<User> findUsers() {
        return userMapper.findUsers();
    }
}

package xyz.hcworld.demo.model;

import com.baomidou.mybatisplus.annotation.IdType;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * @ClassName: User
 * @Author: 張紅塵
 * @Date: 2021-07-20
 * @Version： 1.0
 */
@Data
@TableName("t_user")
public class User {

    private static final long serialVersionUID = 1L;

    @TableId(value = "id", type = IdType.AUTO)
    private Integer id;

    private String nickname;

    private String password;

    private Integer sex;

    private String birthday;
}

七.結果

從結果可以看出，寫入操作全部通過ds1數(shù)據(jù)庫（master）數(shù)據(jù)庫完成，而讀操作因為設置了輪詢的緣故，由ds2（slaver）、ds3（slaver2）數(shù)據(jù)庫完成。這樣就實現(xiàn)了基于一主二從的數(shù)據(jù)庫集群的讀寫分離操作。

八.Sharding-JDBC不同版本上的配置

網(wǎng)上Sharding-JDBC的教程多為4.0.0.RC1版本，筆者使用的是最新的4.1.1所以
在該部分數(shù)據(jù)庫地址在4.1.1為jdbc-url在4.0.0.RC1上需要改為url否則會啟動失敗

jdbc-url: jdbc:mysql://XXXX/XXXX

且網(wǎng)上教程多為properties文件，筆者將其轉變?yōu)閅AML文件更加能直觀感受

項目下載

GitHub:https://github.com/z875479694h/sharding-jdbc-demo

到此這篇關于SpringBoot整合Sharding-JDBC實現(xiàn)MySQL8讀寫分離的文章就介紹到這了,更多相關SpringBoot Sharding-JDBC MySQL8讀寫分離內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

java多線程創(chuàng)建及線程安全詳解
多線程是日常開發(fā)中的常用知識，也是難用知識。通這篇文章主要給大家介紹了關于java多線程創(chuàng)建及線程安全的相關資料，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2021-05-05
Java源碼解析之TypeVariable詳解
這篇文章主要介紹了Java源碼解析之TypeVariable詳解，具有一定參考價值，需要的朋友可以了解下。
2017-10-10
SpringCloud?Eureka服務注冊中心應用入門詳解
這篇文章主要介紹了Spring?Cloud?Eureka服務注冊中心入門流程分析,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下
2022-07-07
一個Servlet是如何處理多個請求的?
以前我一直以為一個Servlet只能處理一個請求,后來發(fā)現(xiàn)是自己太菜了,可以借助攜帶一個參數(shù)來完成多個請求的處理,根據(jù)參數(shù)的不同,在核心的service方法中調用不同的業(yè)務方法,來實現(xiàn)處理多個servlet請求的目的,廢話不多說,直接上代碼,需要的朋友可以參考下
2021-06-06
JAVA中的final關鍵字用法實例詳解
這篇文章主要介紹了JAVA中的final關鍵字用法,結合實例形式較為詳細的分析了Java中的final關鍵字用于修飾數(shù)據(jù),方法及類的具體使用技巧,需要的朋友可以參考下
2015-12-12
java list隨機抽取元素的案例
這篇文章主要介紹了java list隨機抽取元素的案例，具有很好的參考，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧
2020-08-08
如何解決java.util.zip.ZipFile解壓后被java占用問題
這篇文章主要介紹了如何解決java.util.zip.ZipFile解壓后被java占用問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-06-06
java中幾種http請求方式示例詳解
在日常工作和學習中有很多地方都需要發(fā)送HTTP請求,下面這篇文章主要給大家介紹了關于java中幾種http請求方式的相關資料,文中通過代碼介紹的非常詳細,需要的朋友可以參考下
2023-11-11
Java中初始化List的5種方法示例
這篇文章主要給大家介紹了關于Java中初始化List的5種方法，文中通過示例代碼介紹的非常詳細，對大家學習或使用java具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2018-11-11
Java之next()、nextLine()區(qū)別及問題解決
這篇文章主要介紹了Java之next()、nextLine()區(qū)別及問題解決,本篇文章通過簡要的案例,講解了該項技術的了解與使用,以下就是詳細內容,需要的朋友可以參考下
2021-08-08