Spring Boot 中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持

博主： Fivk
发布时间：2025 年 01 月 09 日
31 次浏览
暂无评论
5279字数
分类：基础框架知识总结

在现代应用开发中，事务管理是保证数据一致性的重要手段。当我们同时使用多种数据库（如 MySQL、MongoDB 和 Redis）时，如何配置和管理它们的事务显得尤为关键。本文将详细介绍如何在 Spring Boot 项目中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持，并避免常见的 Bean 重复定义和冲突问题。

---

## **1. 前置依赖与环境准备**

确保项目已经添加了以下依赖：

### Maven 依赖

```xml

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

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

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
```

### 环境要求

* **MySQL** ：使用支持事务的存储引擎（如 InnoDB）。
* **MongoDB** ：确保 MongoDB 集群运行在副本集模式（Replica Set）。
* **Redis** ：确认 Redis 启用了事务功能。

---

## **2. 配置 MySQL 的事务支持**

通过 `DataSourceTransactionManager` 管理 MySQL 的事务，并命名为唯一名称：

```java
@Configuration
@EnableTransactionManagement
public class MySQLConfig {

@Bean(name = "myBatisTransactionManager")
    public PlatformTransactionManager myBatisTransactionManager(DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }
}
```

---

## **3. 配置 MongoDB 的事务支持**

MongoDB 从 4.0 版本开始支持多文档事务，前提是运行在副本集模式下。

通过 `MongoTransactionManager` 管理 MongoDB 的事务，并命名为唯一名称：

```java
@Configuration
public class MongoConfig {

@Bean(name = "mongoTransactionManager")
    public MongoTransactionManager mongoTransactionManager(MongoDatabaseFactory dbFactory) {
        return new MongoTransactionManager(dbFactory);
    }
}
```

---

## **4. 配置 Redis 的事务支持**

Redis 的事务支持基于流水线（Pipeline）和 `MULTI/EXEC` 指令。

在 `application.yml` 或 `application.properties` 中启用 Redis 的事务支持：

```yaml
spring:
  redis:
    lettuce:
      pool:
        enabled: true
    transaction: true
```

---

## **5. 配置 ChainedTransactionManager**

为了实现 MySQL、MongoDB 和 Redis 的全局事务，需要使用 `ChainedTransactionManager`。

以下是 `ChainedTransactionManager` 的完整配置：

```java
@Configuration
public class ChainedTransactionConfig {

@Bean(name = "chainedTransactionManager")
    @Primary
    public ChainedTransactionManager chainedTransactionManager(
            @Qualifier("myBatisTransactionManager") PlatformTransactionManager myBatisTransactionManager,
            @Qualifier("mongoTransactionManager") MongoTransactionManager mongoTransactionManager) {
        return new ChainedTransactionManager(myBatisTransactionManager, mongoTransactionManager);
    }
}
```

`@Primary` 注解将 `chainedTransactionManager` 设置为默认事务管理器。

---

## **6. 避免 Bean 重复定义和冲突问题**

在 Spring Boot 中，如果多个配置类定义了相同名称的 Bean，会导致 `BeanDefinitionOverrideException` 或 Bean 注入冲突。以下是避免问题的设计：

### **方法 1：为每个 Bean 提供唯一名称**

确保每个事务管理器 Bean 都有唯一名称：

```java
// MySQLConfig.java
@Bean(name = "myBatisTransactionManager")
public PlatformTransactionManager myBatisTransactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}

// MongoConfig.java
@Bean(name = "mongoTransactionManager")
public MongoTransactionManager mongoTransactionManager(MongoDatabaseFactory dbFactory) {
    return new MongoTransactionManager(dbFactory);
}
```

### **方法 2：使用 @Qualifier 指定 Bean**

在 `ChainedTransactionManager` 配置中显式指定 Bean 的名称：

```java
@Bean(name = "chainedTransactionManager")
public ChainedTransactionManager chainedTransactionManager(
        @Qualifier("myBatisTransactionManager") PlatformTransactionManager myBatisTransactionManager,
        @Qualifier("mongoTransactionManager") MongoTransactionManager mongoTransactionManager) {
    return new ChainedTransactionManager(myBatisTransactionManager, mongoTransactionManager);
}
```

---

## **7. 全局事务示例**

通过 `@Transactional` 注解实现全局事务：

```java
@Service
public class GlobalService {

@Autowired
    private MySQLService mySQLService;
    @Autowired
    private MongoService mongoService;
    @Autowired
    private RedisService redisService;

@Transactional(transactionManager = "chainedTransactionManager")
    public void executeGlobalTransaction() {
        // 操作 MySQL
        mySQLService.executeMySQLTransaction();

// 操作 MongoDB
        mongoService.executeMongoTransaction();

// 操作 Redis
        redisService.executeRedisTransaction();
    }
}
```

---

## **8. 避免多个事务管理器冲突的策略**

在项目中定义了多个事务管理器时，Spring 可能会因为未指定具体的事务管理器而抛出 `NoUniqueBeanDefinitionException`。以下是解决方法：

1. **通过 `@Qualifier` 明确注入**
   在使用的地方显式指定事务管理器：
   ```java
   @Transactional(transactionManager = "chainedTransactionManager")
   public void executeGlobalTransaction() {
       // 业务逻辑
   }
   ```
2. **设置默认事务管理器**
   使用 `@Primary` 标记一个事务管理器为默认：
   ```java
   @Bean(name = "chainedTransactionManager")
   @Primary
   public ChainedTransactionManager chainedTransactionManager(
           @Qualifier("myBatisTransactionManager") PlatformTransactionManager myBatisTransactionManager,
           @Qualifier("mongoTransactionManager") MongoTransactionManager mongoTransactionManager) {
       return new ChainedTransactionManager(myBatisTransactionManager, mongoTransactionManager);
   }
   ```
3. **仅使用必要的事务管理器**
   如果某些事务管理器不参与当前业务逻辑，可以在配置中移除未使用的事务管理器 Bean。

---

## **9. 注意事项**

1. **MongoDB 必须使用副本集模式** ：单节点 MongoDB 不支持事务。
2. **Redis 的事务有限** ：只保证命令的顺序性，不支持回滚。
3. **MySQL 必须使用支持事务的存储引擎** ：如 InnoDB。
4. **分布式事务协调器** ：如果需要严格的一致性，可以使用分布式事务协调器（如 Atomikos、Seata）。

最后修改：2025 年 01 月 16 日

如果觉得我的文章对你有用，请随意赞赏

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

评论 *

私密评论

名称 *

🎲

邮箱 *

地址

本当迷
哈哈时过境迁再看一遍帆的文章质量还是那么高
挺胸的打工人
感谢博主分享
菜菜
一天就学一些我不知道的东西(´இ皿இ｀)
zhanqy
博主赛高！
null ？？［］
还可以把扩展运算符加上呀，这个很有用［…arr］，用于数组合...

Spring Boot 中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持

Fivk • 2025 年 01 月 09 日

---

## **1. 前置依赖与环境准备**

确保项目已经添加了以下依赖：

### Maven 依赖

```xml

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

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

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
```

### 环境要求

---

## **2. 配置 MySQL 的事务支持**

通过 `DataSourceTransactionManager` 管理 MySQL 的事务，并命名为唯一名称：

```java
@Configuration
@EnableTransactionManagement
public class MySQLConfig {

---

## **3. 配置 MongoDB 的事务支持**

MongoDB 从 4.0 版本开始支持多文档事务，前提是运行在副本集模式下。

通过 `MongoTransactionManager` 管理 MongoDB 的事务，并命名为唯一名称：

```java
@Configuration
public class MongoConfig {

@Bean(name = "mongoTransactionManager")
    public MongoTransactionManager mongoTransactionManager(MongoDatabaseFactory dbFactory) {
        return new MongoTransactionManager(dbFactory);
    }
}
```

---

## **4. 配置 Redis 的事务支持**

Redis 的事务支持基于流水线（Pipeline）和 `MULTI/EXEC` 指令。

在 `application.yml` 或 `application.properties` 中启用 Redis 的事务支持：

```yaml
spring:
  redis:
    lettuce:
      pool:
        enabled: true
    transaction: true
```

---

## **5. 配置 ChainedTransactionManager**

为了实现 MySQL、MongoDB 和 Redis 的全局事务，需要使用 `ChainedTransactionManager`。

以下是 `ChainedTransactionManager` 的完整配置：

```java
@Configuration
public class ChainedTransactionConfig {

`@Primary` 注解将 `chainedTransactionManager` 设置为默认事务管理器。

---

## **6. 避免 Bean 重复定义和冲突问题**

在 Spring Boot 中，如果多个配置类定义了相同名称的 Bean，会导致 `BeanDefinitionOverrideException` 或 Bean 注入冲突。以下是避免问题的设计：

### **方法 1：为每个 Bean 提供唯一名称**

确保每个事务管理器 Bean 都有唯一名称：

### **方法 2：使用 @Qualifier 指定 Bean**

在 `ChainedTransactionManager` 配置中显式指定 Bean 的名称：

---

## **7. 全局事务示例**

通过 `@Transactional` 注解实现全局事务：

```java
@Service
public class GlobalService {

@Autowired
    private MySQLService mySQLService;
    @Autowired
    private MongoService mongoService;
    @Autowired
    private RedisService redisService;

@Transactional(transactionManager = "chainedTransactionManager")
    public void executeGlobalTransaction() {
        // 操作 MySQL
        mySQLService.executeMySQLTransaction();

// 操作 MongoDB
        mongoService.executeMongoTransaction();

// 操作 Redis
        redisService.executeRedisTransaction();
    }
}
```

---

## **8. 避免多个事务管理器冲突的策略**

在项目中定义了多个事务管理器时，Spring 可能会因为未指定具体的事务管理器而抛出 `NoUniqueBeanDefinitionException`。以下是解决方法：

---

## **9. 注意事项**

Spring Boot 中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

【踩坑日志】SpringBoot项目启动提示This primary key of "id" is primitive !不建议如此请使用包装类 in Class:

【C】极域电子教室学生端解除控制

【开发技巧】@CrossOrigin注解解决跨域问题

【Fivk】文章归档

回忆刚入天柱二中的我

【Linux】vim教程

【MyBatis】PageHelper分页插件

【函数快查】大小写转换tolower/toupper以及transform函数

【Mongo】副本集群搭建

【C】求小数的某一位

Spring Boot 中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持

发表评论 取消回复 使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款

Spring Boot 中同时开启并配置 MongoDB、MySQL 和 Redis 的事务支持

发表评论取消回复
使用cookie技术保留您的个人信息以便您下次快速评论，继续评论表示您已同意该条款