SpringBoot事务钩子函数的使用方式

import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionSynchronization;
import org.springframework.transaction.support.TransactionSynchronizationManager;

@Service
public class OrderService {

    @Transactional
    public void createOrder(String orderId) {
        // 1. 数据库操作（如创建订单）
        System.out.println("订单创建完成，订单号：" + orderId);

        // 2. 添加事务同步逻辑
        TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronization() {
            @Override
            public void afterCommit() {
                // 事务提交后发送 MQ 消息
                System.out.println("事务提交成功，发送订单消息：" + orderId);
            }

            @Override
            public void afterCompletion(int status) {
                if (status == TransactionSynchronization.STATUS_ROLLED_BACK) {
                    System.out.println("事务回滚，清理资源");
                }
            }
        });
    }
}

import org.springframework.context.ApplicationEvent;

public class OrderCreatedEvent extends ApplicationEvent {
    private final String orderId;

    public OrderCreatedEvent(Object source, String orderId) {
        super(source);
        this.orderId = orderId;
    }

    public String getOrderId() {
        return orderId;
    }
}

import org.springframework.context.ApplicationEventPublisher;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

@Service
public class OrderService {

    private final ApplicationEventPublisher eventPublisher;

    public OrderService(ApplicationEventPublisher eventPublisher) {
        this.eventPublisher = eventPublisher;
    }

    @Transactional
    public void createOrder(String orderId) {
        // 1. 数据库操作
        System.out.println("订单创建完成，订单号：" + orderId);

        // 2. 发布事件
        eventPublisher.publishEvent(new OrderCreatedEvent(this, orderId));
    }
}

import org.springframework.context.event.EventListener;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Component;

@Component
public class OrderEventListener {

    @Async
    @EventListener
    public void handleOrderCreatedEvent(OrderCreatedEvent event) {
        System.out.println("事务提交后，处理订单事件：" + event.getOrderId());
    }
}

src
├── main
│   ├── java
│   │   ├── com.example.transaction
│   │   │   ├── OrderService.java
│   │   │   ├── OrderCreatedEvent.java
│   │   │   ├── OrderEventListener.java
│   ├── resources
│       ├── application.yml