Spring Cloud Stream Function接收数据无法存入数据库且无事务如何解决？

核心原因 #

• Consumer 返回的 Lambda 表达式默认无法被 Spring 事务切面代理，如果事务注解加在 Lambda 内部、或业务层未正确配置事务，都会导致事务不生效，存库操作异常无感知或提交失败。
• Spring Cloud Stream 默认未开启消费侧事务绑定，事务管理器未和消息消费上下文关联，异常不会触发事务回滚。
• 代码中吞掉了存库操作抛出的异常，导致报错无感知，数据未写入也看不到错误日志。

解决方案 #

1. 确认业务层事务配置正确 #

orderService.save() 方法必须加 Spring 官方事务注解，确认事务管理器已正确注入上下文：

import org.springframework.transaction.annotation.Transactional;

@Service
public class OrderService {
    @Autowired
    private OrderStreamMapper orderStreamMapper;

    // rollbackFor 可按需调整，配置所有异常都触发回滚
    @Transactional(rollbackFor = Exception.class)
    public void save(OrderStream orderStream) {
        orderStreamMapper.insert(orderStream);
    }
}

2. 给 Consumer 消费逻辑绑定事务 #

Lambda 本身无法加事务注解，两种可选实现方案：

方案1：消费逻辑抽离到独立类方法加事务注解

@Component
public class OrderEventHandler {
    @Autowired
    private OrderService orderService;

    @Transactional(rollbackFor = Exception.class)
    public void handle(OrderCreateEvent order) {
        System.out.println("OrderCreateEvent: " + order.getId());
        OrderStream orderStream = new OrderStream();
        orderStream.setId(order.getId());
        orderService.save(orderStream);
    }
}

Consumer Bean 直接引用方法即可：

@Bean
public Consumer<OrderCreateEvent> receiveOrderCreateEvent(OrderEventHandler handler){
    return handler::handle;
}

方案2：TransactionTemplate 手动控制事务

不想额外抽类可以直接在 Lambda 内使用事务模板：

@Bean
public Consumer<OrderCreateEvent> receiveOrderCreateEvent(TransactionTemplate transactionTemplate, OrderService orderService){
    return order -> transactionTemplate.execute(status -> {
        System.out.println("OrderCreateEvent: " + order.getId());
        OrderStream orderStream = new OrderStream();
        orderStream.setId(order.getId());
        orderService.save(orderStream);
        return null;
    });
}

3. 配置消费端事务绑定（需要消息重试场景可选） #

如果需要消费失败后事务回滚、消息重新投递，添加如下配置：

spring:
  cloud:
    stream:
      bindings:
        receiveOrderCreateEvent-in-0:
          consumer:
            transactional: true # 开启消费端事务绑定
  transaction:
    rollback-on-commit-failure: true # 提交失败也触发事务回滚

排查项 #

• 不要在消费逻辑中捕获异常不抛出，否则事务会认为执行成功直接提交，不会触发回滚也看不到报错信息。
• 确认使用的数据库表引擎支持事务，比如 MySQL 需使用 InnoDB 引擎，MyISAM 本身不支持事务。

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