public class User { private long id; private String name; private int age; 
 // getter, setter...} 

public interface UserService { void insert(User user); 
}@Service@Transactionalpublic class UserServiceImpl implements UserService { @Autowired 
 private JdbcTemplate jdbcTemplate; @Override 
 public void insert(User user) { 
 jdbcTemplate.update("insert into user (name, age) value (?, ?)", 
  user.getName(), user.getAge()); 
 } 
} 

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> 
 <property name="url" value="jdbc:mysql://localhost/test?useUnicode=true"/> 
 <property name="driverClassName" value="com.mysql.jdbc.Driver"/> 
 <property name="username" value="****"/> 
 <property name="password" value="******"/></bean><bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> 
 <property name="dataSource" ref="dataSource"/></bean><bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> 
 
 <property name="dataSource" ref="dataSource"/></bean><context:component-scan base-package="com.transaction"/><tx:annotation-driven/> 

public class TransactionApp { @Test 
 public void testTransaction() { 
 ApplicationContext ac = new ClassPathXmlApplicationContext("applicationContext.xml"); 
 UserService userService = ac.getBean(UserService.class); 
 User user = getUser(); 
 userService.insert(user); 
 } private User getUser() { 
 User user = new User(); 
 user.setName("Mary"); 
 user.setAge(27); return user; 
 } 
} 

@Service@Transactionalpublic class UserServiceImpl implements UserService { @Autowired 
 private JdbcTemplate jdbcTemplate; @Override 
 public void insert(User user) { 
 jdbcTemplate.update("insert into user (name, age) value (?, ?)", 
  user.getName(), user.getAge()); throw new RuntimeException(); 
 } 
} 

@Overridepublic void init() { 
 registerBeanDefinitionParser("advice", new TxAdviceBeanDefinitionParser()); 
 registerBeanDefinitionParser("annotation-driven", 
  new AnnotationDrivenBeanDefinitionParser()); 
 registerBeanDefinitionParser("jta-transaction-manager", 
  new JtaTransactionManagerBeanDefinitionParser()); 
} 

public BeanDefinition parse(Element element, ParserContext parserContext) { // 注冊事務(wù)相關(guān)的監(jiān)聽器，如果某個方法標(biāo)注了TransactionalEventListener注解， 
 // 那么該方法就是一個事務(wù)事件觸發(fā)方法，即發(fā)生某種事務(wù)事件后，將會根據(jù)該注解的設(shè)置，回調(diào)指定 
 // 類型的方法。常見的事務(wù)事件有：事務(wù)執(zhí)行前和事務(wù)完成(包括報錯后的完成)后的事件。 
 registerTransactionalEventListenerFactory(parserContext); 
 String mode = element.getAttribute("mode"); // 獲取當(dāng)前事務(wù)驅(qū)動程序的模式，如果使用了aspectj模式，則會注冊一個AnnotationTransactionAspect 
 // 類型的bean，用戶可以以aspectj的方式使用該bean對事務(wù)進(jìn)行更多的配置 
 if ("aspectj".equals(mode)) { 
  registerTransactionAspect(element, parserContext); 
 } else {  // 一般使用的是當(dāng)前這種方式，這種方式將會在Spring中注冊三個bean，分別是 
  // AnnotationTransactionAttributeSource，TransactionInterceptor 
  // 和BeanFactoryTransactionAttributeSourceAdvisor，并通過Aop的方式實(shí)現(xiàn)事務(wù) 
  AopAutoProxyConfigurer.configureAutoProxyCreator(element, parserContext); 
 } return null; 
} 

public static void configureAutoProxyCreator(Element element, 
  ParserContext parserContext) { // 這個方法主要是在當(dāng)前BeanFactory中注冊InfrastructureAdvisorAutoProxyCreator這個 
 // bean，這個bean繼承了AbstractAdvisorAutoProxyCreator，也就是其實(shí)現(xiàn)原理與我們前面 
 // 講解的Spring Aop的實(shí)現(xiàn)原理幾乎一致 
 AopNamespaceUtils.registerAutoProxyCreatorIfNecessary(parserContext, element); // 這里的txAdvisorBeanName就是我們最終要注冊的bean，其類型就是下面注冊的 
 // BeanFactoryTransactionAttributeSourceAdvisor，可以看到，其本質(zhì)是一個 
 // Advisor類型的對象，因而Spring Aop會將其作為一個切面織入到指定的bean中 
 String txAdvisorBeanName = TransactionManagementConfigUtils 
  .TRANSACTION_ADVISOR_BEAN_NAME; // 如果當(dāng)前BeanFactory中已經(jīng)存在了目標(biāo)bean，則不進(jìn)行注冊 
 if (!parserContext.getRegistry().containsBeanDefinition(txAdvisorBeanName)) { 
  Object eleSource = parserContext.extractSource(element);  // 注冊AnnotationTransactionAttributeSource，這個bean的主要作用是封裝 
  // @Transactional注解中聲明的各個屬性 
  RootBeanDefinition sourceDef = new RootBeanDefinition(  "org.springframework.transaction.annotation.AnnotationTransactionAttributeSource"); 
  sourceDef.setSource(eleSource); 
  sourceDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE); 
  String sourceName = parserContext.getReaderContext() 
   .registerWithGeneratedName(sourceDef);  // 注冊TransactionInterceptor類型的bean，并且將上面的封裝屬性的bean設(shè)置為其一個屬性。 
  // 這個bean本質(zhì)上是一個Advice(可查看其繼承結(jié)構(gòu))，Spring Aop使用Advisor封裝實(shí)現(xiàn)切面 
  // 邏輯織入所需的所有屬性，但真正的切面邏輯卻是保存在其Advice屬性中的，也就是說這里的 
  // TransactionInterceptor才是真正封裝了事務(wù)切面邏輯的bean 
  RootBeanDefinition interceptorDef = 
   new RootBeanDefinition(TransactionInterceptor.class); 
  interceptorDef.setSource(eleSource); 
  interceptorDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE); 
  registerTransactionManager(element, interceptorDef); 
  interceptorDef.getPropertyValues().add("transactionAttributeSource", 
   new RuntimeBeanReference(sourceName)); 
  String interceptorName = parserContext.getReaderContext() 
   .registerWithGeneratedName(interceptorDef);  // 注冊BeanFactoryTransactionAttributeSourceAdvisor類型的bean，這個bean實(shí)現(xiàn)了 
  // Advisor接口，實(shí)際上就是封裝了當(dāng)前需要織入的切面的所有所需的屬性 
  RootBeanDefinition advisorDef = 
   new RootBeanDefinition(BeanFactoryTransactionAttributeSourceAdvisor.class); 
  advisorDef.setSource(eleSource); 
  advisorDef.setRole(BeanDefinition.ROLE_INFRASTRUCTURE); 
  advisorDef.getPropertyValues().add("transactionAttributeSource", 
   new RuntimeBeanReference(sourceName)); 
  advisorDef.getPropertyValues().add("adviceBeanName", interceptorName);  if (element.hasAttribute("order")) { 
   advisorDef.getPropertyValues().add("order", element.getAttribute("order")); 
  } 
  parserContext.getRegistry().registerBeanDefinition(txAdvisorBeanName, advisorDef);  // 將需要注冊的bean封裝到CompositeComponentDefinition中，并且進(jìn)行注冊 
 
  CompositeComponentDefinition compositeDef = 
   new CompositeComponentDefinition(element.getTagName(), eleSource); 
  compositeDef.addNestedComponent(   new BeanComponentDefinition(sourceDef, sourceName)); 
  compositeDef.addNestedComponent(   new BeanComponentDefinition(interceptorDef, interceptorName)); 
  compositeDef.addNestedComponent(   new BeanComponentDefinition(advisorDef, txAdvisorBeanName)); 
  parserContext.registerComponent(compositeDef); 
 } 
}