@Service
public class UserService {
    @Autowired
    private UserRepository userRepository;

    @Transactional
    public User registerUser(String username, String email) {
        User user = new User(username, email);
        return userRepository.save(user);
    }

}

@Transactional(
    propagation = Propagation.REQUIRES_NEW,
    isolation = Isolation.READ_COMMITTED,
    rollbackFor = {SQLException.class},
    timeout = 30
)
public void updateUserProfile(User user) {
    // 業(yè)務(wù)邏輯
}

public class UserRegisteredEvent extends ApplicationEvent {
    private final User user;

    public UserRegisteredEvent(Object source, User user) {
        super(source);
        this.user = user;
    }
    
    public User getUser() {
        return user;
    }

}

@Service
public class RegistrationService {
    @Autowired
    private UserRepository userRepository;
    @Autowired
    private ApplicationEventPublisher eventPublisher;

    @Transactional
    public User registerUser(String username, String email) {
        User newUser = userRepository.save(new User(username, email));
        // 發(fā)布領(lǐng)域事件
        eventPublisher.publishEvent(new UserRegisteredEvent(this, newUser));
        return newUser;
    }

}

@Component
public class RegistrationListeners {
    

    // 郵件服務(wù)監(jiān)聽器
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    public void handleEmailNotification(UserRegisteredEvent event) {
        User user = event.getUser();
        System.out.println("發(fā)送郵件至：" + user.getEmail());
        // 實(shí)際應(yīng)調(diào)用郵件服務(wù)
    }
    
    // 日志記錄監(jiān)聽器（新事務(wù)）
    @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public void auditLog(UserRegisteredEvent event) {
        System.out.println("記錄審計(jì)日志：" + event.getUser());
        // 日志存儲(chǔ)操作將使用獨(dú)立事務(wù)
    }

}

@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
public void handleEvent(MyEvent event) {
    try {
        // 業(yè)務(wù)邏輯
    } catch (Exception e) {
        // 記錄異常或進(jìn)行補(bǔ)償
        logger.error("事件處理失敗", e);
        retryService.scheduleRetry(event);
    }
}

@Async
@TransactionalEventListener
public void asyncHandleEvent(MyEvent event) {
    // 異步處理
}

logging.level.org.springframework.transaction=DEBUG