spring的事务

全局事务(Global Transaction).  如果整个事务处理过程中有多个Resource Manager的参与，那么就需要引入TP Monitor来协调多个RM之间的事务处理，TP Monitor将采用“两阶段提交(2 Phase Commit)”协议来保证整个事务的ACID属性， 这种场景下的事务我们就称其为全局事务(Global Transaction)或者分布式事务(Distributed Transaction)。全局事务中各个参与者之间的关系如下图所示：

Figure 1.2. 全局事务示意图

局部事务(Local Transaction).  如果当前事务只有一个Resource Manager参与其中的话，我们就可以称当前事务为局部事务(Local Transaction)。 比如，你在当前事务中只对一个数据库进行更新，或者只向一个消息队列中发送消息的情况，都属于局部事务。

Figure 1.3. 局部事务示意图

数据库资源的局部事务管理.  要在对数据库的访问过程中进行事务管理，每一种数据访问技术都提供了特定于它自身的事务管理API，比如JDBC是Java平台访问关系数据库最基础的 API，如果直接使用JDBC进行数据访问的话，我们可以将数据库连接(java.sql.Connection)的自动提交(AutoCommit)功 能设置为false，改为手动提交来控制整个事务的提交或者回滚：

Connection connection = null;
    boolean rollback = false;
    try
    {
    connection = dataSource.getConnection();
    connection.setAutoCommit(false);
    // do data access with JDBC
    connection.commit();
    }
    catch(SQLException e)
    {
    e.printStackTrace(); // don‘t do this
    rollback = true;
    }
    finally
    {
    if(connection != null)
    {
    if(rollback)
    {
    try {
    connection.rollback();
    } catch (SQLException e) {
    e.printStackTrace(); // don‘t do this
    }
    }
    else
    {
    try {
    connection.close();
    } catch (SQLException e) {
    e.printStackTrace(); // don‘t do this
    }
    }
    }
    }
    

Session session = null;
    Transaction transaction = null;
    try
    {
    session = sessionFactory.openSession();
    transaction = session.beginTransaction();
    // do data access with Hibernate
    session.flush();
    transaction.commit();
    }
    catch(HibernateException e)
    {
    transaction.rollback();
    }
    finally
    {
    session.close();
    }
    

消息服务资源的局部事务管理.  在使用JMS进行消息处理的过程中，我们可以通过JMS的javax.jms.Session来控制整个处理过程的事务：

boolean rollback = false;
    Connection  con = null;
    Session session = null;
    try
    {
    con = cf.createConnection();
    session = con.createSession(true, Session.AUTO_ACKNOWLEDGE);
    // process Messages with JMS API
    session.commit();
    }
    catch (JMSException e) {
    e.printStackTrace();// don‘t do this
    rollback = true;
    }
    finally
    {
    if(con != null)
    {
    if(rollback)
    {
    try {
    session.rollback();
    } catch (JMSException e1) {
    e1.printStackTrace(); // don‘t do this
    }
    }
    else
    {
    try
    {
    con.close();
    } catch (JMSException e) {
    e.printStackTrace(); // don‘t do this
    }
    }
    }
    }