@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    public void foo() {
        // 在此調(diào)用 bar 方法，事務(wù)將自動(dòng)傳播
        bar();
    }
    public void bar() {
        // 這里是被調(diào)用的方法，也添加 @Transactional 注解來(lái)管理事務(wù)
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    public void foo() {
        // 在此調(diào)用 bar 方法，事務(wù)將生效
        ((MyService) AopContext.currentProxy()).bar();
    }
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    private void bar() {
        // 這里是被調(diào)用的方法，使用 REQUIRES_NEW 傳播行為開啟一個(gè)新的事務(wù)
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    @Autowired
    private MyService self;
    public void foo() {
        // 在此調(diào)用 bar 方法，事務(wù)將自動(dòng)傳播
        self.bar();
    }
    public void bar() {
        // 這里是被調(diào)用的方法，也添加 @Transactional 注解來(lái)管理事務(wù)
        myRepository.save(new MyEntity());
    }
}

@Service
@Transactional
public class MyService {
    @Autowired
    private MyRepository myRepository;
    @Autowired
    private TransactionTemplate transactionTemplate;
    public void foo() {
        // 在此調(diào)用 bar 方法，事務(wù)將生效
        transactionTemplate.execute(new TransactionCallback<Void>() {
            @Override
            public Void doInTransaction(TransactionStatus status) {
                // 在此執(zhí)行需要在事務(wù)中完成的邏輯
                myRepository.save(new MyEntity());
                return null;
            }
        });
    }
}

@Component
@Aspect
public class TransactionalAspect {
    @Autowired
    private PlatformTransactionManager transactionManager;
    @Pointcut("@annotation(org.springframework.transaction.annotation.Transactional)")
    public void transactionalMethod() {}
    @Around("transactionalMethod()")
    public Object manageTransaction(ProceedingJoinPoint pjp) throws Throwable {
        DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
        definition.setName(pjp.getSignature().getName());
        definition.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
        TransactionStatus status = transactionManager.getTransaction(definition);
        try {
            Object result = pjp.proceed();
            transactionManager.commit(status);
            return result;
        } catch (Throwable t) {
            transactionManager.rollback(status);
            throw t;
        }
    }
}