R2DBC中@Transactional报错：无法为非响应式返回类型应用事务

• R2dbcRepository是Spring Data专为响应式数据库（基于R2DBC规范）设计的仓库接口，它的方法天然适配响应式编程模型，应当返回Mono<T>或Flux<T>这类响应式类型，而非List<T>这种阻塞式集合。
• Spring的响应式事务机制仅支持返回响应式类型的方法，当你在Service方法上添加@Transactional但方法返回非响应式的List<Receipt>时，事务管理器无法完成响应式事务的绑定与处理，因此抛出该错误。

1. 修正Repository方法的返回类型 #

将ReceiptRepository中的findReceiptsByCompanyId方法返回类型改为响应式类型，根据业务场景二选一：

public interface ReceiptRepository extends R2dbcRepository<Receipt, Long> {
    // 场景1：流式处理多条数据，用Flux
    Flux<Receipt> findReceiptsByCompanyId(Long companyId);
    
    // 场景2：一次性获取完整列表，用Mono包装List
    Mono<List<Receipt>> findReceiptsByCompanyId(Long companyId);
}

2. 调整Service层实现与事务注解 #

Service方法需返回对应的响应式类型，同时保留@Transactional注解（Spring会自动识别并绑定响应式事务上下文）：

@Service
public class ReceiptService {
    private final ReceiptRepository receiptRepository;

    public ReceiptService(ReceiptRepository receiptRepository) {
        this.receiptRepository = receiptRepository;
    }

    // 对应Flux版本的Repository方法
    @Transactional
    public Flux<Receipt> getReceiptsByCompanyId(Long companyId) {
        return receiptRepository.findReceiptsByCompanyId(companyId);
    }

    // 或者对应Mono<List<Receipt>>版本的Repository方法
    @Transactional
    public Mono<List<Receipt>> getReceiptsByCompanyId(Long companyId) {
        return receiptRepository.findReceiptsByCompanyId(companyId);
    }
}

3. 上层调用适配（可选） #

如果调用方需要阻塞式获取列表（仅适用于非响应式上下文，比如传统同步控制器），可通过block()方法转换，但响应式场景不推荐此操作：

// 仅示例，响应式架构中应尽量传递Mono/Flux而不是阻塞获取
List<Receipt> receipts = receiptService.getReceiptsByCompanyId(companyId).collectList().block();

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