Spring | 基于SpringBoot的多数据源实战 - 使用seata实现多数据源的全局事务管理

news2024/12/25 23:53:10

Spring | 基于SpringBoot的多数据源实战 - 使用seata实现多数据源的全局事务管理

  • 引言
      • 1.1 多数据源的必要性
      • 1.2 多数据源的应用场景
  • 实战演示
    • 2.1 创建实体类
    • 2.2 配置数据源
    • 2.3 实现数据源配置类
    • 2.4 配置Repository类
    • 2.5 运行与验证
  • 事务管理与数据一致性
      • 3.1 事务管理
      • 3.2 使用Seata完成全局事务管理
        • 3.2.1 安装seata-server
        • 3.2.2 配置IDEA
  • 总结
  • 参考文献

引言

在软件开发中，多数据源的应用越来越普遍，特别是在微服务架构和业务模块化的场景下。多数据源能够让不同的业务模块和微服务拥有各自独立的数据存储，大大提高了系统的灵活性和可维护性。本文将深入探讨多数据源的配置和实施，以及在Spring Boot环境下，如何通过Spring Data JPA和Gradle来实现多数据源的管理和应用。

本文讨论的多数据源指的是关系型数据库，即一个服务有多个这样的数据库。

1.1 多数据源的必要性

随着业务的发展和演变，单一数据源已经无法满足多元化和复杂化的业务需求。多数据源的应用不仅能够更好地支持业务的发展，还能够有效地实现资源隔离和管理，减少系统的耦合度，提高服务的稳定性和可用性。使用多数据源可以有如下几个优点：

  1. 性能优化：不同的关系型数据库有各自的优势和特性，一些数据库更适合读取操作，而另一些数据库更适合写入操作。通过将读写负载分配到不同的数据库实例上，可以优化性能。
  2. 数据隔离：在一个系统中，有些数据可能更重要，需要更高的安全性和可靠性；而其他数据可能不太重要，可以容忍一定程度的数据丢失。这个时候，将不同类型的数据存储在不同的数据库中，可以实现数据的隔离，满足不同的数据安全和可靠性需求。
  3. 业务逻辑隔离：在复杂的系统中，不同的模块或子系统可能有不同的业务逻辑和数据处理需求。为不同的模块或子系统使用不同的数据库，可以简化系统的设计和维护。

1.2 多数据源的应用场景

常见到的几个大型项目的业务场景如下：

  • 金融系统：金融系统通常要处理大量的事务数据和报表数据。将事务处理和报表生成分配到不同的数据库可以优化性能和简化系统设计。
  • 电商平台：电商平台通常会涉及到用户信息、订单数据、商品数据等多种类型的数据。为这些不同类型的数据使用不同的数据库实例可以实现数据和业务逻辑的隔离。
  • ERP系统：企业资源规划（ERP）系统通常包含多个模块，例如财务、人力资源和供应链管理。为每个模块使用独立的数据库可以使得开发和维护更加便捷。

以下所有示例均已上传至Github上，大家可以将项目拉取到本地进行运行
Github示例（如果对Gradle还不熟练，建议翻看我之前的文章）：gradle-spring-boot-demo

实战演示

本章将详细说明如何在Spring Boot项目中实施多数据源。我们会一步一步地演示如何配置两个H2数据库实例作为我们的数据源。

2.1 创建实体类

首先，我们创建两个实体类，一个用于主数据源，一个用于次数据源。我们在这里以User实体为例。请确保您的实体类在正确的包中。

// 主数据源实体
@Entity
@Data
@Table(name = "users")
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String name;
    private String email;
}

// 次数据源实体
@Entity
@Table(name = "orders")
@Data
public class Order {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String orderNumber;
    private Double amount;
}

2.2 配置数据源

接下来，我们需要在application.yml中配置两个数据源：

spring:
  datasource:
    primary:
      jdbc-url: jdbc:h2:file:./multi-datasource/data/testdb1
      driver-class-name: org.h2.Driver
      username: sa
      password: password
    secondary:
      jdbc-url: jdbc:h2:file:./multi-datasource/data/testdb2
      driver-class-name: org.h2.Driver
      username: sa
      password: password
  h2:
    console:
      enabled: true
  jpa:
    hibernate:
      ddl-auto: update
    show-sql: true

这里，我们配置了两个H2数据库实例，一个作为主数据源，一个作为次数据源。

2.3 实现数据源配置类

为了实现多数据源，我们需要创建两个配置类，PrimaryDataSourceConfig和SecondaryDataSourceConfig，并在其中定义DataSource、EntityManagerFactory和TransactionManager的beans。

@Configuration
@EnableJpaRepositories(
        basePackages = "org.kfaino.datasource.repository.primary")
@EntityScan(basePackages = {"org.kfaino.datasource.entity.primary"})
public class PrimaryDataSourceConfig {

    @Primary
    @Bean(name = "primaryDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.primary")
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create().build();
    }

    @Primary
    @Bean(name = "entityManagerFactory")
    public LocalContainerEntityManagerFactoryBean primaryEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("primaryDataSource") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("org.kfaino.datasource.entity.primary") // 设置实体类的包路径
                .persistenceUnit("primary")
                .properties(hibernateProperties())
                .build();
    }

    private Map<String, Object> hibernateProperties() {
        Map<String, Object> properties = new HashMap<>();
        properties.put("hibernate.hbm2ddl.auto", "update");
        properties.put("hibernate.show_sql", true);
        return properties;
    }

    @Primary
    @Bean(name = "transactionManager")
    public PlatformTransactionManager transactionManager(
            @Qualifier("entityManagerFactory") EntityManagerFactory entityManagerFactory) {
        return new JpaTransactionManager(entityManagerFactory);
    }

}

@Configuration
@EnableJpaRepositories(
        basePackages = "org.kfaino.datasource.repository.secondary",
        entityManagerFactoryRef = "secondaryEntityManagerFactory",
        transactionManagerRef = "secondaryTransactionManager")
@EntityScan(basePackages = {"org.kfaino.datasource.entity.primary"})
public class SecondaryDataSourceConfig {

    @Bean(name = "secondaryDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.secondary")
    public DataSource secondaryDataSource() {
        return DataSourceBuilder.create().build();
    }


    @Bean(name = "secondaryEntityManagerFactory")
    public LocalContainerEntityManagerFactoryBean secondaryEntityManagerFactory(
            EntityManagerFactoryBuilder builder,
            @Qualifier("secondaryDataSource") DataSource dataSource) {
        return builder
                .dataSource(dataSource)
                .packages("org.kfaino.datasource.entity.secondary") // 设置实体类的包路径
                .persistenceUnit("secondary")
                .properties(hibernateProperties())
                .build();
    }

    private Map<String, Object> hibernateProperties() {
        Map<String, Object> properties = new HashMap<>();
        properties.put("hibernate.hbm2ddl.auto", "update");
        properties.put("hibernate.show_sql", true);
        return properties;
    }

    @Bean(name = "secondaryTransactionManager")
    public PlatformTransactionManager secondaryTransactionManager(
            @Qualifier("secondaryEntityManagerFactory") EntityManagerFactory secondaryEntityManagerFactory) {
        return new JpaTransactionManager(secondaryEntityManagerFactory);
    }

}

💡 温馨提示： 请注意，在这个配置类中，我们为两个数据源分别定义了DataSource、EntityManagerFactory和TransactionManager。@Primary注解用于指定主数据源相关的beans。

2.4 配置Repository类

我们需要创建两个Repository类，每个类操作一个数据源的实体。在这里，我们可以使用Spring Data JPA的JpaRepository接口。

// 主数据源Repository
@Repository
public interface UserRepository extends JpaRepository<User, Long> {}

// 次数据源Repository
@Repository
public interface OrderRepository extends JpaRepository<Order, Long> {}

2.5 运行与验证

运行Spring Boot应用，在控制台能够看到两个数据源都被成功配置。
在这里插入图片描述
并且可以通过相应的Repository类进行数据操作。我们写个Controller来和数据库进行交互，限于篇幅，其它代码我已省略，如需完整实例，可以直接从GitHub仓库下载：

@RestController
@RequestMapping("user")
public class UserController {
    @Resource
    private UserService userService;
    @Resource
    private OrderService orderService;
    @Resource
    private UserOrderService userOrderService;
    
    @PostMapping("/createUser")
    public User createUser(@Valid @RequestBody UserDTO userDTO) {
        return userService.createUser(userDTO);
    }

    @PostMapping("/createOrder")
    public Order createOrder(@Valid @RequestBody OrderDTO orderDTO) {
        return orderService.createOrder(orderDTO);
    }


    @PostMapping("/createMix")
    public User createMix(@Valid @RequestBody UserOrderDTO userOrderDTO) {
        return userOrderService.createUserAndOrder(userOrderDTO);
    }
}

接着执行这三个请求：
在这里插入图片描述
两张不同数据源的表均被创建完毕：
在这里插入图片描述
在这里插入图片描述

💡 注意： 在进行实际的数据操作时，如果需要特定的事务管理器，可以在Service类或Repository类上使用@Transactional(transactionManager = "指定的事务管理器")来进行指定。

事务管理与数据一致性

3.1 事务管理

在多数据源中，事务管理是至关重要的，它确保我们的系统在执行多个操作时能够维持数据的完整性和一致性。我们用代码演示一个案例，我们在UserOrderService中故意写一个会报错代码：

    @Transactional("transactionManager")
    public User createUserAndOrder(UserOrderDTO userOrderDTO) {
        OrderDTO orderDTO = new OrderDTO();
        BeanUtils.copyProperties(userOrderDTO, orderDTO);
        orderService.createOrder(orderDTO);
        // 报错
        int i = 1/0;
        User user = new User();
        BeanUtils.copyProperties(userOrderDTO, user);
        userRepository.save(user);
        return user;
    }

我们调用下该方法：
在这里插入图片描述
在这里插入图片描述
在这里插入图片描述

由于使用的是不同的事务管理器，尽管transactionManager事务管理器回滚了，我们依然可以看到orders表被提交：
在这里插入图片描述

3.2 使用Seata完成全局事务管理

💡本节案例只是简单的全局事务管理，为了演示测试方便，除了seata本身并未引入其它中间件

3.2.1 安装seata-server

要想使用seata需要先安装seata-server，下载路径如下：https://github.com/seata/seata/releases 我这里使用的是window系统，下载zip即可：
在这里插入图片描述
下载后双击运行：
在这里插入图片描述
在控制台看到seata正常启动了：
在这里插入图片描述

3.2.2 配置IDEA

  1. 引入seata依赖，我这里使用的是gradle，只需要引入这行即可：

        implementation 'io.seata:seata-spring-boot-starter:1.7.1' // 请检查最新的版本号

  2. 新增application.yml配置

    seata:
  enabled: true
  application-id: multi-datasource
  tx-service-group: my_test_tx_group
  enable-auto-data-source-proxy: true
  config:
    type: file
    file:
      data-file: classpath:file.conf
  registry:
    type: file
    file:
      data-file: classpath:registry.conf

  3. 新增file.conf文件

    service {
  # tx-service-group映射
  vgroupMapping.my_test_tx_group = "default"
  vgroupMapping.default = "default"

  # Seata Server的地址，是你的Seata Server所在的IP地址和端口
  default.grouplist = "127.0.0.1:8091"

  # 其他相关配置
  enableDegrade = false
  disableGlobalTransaction = false
}

store {
  mode = "file"
  file {
    # 本地事务日志存储的目录
    dir = "sessionStore"
  }
}

  4. 新增registry.conf文件

    registry {
  type = "file"

  file {
    name = "file.conf"
  }
}

config {
  type = "file"
  file {
    name = "file.conf"
  }
}

  5. UserOrderService新增如下方法：

        @GlobalTransactional
    public void createUserAndOrderByGlobalTransaction(UserOrderDTO userOrderDTO) {
        OrderDTO orderDTO = new OrderDTO();
        BeanUtils.copyProperties(userOrderDTO, orderDTO);
        orderService.createOrder(orderDTO);
        // 报错
        int i = 1/0;

        UserDTO userDTO = new UserDTO();
        BeanUtils.copyProperties(userOrderDTO, userDTO);
        userService.createUser(userDTO);
    }

  6. 新增controller方法：

        @PostMapping("/createMixGlobalTransaction")
    public void createMixByGlobalTransaction(@Valid @RequestBody UserOrderDTO userOrderDTO) {
        userOrderService.createUserAndOrderByGlobalTransaction(userOrderDTO);
    }

  7. 请求controller
    在这里插入图片描述
    执行结果如下：
    在这里插入图片描述
    在这里插入图片描述
    在这里插入图片描述
    全局事务生效，事务被回滚。

总结

至此，本章结束。本文深入探讨了多数据源的优势和应用常见，并为你展示了在Spring Boot如何进行多数据源的使用和整合。同时，我们也探讨了多数据源中存在的事务问题，并通过seata的全局事务管理解决这个问题。

参考文献

  1. SpringBoot如何整合多个数据源，看这篇就够了 - 腾讯云
  2. Spring Boot 整合多数据源，这才叫优雅 - 掘金
  3. springboot整合mybatis跨库操作、配置多个数据源DataSource - CSDN
  4. SpringBoot整合MyBatis多数据源 - 腾讯云
  5. 5分钟学会springboot整合多数据源 - 思否
  6. springboot(七)：springboot+mybatis多数据源最简解决方案 - 阿里云

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1051112.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

长假，GPT来敲(Jué)门(Fén)

长假，GPT来敲(Jué)门(Fén)

引 马上十一了&#xff0c;本拐在干了XX和XX事情以后&#xff0c;开始划水&#xff0c;欢天喜地的等放假。 然后&#xff0c;GPT4说更新了&#xff0c;据说加了一个读图的功能&#xff0c;本拐不以为然&#xff0c;不就是什么文生图&#xff0c;图生文么&#xff0c;TOOOLD。 不…
阅读更多...
案例题-系统开发

案例题-系统开发

案例题-系统开发 结构化分析方法概述面向对象分析方法真题1真题2 结构化分析方法概述 面向对象分析方法 了解一下符号就行 依赖关系&#xff1a;一个事务的变化影响另外一个事务的变化 泛化关系&#xff0c;父类子类 聚合&#xff1a;部分和整体之间的生命周期不同 组合&#x…
阅读更多...
Cache系列直播，这次真的来了！

Cache系列直播，这次真的来了！

1、要学cache&#xff0c;一大堆一大堆待讨论的问题。例如近期的一些问题&#xff1a; L1、L2、L3 cache的替换策略是怎样的&#xff1f;什么类型的内存永远不会进L3 cache&#xff1f;L3 cache一般都是多大&#xff1f;L3 cache的组织形式一般是怎样的&#xff1f;什么是cache…
阅读更多...
MySQL体系结构和四层架构介绍

MySQL体系结构和四层架构介绍

MySQL体系结构图如下&#xff1a; 四层介绍 1. 连接层&#xff1a; 它的主要功能是处理客户端与MySQL服务器之间的连接(比如Java应用程序通过JDBC连接MySQL)。当客户端应用程序连接到MySQL服务器时&#xff0c;连接层对用户进行身份验证、建立安全连接并管理会话状态。它还处理…
阅读更多...
医疗图像分割指标

医疗图像分割指标

医疗图像其中两种图像格式&#xff1a;MRI&#xff08;Magnetic Resonance Imaging&#xff0c;磁共振成像&#xff09;、CT&#xff08;Computed Tomography&#xff0c;计算机断层&#xff09;&#xff0c;常存成 .nii.gz 格式。都是 3D 的 H W L H \times W \times L HWL…
阅读更多...
数字孪生智慧能源：风光储一体化能源中心

数字孪生智慧能源：风光储一体化能源中心

自“双碳”目标提出以来&#xff0c;我国能源产业不断朝着清洁低碳化、绿色化的方向发展。其中&#xff0c;风能、太阳能等可再生能源在促进全球能源可持续发展、共建清洁美丽世界中被寄予厚望。风能、太阳能具有波动性、间歇性、随机性等特点&#xff0c;主要通过转化为电能再…
阅读更多...
jvm内存分配与回收策略

jvm内存分配与回收策略

自动内存管理 解决两个问题 自动给对象分配内存 对象一般堆上分配&#xff08;而实际上也有可能经过即时编译后被拆散为标量类型并间接地在栈上分配&#xff09; 新生对象通常会分配在新生代&#xff0c;少数情况下&#xff08;例如对象大小超过一定阈值&#xff09;也可能…
阅读更多...
[H5动画制作系列 ]变量,帧频,监听器等的生命周期基础测试

[H5动画制作系列 ]变量,帧频,监听器等的生命周期基础测试

模式:按照上述抓图,actions层&#xff0c;1帧,写初始化代码,10帧写返回代码到2帧代码,2-10帧之间一直循环。1帧及10帧代码如下&#xff1a; 如果程序在1-10之间循环,会反复创建变量i,多个监听器等。所以,第一帧最好执行一次即可&#xff0c;程序在2-10帧之间一直循环。
阅读更多...
《Upload-Labs》01. Pass 1~13

《Upload-Labs》01. Pass 1~13

Upload-Labs 索引前言Pass-01题解 Pass-02题解总结 Pass-03题解总结 Pass-04题解 Pass-05题解总结 Pass-06题解总结 Pass-07题解总结 Pass-08题解总结 Pass-09题解 Pass-10题解 Pass-11题解 Pass-12题解总结 Pass-13题解 靶场部署在 VMware - Win7。 靶场地址&#xff1a;https…
阅读更多...
Leetcode290. 单词规律

Leetcode290. 单词规律

给定一种规律 pattern 和一个字符串 s &#xff0c;判断 s 是否遵循相同的规律。 这里的 遵循 指完全匹配&#xff0c;例如&#xff0c; pattern 里的每个字母和字符串 s 中的每个非空单词之间存在着双向连接的对应规律。 解题思路&#xff1a;哈希 力扣&#xff08;LeetCode&…
阅读更多...
软件测试中的测试工具和自动化测试

软件测试中的测试工具和自动化测试

1. 测试工具 测试工具也分为不同人员使用的 开发人员&#xff1a;测试框架&#xff0c;编写测试用例&#xff1b;各类线上dump分析工具如windgb&#xff1b;开发时的集成IDE工具如Visual Studio&#xff0c;idea等等 面向不同测试需求的测试工具 软件测试是软件开发生命周期…
阅读更多...
网络子网划分练习

网络子网划分练习

网络子网划分练习 1.背景&#xff1a; 在一个仓储企业网络拓朴结构如图1-所示&#xff0c;该企业占地500亩。有五层办公楼1栋&#xff0c;大型仓库10栋。每栋仓库内、外部配置视频监控16台&#xff0c;共计安装视频监控160台&#xff0c;Switch A、服务器、防火墙、管理机、Rou…
阅读更多...
UE4/5数字人MetaHuman通过已有动画进行修改

UE4/5数字人MetaHuman通过已有动画进行修改

目录 通过已有动画修改动画 开始制作 创建一个关卡序列 将动画序列烘焙到控制绑定 打开我们自己创建的动画序列 之后便是烘焙出来 通过已有动画修改动画 首先架设我们已经有相关的MetaHuman的动画&#xff0c;但是这个动画因为是外部导入进来的&#xff0c;所以可能会出…
阅读更多...
基于微信小程序的刷题考试系统设计与实现(适用于各类考试类、答题类程序)

基于微信小程序的刷题考试系统设计与实现(适用于各类考试类、答题类程序)

文章目录 前言系统主要功能&#xff1a;具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计…
阅读更多...
C/C++跨平台构建工具CMake入门

C/C++跨平台构建工具CMake入门

文章目录 1.概述2.环境准备2.1 安装编译工具2.2 安装CMake 3.编译一个示例程序总结 1.概述 本人一直对OpenGL的3d渲染很感兴趣&#xff0c;但是苦于自己一直是Android开发&#xff0c;没有机会接触这方面的知识。就在最近吗&#xff0c;机会来了&#xff0c;以前一个做3D渲染的…
阅读更多...
TouchGFX之字体缓存

TouchGFX之字体缓存

使用二进制字体需要将整个字体加载到存储器。 在某些情况下&#xff0c;如果字体很大&#xff0c;如大字号中文字体&#xff0c;则这样做可能不可取。 字体缓存使应用能够从外部存储器只能加载显示字符串所需的字母。 这意味着整个字体无需保存到在可寻址闪存或RAM上&#xff…
阅读更多...
JMM与JUC

JMM与JUC

1.JMM 问题1&#xff1a;请你谈谈你对Volatile的理解 Volatile 是java虚拟机提供轻量级的同步机制 1. 保证可见性 2. 不保证原子性 3. 禁止指令重排 1.1、什么是JMM JMM Java内存模型 不存在的东西&#xff0c;概念&#xff01;约定 &#xff01; 1.2、关于JMM的一些同…
阅读更多...
python使用mitmproxy和mitmdump抓包之拦截和修改包（四）

python使用mitmproxy和mitmdump抓包之拦截和修改包（四）

我认为mitmproxy最强大的地方&#xff0c;就是mitmdump可以结合python代码&#xff0c;灵活拦截和处理数据包。 首先&#xff0c;mitmdump的路径如下&#xff1a;&#xff08;使用pip3 install mitmproxy安装的情况&#xff0c;参考我的文章python使用mitmproxy和mitmdump抓包…
阅读更多...
【C++数据结构】二叉树搜索树【完整版】

【C++数据结构】二叉树搜索树【完整版】

目录 一、二叉搜索树的定义 二、二叉搜索树的实现&#xff1a; 1、树节点的创建--BSTreeNode 2、二叉搜索树的基本框架--BSTree 3、插入节点--Insert 4、中序遍历--InOrder 5、 查找--Find 6、 删除--erase 完整代码&#xff1a; 三、二叉搜索树的应用 1、key的模型 &a…
阅读更多...
Arthas学习（1）

Arthas学习（1）

1.Arthas作用 Arthas是Alibaba开源的Java诊断工具。 作用&#xff1a;当遇到以下类似问题时&#xff0c;可以帮助我们解决&#xff1a; 1.这个类从哪个jar包加载的&#xff1f;为什么会报各种类相关的Exception? 2.我改的代码为什么没有执行到&#xff1f;难道是我没提交&am…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023