Spring Webflux中@Transactional与dev.miku r2dbc-mysql兼容问题求助

问题原因 #

你遇到的AbstractMethodError是因为r2dbc-mysql版本与Spring R2DBC事务API不兼容：Spring的Reactive事务实现要求数据库连接类实现beginTransaction(TransactionDefinition)方法，但旧版本的dev.miku.r2dbc.mysql并未提供该方法，导致事务初始化时抛出错误。

解决方案 #

1. 升级r2dbc-mysql到兼容版本 #

确保使用的r2dbc-mysql版本与你的Spring Boot/Spring Framework版本匹配：

• 若使用Spring Boot 3.x，对应r2dbc-mysql 1.0.x及以上版本
• 若使用Spring Boot 2.x，对应r2dbc-mysql 0.8.x及以上版本

如果是Maven项目，可直接在pom.xml中指定兼容版本（或依赖Spring Boot的spring-boot-starter-data-r2dbc自动管理版本）：

<!-- Spring Boot 3.x 示例 -->
<dependency>
    <groupId>dev.miku</groupId>
    <artifactId>r2dbc-mysql</artifactId>
    <version>1.0.2.RELEASE</version>
</dependency>

2. 配置正确的Reactive事务管理器 #

确保项目中配置了R2dbcTransactionManager（而非JDBC的DataSourceTransactionManager），Spring才能正确处理Reactive事务：

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.r2dbc.connection.R2dbcTransactionManager;
import io.r2dbc.spi.ConnectionFactory;

@Configuration
public class R2dbcConfig {
    @Bean
    public R2dbcTransactionManager transactionManager(ConnectionFactory connectionFactory) {
        return new R2dbcTransactionManager(connectionFactory);
    }
}

3. 规范@Transactional的使用 #

在WebFlux的Reactive场景下，使用@Transactional需满足：

• 服务方法的返回值必须是Mono或Flux（不能是阻塞式返回类型）
• 避免在非Reactive上下文（如阻塞式方法）中使用该注解

示例正确的服务方法：

@Service
public class ExampleService {
    private final ExampleRepository repository;

    public ExampleService(ExampleRepository repository) {
        this.repository = repository;
    }

    @Transactional
    public Flux<ExampleEntity> getAll() {
        return repository.findAll();
    }
}

4. 排查依赖冲突 #

检查项目依赖中是否存在多版本的r2dbc-api，这可能导致类加载异常。通过Maven命令查看依赖树：

mvn dependency:tree

若发现不同版本的r2dbc-api，排除旧版本，确保与r2dbc-mysql版本一致。

内容的提问来源于stack exchange，提问作者Scott