事务与 @Async、@TransactionalEventListener:提交之后再做事

  --- 事务正常提交
  1. place():insert 完,发布 Placed 事件
  2.   [普通 @EventListener] 收到 1
  3. place():publishEvent 返回
  4.   [BEFORE_COMMIT] 收到 1
  5.   [AFTER_COMMIT + fallbackExecution = true] 收到 1
  6.   [AFTER_COMPLETION] 收到 1
  7.   [AFTER_COMMIT] 收到 1
  --- 事务回滚
  1. place():insert 完,发布 Placed 事件
  2.   [普通 @EventListener] 收到 2
  3. place():publishEvent 返回
  4.   [AFTER_ROLLBACK] 收到 2
  5.   [AFTER_COMPLETION] 收到 2
  6. 调用者收到 IllegalStateException
  --- 没有事务时直接 publishEvent
  1.   [AFTER_COMMIT + fallbackExecution = true] 收到 3
  2.   [普通 @EventListener] 收到 3

  AFTER_COMMIT 监听器里的写入,事务提交之后 audit 表里有:[REQUIRES_NEW, NOT_SUPPORTED, PLAIN]
  启动失败:IllegalStateException: @TransactionalEventListener method must not be annotated with @Transactional unless when declared as REQUIRES_NEW or NOT_SUPPORTED: public void BadListener.required(Placed)

  @Async @EventListener(事件在事务里发布):100 次下单,监听器被调用 100 次,其中读得到刚下的那个订单的有 90 次
  @Async @TransactionalEventListener(AFTER_COMMIT):100 次下单,监听器被调用 100 次,其中读得到刚下的那个订单的有 100 次

  LOG ERROR TransactionSynchronizationUtils: TransactionSynchronization.afterCompletion threw exception
  --- AFTER_COMMIT 监听器抛异常
  1. place():insert 完,发布 Placed 事件
  2. place():publishEvent 返回
  3. place() 正常返回
  4. 表 orders 里有 1 行