springboot集成shardingsphere-jdbc之读写分离配置_Husky_jzq的博客-程序员宅基地

技术标签: MySQL  mysql  ShardingSphere  读写分离  

关于MySQL主从搭建,可以参考我的文章学习docker第五天之MySQL主从复制搭建_Husky_jzq的博客-程序员宅基地

首先导入相关的pom依赖

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>

        <dependency>
            <groupId>org.apache.shardingsphere</groupId>
            <artifactId>shardingsphere-jdbc-core-spring-boot-starter</artifactId>
            <version>5.1.0</version>
        </dependency>


        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.1</version>
        </dependency>

        <dependency>
            <groupId>cn.hutool</groupId>
            <artifactId>hutool-all</artifactId>
            <version>5.7.22</version>
        </dependency>

        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </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>

导入依赖后配置shardingsphere-jdbc的yml文件

spring:
  shardingsphere:
    # 数据源配置
    datasource:
      # 数据源名称,多数据源以逗号分隔
      names: master,slave
      master:
        # 数据库连接池类名称
        type: com.zaxxer.hikari.HikariDataSource
        # 数据库驱动类名
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://ip:端口/数据库?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: root
      slave:
        # 数据库连接池类名称
        type: com.zaxxer.hikari.HikariDataSource
        # 数据库驱动类名
        driver-class-name: com.mysql.cj.jdbc.Driver
        jdbc-url: jdbc:mysql://ip:端口/数据库?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=Asia/Shanghai
        username: root
        password: root
    # 规则配置
    rules:
      readwrite-splitting:
        load-balancers:
          ms:
            type: ROUND_ROBIN
            props:
              workId: 1
        data-sources:
          ms:
            type: Static
            load-balancer-name: round-robin
            props:
              write-data-source-name: master
              read-data-source-names: slave
    # 属性配置
    props:
      # 展示修改以后的sql语句
      sql-show: true
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

然后测试读写情况,读是在slave,写是在master

 

 至此,读写分离集成成功!

笔者此次读写分离是一主一从,既然读写分离就涉及事务问题。在配置成功后发现使用事务失败@Transactional。基于之前项目配置过一次双数据源和本次读写分离的形式,笔者认为,既然是一主一从,按理说只需要指定主库进行事务即可(因为从库会同步主库)。所以在进行相关查阅后,进行事务管理器的配置,指定@Transactional的事务为主库事务即可。相关配置如下:

 

 进过测试,事务成功

 主库数据

 从库数据

 

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/GINNOSQL/article/details/123877203

智能推荐

qt停车场课设 第一次版本_qt4停车场-程序员宅基地

UI设计原型代码card.h`.#ifndef CARD_H#define CARD_H#include<QString>class card{public: card(); void getcard(QString name1,QString number1,QString password1,QString telephone1); void invest(double money1); double moneyleft(); vo_qt4停车场

Conda:误解与迷思_conda-forge-程序员宅基地

翻译自这里我试着尽可能简洁,但如果你想要跳过这篇文章,并得到讨论的要点,你可以阅读每个标题以及下面的摘要。神话#1:Conda是一个发行版,不是一个软件包管理器现实:Conda是一个包管理器;Anaconda是一个发行包。虽然Conda与Anaconda一起包装,但两者是具有不同目标的不同实体。软件发布包是预先构建和预配置的包的集合,其可以在系统上安装和使用。包管理器是自动化安装,更新和删除包的过程_conda-forge

Nuke python脚本开发 01-程序员宅基地

Nuke使用python和TCL作为脚本,这个教程主要介绍python。首先介绍Nuke如何加载脚本。脚本想要加载运行,就必须能被Nuke找到。Nuke提供了一个插件路径列表来记录脚本的位置,但是其加载过程是按照列表逆序执行的。下面是linux上的情况:nuke脚本路径的默认顺序为:/home/nukeuser/.nuke/usr/local/Nuke/6.2/pl

JDBC连接MYSQL-程序员宅基地

//A.javaimport java.sql.*;class A { public static void main (String args[]) { try { // 加载驱动,对本程序,驱动目录为./org/gjt/mm/mysql/Driver,要捕捉ClassNotFoundException异常 Class.forName("org.gjt.

linux报错之--->export `=' not a valid identifier的一般原因-程序员宅基地

export `=' not a valid identifier的一般原因 原因就是你修改的 /etc/profile 文件里你加过空格我的代码如下:export JAVA_HOME = /usr/java/jdk1.7.0_75export PATH = $JAVA_HOME/bin:$PATHexport CLASSPATH = .:$JAVA_HO

实验记录-BLDC六步法驱动-高侧全斩波与半斩波驱动效果对比_高侧全斩波(互补)与半斩波驱动效果对比-程序员宅基地

在无刷电机驱动过程中,最简单的驱动方式是利用霍尔传感器实现BLDC的六步换相法驱动,硬件上,由三个半桥组成了BLDC的三相换相电路。任意时刻只有两个半桥处于工作状态,其中一个半桥的上桥臂输出PWM波,另一个半桥的下桥臂完全打开。在某一个半桥(半桥A)的高侧动作时该半桥的上桥臂通过PWM波控制。另一个半桥(半桥B)的上桥臂完全关断,下桥臂完全打开。我们通过该笔半桥A的占空比实现了电机的功率控制。那么_高侧全斩波(互补)与半斩波驱动效果对比

随便推点

【NEO4J数据库】编写自定义过程/函数-程序员宅基地

1.NEO4J 过程:使用CALL语句调用,可以选择添加参数,大多数过程返回固定列的记录流。例如,调用数据库的内嵌过程,列出数据库的所有标签CALL db.labels2.NEO4J 可以编写自定义过程。步骤为:1)编写类和方法。关键点:a、对方法使用@Procedure 注解 b、方法的返回值是Stream&lt;T&gt;package example;import java.util....

eclipse使用 console 查看异常信息 如何组织窗口 工作效率-程序员宅基地

1.组织窗口,把最常用放到不同的位置都显示出来 2.把console的字体变小 preference->font->搜索console 在console里点右键,preferences里面有个Console buffer size(characters),默认只有80000,你可以最大设置到1000000 这样可以提高缓冲区的大小 3.提高效率 copy qualified name 可

监听Gps设置变化方法二_mode_changed_action-程序员宅基地

上一篇提到用内容观察者通过来监听数据库变化获取GPS状态,其实在GPS状态或模式改变时,会发出相应的广播LocationManager.MODE_CHANGED_ACTION,LocationManager.PROVIDERS_CHANGED_ACTION这里贴出关键代码:////注册广播IntentFilter filter = new IntentFilter();filt_mode_changed_action

自学Python去面试,月薪为何仅3K?面试官问题解析!-程序员宅基地

关注「实验楼」,每天分享一个项目教程 很多人认为Python语言简单(实际真的那么简单吗?语法简洁不代表容易学),都去自学Python编程语言,然后寻思出去找一份好的...

Unity3D UGUI按钮长按事件_ugui 和 ipointerdown冲突-程序员宅基地

**转载**原理:处理 Unity 的点击事件IPointerDownHandlerIPointerUpHandlerIPointerExitHandler在鼠标 按下的状态、松开、以及鼠标离开的状态来进行状态控制。代码:using UnityEngine;using UnityEngine.Events;using UnityEngine.EventSystems;using Syste_ugui 和 ipointerdown冲突

c语言实现读取csv文件,并对数据进行分析。_读取'visual.csv'文件,进行描述统计分析;在一个figure的两个子图里完成北京、上海各项-程序员宅基地

总代码:```c在这里插入代码片#include <stdio.h>#include <stdlib.h>#include <string.h>struct Student{char shuzu[20];}students[8][21];int main(){int i=0,k=0,q=0;FILE *fp = NULL;char *line,*record;char buffer[1024];float a[8][21]={0};if (_读取'visual.csv'文件,进行描述统计分析;在一个figure的两个子图里完成北京、上海各项支出的2个垂直条形图;计算各个城市各项支出占总支出的百分比;将百分比数据框融合为长格式,并绘制不少于两种的统计图(任选)

推荐文章

热门文章

相关标签