// @since 4.2 注解的方式提供的相對較晚，其實(shí)API的方式在第一個(gè)版本就已經(jīng)提供了。
// 值得注意的是，在這個(gè)注解上面有一個(gè)注解：`@EventListener`，所以表明其實(shí)這個(gè)注解也是個(gè)事件監(jiān)聽器。 
@Target({ElementType.METHOD, ElementType.ANNOTATION_TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@EventListener //有類似于注解繼承的效果
public @interface TransactionalEventListener {
 // 這個(gè)注解取值有：BEFORE_COMMIT、AFTER_COMMIT、AFTER_ROLLBACK、AFTER_COMPLETION
 // 各個(gè)值都代表什么意思表達(dá)什么功能，非常清晰，下面解釋了對應(yīng)的枚舉類~
 // 需要注意的是：AFTER_COMMIT + AFTER_COMPLETION是可以同時(shí)生效的
 // AFTER_ROLLBACK + AFTER_COMPLETION是可以同時(shí)生效的
 TransactionPhase phase() default TransactionPhase.AFTER_COMMIT;
 // 表明若沒有事務(wù)的時(shí)候，對應(yīng)的event是否需要執(zhí)行，默認(rèn)值為false表示，沒事務(wù)就不執(zhí)行了。
 boolean fallbackExecution() default false;
 // 這里巧妙的用到了@AliasFor的能力，放到了@EventListener身上
 // 注意：一般建議都需要指定此值，否則默認(rèn)可以處理所有類型的事件，范圍太廣了。
 @AliasFor(annotation = EventListener.class, attribute = "classes")
 Class<?>[] value() default {};
 @AliasFor(annotation = EventListener.class, attribute = "classes")
 Class<?>[] classes() default {};
 
 String condition() default "";
}

public enum TransactionPhase {
   // 指定目標(biāo)方法在事務(wù)commit之前執(zhí)行
   BEFORE_COMMIT,
   // 指定目標(biāo)方法在事務(wù)commit之后執(zhí)行
    AFTER_COMMIT,
    // 指定目標(biāo)方法在事務(wù)rollback之后執(zhí)行
    AFTER_ROLLBACK,
   // 指定目標(biāo)方法在事務(wù)完成時(shí)執(zhí)行，這里的完成是指無論事務(wù)是成功提交還是事務(wù)回滾了
   AFTER_COMPLETION
  }

@Data
public class User {
 private long id;
 private String name;
 private Integer age;
}

@Service
@Slf4j
public class UserServiceImpl extends implements UserService {
 @Autowired
    UserMapper userMapper;
     
 @Autowired
    ApplicationEventPublisher eventPublisher;
 
 public void userRegister(User user){
  userMapper.insertUser(user);
  eventPublisher.publishEvent(new UserRegisterEvent(new Date()));
 }
}

@Getter
@Setter
public class UserRegisterEvent extends ApplicationEvent {
    private Date registerDate;
    public UserRegisterEvent(Date registerDate) {
        super(registerDate);
        this.registerDate = registerDate;
    }
}

@Slf4j
@Component
public class UserListener {
    @Autowired
    UserService userService;
    @Async
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT, classes = UserRegisterEvent.class)
    public void onUserRegisterEvent(UserRegisterEvent event) {
        userService.sendActivationCode(event.getRegisterDate());
    }
}

public interface TransactionSynchronization extends Flushable {
// 在當(dāng)前事務(wù)掛起時(shí)執(zhí)行
default void suspend() {
}
// 在當(dāng)前事務(wù)重新加載時(shí)執(zhí)行
default void resume() {
}
// 在當(dāng)前數(shù)據(jù)刷新到數(shù)據(jù)庫時(shí)執(zhí)行
default void flush() {
}
// 在當(dāng)前事務(wù)commit之前執(zhí)行
default void beforeCommit(boolean readOnly) {
}
// 在當(dāng)前事務(wù)completion之前執(zhí)行
default void beforeCompletion() {
}
// 在當(dāng)前事務(wù)commit之后實(shí)質(zhì)性
default void afterCommit() {
}
// 在當(dāng)前事務(wù)completion之后執(zhí)行
default void afterCompletion(int status) {
}
}

public class TransactionalEventListenerFactory implements EventListenerFactory, Ordered {
// 指定當(dāng)前監(jiān)聽器的順序
private int order = 50;
public void setOrder(int order) {
    this.order = order;
}
@Override
public int getOrder() {
    return this.order;
}
// 指定目標(biāo)方法是否是所支持的監(jiān)聽器的類型，這里的判斷邏輯就是如果目標(biāo)方法上包含有
// TransactionalEventListener注解，則說明其是一個(gè)事務(wù)事件監(jiān)聽器
@Override
public boolean supportsMethod(Method method) {
    return (AnnotationUtils.findAnnotation(method, TransactionalEventListener.class) != null);
}
// 為目標(biāo)方法生成一個(gè)事務(wù)事件監(jiān)聽器，這里ApplicationListenerMethodTransactionalAdapter實(shí)現(xiàn)了
// ApplicationEvent接口
@Override
public ApplicationListener<?> createApplicationListener(String beanName, Class<?> type, Method method) {
    return new ApplicationListenerMethodTransactionalAdapter(beanName, type, method);
}
}

@Override
 public void onApplicationEvent(ApplicationEvent event) {
// 如果當(dāng)前TransactionManager已經(jīng)配置開啟事務(wù)事件監(jiān)聽，
// 此時(shí)才會注冊TransactionSynchronization對象
if (TransactionSynchronizationManager.isSynchronizationActive()) {
    // 通過當(dāng)前事務(wù)事件發(fā)布的參數(shù)，創(chuàng)建一個(gè)TransactionSynchronization對象
    TransactionSynchronization transactionSynchronization = 
        createTransactionSynchronization(event);
    // 注冊TransactionSynchronization對象到TransactionManager中
    TransactionSynchronizationManager
        .registerSynchronization(transactionSynchronization);
} else if (this.annotation.fallbackExecution()) {
    // 如果當(dāng)前TransactionManager沒有開啟事務(wù)事件處理，但是當(dāng)前事務(wù)監(jiān)聽方法中配置了
    // fallbackExecution屬性為true，說明其需要對當(dāng)前事務(wù)事件進(jìn)行監(jiān)聽，無論其是否有事務(wù)
    if (this.annotation.phase() == TransactionPhase.AFTER_ROLLBACK 
        && logger.isWarnEnabled()) {
        logger.warn("Processing " 
                    + event + " as a fallback execution on AFTER_ROLLBACK phase");
    }
    processEvent(event);
} else {
    // 走到這里說明當(dāng)前是不需要事務(wù)事件處理的，因而直接略過
    if (logger.isDebugEnabled()) {
        logger.debug("No transaction is active - skipping " + event);
    }
}
}

private static class TransactionSynchronizationEventAdapter 
    extends TransactionSynchronizationAdapter {
    private final ApplicationListenerMethodAdapter listener;
    private final ApplicationEvent event;
    private final TransactionPhase phase;
public TransactionSynchronizationEventAdapter(ApplicationListenerMethodAdapter 
    listener, ApplicationEvent event, TransactionPhase phase) {
    this.listener = listener;
    this.event = event;
    this.phase = phase;
}
@Override
public int getOrder() {
    return this.listener.getOrder();
}
// 在目標(biāo)方法配置的phase屬性為BEFORE_COMMIT時(shí)，處理before commit事件
public void beforeCommit(boolean readOnly) {
    if (this.phase == TransactionPhase.BEFORE_COMMIT) {
        processEvent();
    }
}
// 這里對于after completion事件的處理，雖然分為了三個(gè)if分支，但是實(shí)際上都是執(zhí)行的processEvent()
// 方法，因?yàn)閍fter completion事件是事務(wù)事件中一定會執(zhí)行的，因而這里對于commit，
// rollback和completion事件都在當(dāng)前方法中處理也是沒問題的
public void afterCompletion(int status) {
    if (this.phase == TransactionPhase.AFTER_COMMIT && status == STATUS_COMMITTED) {
        processEvent();
    } else if (this.phase == TransactionPhase.AFTER_ROLLBACK 
               && status == STATUS_ROLLED_BACK) {
        processEvent();
    } else if (this.phase == TransactionPhase.AFTER_COMPLETION) {
        processEvent();
    }
}
// 執(zhí)行事務(wù)事件
protected void processEvent() {
    this.listener.processEvent(this.event);
}
}

 public void processEvent(ApplicationEvent event) {
// 處理事務(wù)事件的相關(guān)參數(shù)，這里主要是判斷TransactionalEventListener注解中是否配置了value
// 或classes屬性，如果配置了，則將方法參數(shù)轉(zhuǎn)換為該指定類型傳給監(jiān)聽的方法；如果沒有配置，則判斷
// 目標(biāo)方法是ApplicationEvent類型還是PayloadApplicationEvent類型，是則轉(zhuǎn)換為該類型傳入
Object[] args = resolveArguments(event);
// 這里主要是獲取TransactionalEventListener注解中的condition屬性，然后通過
// Spring expression language將其與目標(biāo)類和方法進(jìn)行匹配
if (shouldHandle(event, args)) {
    // 通過處理得到的參數(shù)借助于反射調(diào)用事務(wù)監(jiān)聽方法
    Object result = doInvoke(args);
    if (result != null) {
        // 對方法的返回值進(jìn)行處理
        handleResult(result);
    } else {
        logger.trace("No result object given - no result to handle");
    }
}
 }
 // 處理事務(wù)監(jiān)聽方法的參數(shù)
protected Object[] resolveArguments(ApplicationEvent event) {
// 獲取發(fā)布事務(wù)事件時(shí)傳入的參數(shù)類型
ResolvableType declaredEventType = getResolvableType(event);
if (declaredEventType == null) {
    return null;
}
// 如果事務(wù)監(jiān)聽方法的參數(shù)個(gè)數(shù)為0，則直接返回
if (this.method.getParameterCount() == 0) {
    return new Object[0];
}
// 如果事務(wù)監(jiān)聽方法的參數(shù)不為ApplicationEvent或PayloadApplicationEvent，則直接將發(fā)布事務(wù)
// 事件時(shí)傳入的參數(shù)當(dāng)做事務(wù)監(jiān)聽方法的參數(shù)傳入。從這里可以看出，如果事務(wù)監(jiān)聽方法的參數(shù)不是
// ApplicationEvent或PayloadApplicationEvent類型，那么其參數(shù)必須只能有一個(gè)，并且這個(gè)
// 參數(shù)必須與發(fā)布事務(wù)事件時(shí)傳入的參數(shù)一致
Class<?> eventClass = declaredEventType.getRawClass();
if ((eventClass == null || !ApplicationEvent.class.isAssignableFrom(eventClass)) &&
    event instanceof PayloadApplicationEvent) {
    return new Object[] {((PayloadApplicationEvent) event).getPayload()};
} else {
    // 如果參數(shù)類型為ApplicationEvent或PayloadApplicationEvent，則直接將其傳入事務(wù)事件方法
    return new Object[] {event};
}
 }
 // 判斷事務(wù)事件方法方法是否需要進(jìn)行事務(wù)事件處理
private boolean shouldHandle(ApplicationEvent event, @Nullable Object[] args) {
if (args == null) {
    return false;
}
String condition = getCondition();
if (StringUtils.hasText(condition)) {
    Assert.notNull(this.evaluator, "EventExpressionEvaluator must no be null");
    EvaluationContext evaluationContext = this.evaluator.createEvaluationContext(
        event, this.targetClass, this.method, args, this.applicationContext);
    return this.evaluator.condition(condition, this.methodKey, evaluationContext);
}
return true;
 }
 // 對事務(wù)事件方法的返回值進(jìn)行處理，這里的處理方式主要是將其作為一個(gè)事件繼續(xù)發(fā)布出去，這樣就可以在
// 一個(gè)統(tǒng)一的位置對事務(wù)事件的返回值進(jìn)行處理
protected void handleResult(Object result) {
// 如果返回值是數(shù)組類型，則對數(shù)組元素一個(gè)一個(gè)進(jìn)行發(fā)布
if (result.getClass().isArray()) {
    Object[] events = ObjectUtils.toObjectArray(result);
    for (Object event : events) {
        publishEvent(event);
    }
} else if (result instanceof Collection<?>) {
    // 如果返回值是集合類型，則對集合進(jìn)行遍歷，并且發(fā)布集合中的每個(gè)元素
    Collection<?> events = (Collection<?>) result;
    for (Object event : events) {
        publishEvent(event);
    }
} else {
    // 如果返回值是一個(gè)對象，則直接將其進(jìn)行發(fā)布
    publishEvent(result);
}
}