Spring Data Mongodb事务管理

前言

这是一个很基础实例demo，并未涉及到相关原理，以及什么高深的知识。

一、环境

1、Mongodb 4.0副本集群（必须）：

mongo4.0开始支持事务管理，是基于副本集的（mongodb副本集群搭建教程自行查询）。

mongo4.2支持分片集群事务。

2、Spring data mongodb 版本2.1以上（必须）：

Spring data mongodb支持事务管理需要配置MongoTransactionManager，而这个Bean从Spring data mongodb 2.1版本才开始有的（如果你使用的是Spring boot，那么至少要保证data mongodb的版本在2.1以上，所以建议spring boot版本在2.1以后）

二、实例

1、Spring data mongodb配置

maven依赖：

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

application.properties配置文件：

# Mongodb
spring.data.mongodb.uri=mongodb://192.168.1.100:27017,192.168.1.200:27017/db

spring mongodb事务管理bean：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.mongodb.MongoDbFactory;
import org.springframework.data.mongodb.MongoTransactionManager;

@Configuration
public class MongoTransactionConfig {
    @Bean
    public MongoTransactionManager transactionManager(MongoDbFactory dbFactory) {
        return new MongoTransactionManager(dbFactory);
    }
}

spring boot开启事务管理( @EnableTransactionManagement )：

@EnableTransactionManagement
public class SpringBootApplication{
    public static void main(String[] args) {
        SpringApplication.run(SpringBootApplication.class, args);
    }
}

使用@Transactional注解标记需要事务管理的业务：

import lombok.AllArgsConstructor;
import lombok.Data;
import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

@Service
public class ProcessService {
    ...

	@Transactional
	public void run() {
		// dosomething...
	}

	...
}