1
@Transactional(rollbackFor = Exception.class)
2
public void createOrder(CreateOrderCmd cmd) {
3
  Order order = doSaveOrder(cmd);
4
  EmailContext emailCtx = prepareEmailContext(order);
5
  sendEmail(emailCtx);
6
}
7

8
public void sendEmail(EmailContext emailCtx) {
9
  // 邮件发送逻辑
10
}

1
@Transactional(rollbackFor = Exception.class)
2
public void createOrder(CreateOrderCmd cmd) {
3
  Order order = doSaveOrder(cmd);
4
  // 在数据库事务提交后执行发送邮件
5
  TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
6
    // 事务同步只在事务存在且成功提交时触发，如果事务回滚，afterCommit() 不会执行
7
    @Override
8
    public void afterCommit() {
9
      EmailContext emailCtx = prepareEmailContext(order);
10
      sendEmail(emailCtx);
11
    }
12
  });
13
}
14

15
public void sendEmail(EmailContext emailCtx) {
16
  // 邮件发送逻辑
17
}

1
@Transactional(rollbackFor = Exception.class)
2
public void createOrder(CreateOrderCmd cmd) {
3
  Order order = doSaveOrder(cmd);
4
  OrderCreatedEvent event = new OrderCreatedEvent();
5
  // ... setEvent
6
  saveLocalEvent(event);
7

8
  // 在数据库事务提交后执行发送短信
9
  TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
10
    @Override
11
    public void afterCommit() {
12
      applicationEventPublisher.publishEvent(event);
13
      // 更新事件发送状态
14
      updateEventSendStatus(event);
15
    }
16
  });
17
}
18

19
@EventListener
20
public void orderCreatedEventHandler(OrderCreatedEvent event) {
21
  EmailContext emailCtx = prepareEmailContext(event);
22
  sendEmail(emailCtx);
23
  // 保存事件消费记录
24
  saveLocalEventHandleLog(event);
25
}
26

27
@Transactional(rollbackFor = Exception.class)
28
public void saveLocalEventHandleLog(Object event) {
29
  // 将事件处理记录保存到数据库中
30
}
31

32
public void saveLocalEvent(Object event) {
33
  // 保存到数据库
34
}
35

36
public void sendEmail(EmailContext emailCtx) {
37
  // 邮件发送逻辑
38
}