spring原理（五）

发表于

JPA原理

事务

　　事务是计算机应用中不可或缺的组件模型，它保证了用户操作的原子性(Atomicity)、一致性(Consistency)、隔离性(Isolation )和持久性(Durabilily)。

本地事务

　　紧密依赖于底层资源管理器（例如数据库连接 )，事务处理局限在当前事务资源内。此种事务处理方式不存在对应用服务器的依赖，因而部署灵活却无法支持多数据源的分布式事务。在数据库连接中使用本地事务示例如下：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
public void transferAccount() {
	Connection conn = null;
	Statement stmt = null;
	try {
		conn = getDataSource().getConnection();
		// 将自动ᨀ交设置为 false，若设置为 true 则数据库将会把每一次数据更新认定为一个事务并自动ᨀ交
		conn.setAutoCommit(false);
		stmt = conn.createStatement();
		// 将 A 账户中的金额减少 500
		stmt.execute("update t_account set amount = amount - 500 where account_id = 'A'");
		// 将 B 账户中的金额增加 500
		stmt.execute("update t_account set amount = amount + 500 where account_id = 'B'");
		// ᨀ交事务
		conn.commit();
		// 事务ᨀ交：转账的两步操作同时成功
	} catch (SQLException sqle) {
		// 发生异常，回滚在本事务中的操做
		conn.rollback();
		// 事务回滚：转账的两步操作完全撤销
		stmt.close();
		conn.close();
	}
}

分布式事务

　　Java事务编程接口（JTA：Java Transaction API）和Java事务服务(JTS；Java Transaction Service)为J2EE平台提供了分布式事务服务。分布式事务（Distributed Transaction）包括事务管理器（Transaction Manager）和一个或多个支持 XA 协议的资源管理器(Resource Manager )。我们可以将资源管理器看做任意类型的持久化数据存储；事务管理器承担着所有事务参与单元的协调与控制。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
public void transferAccount2() {
	UserTransaction userTx = null;
	Connection connA = null;
	Statement stmtA = null;
	Connection connB = null;
	Statement stmtB = null;
	try {
		// 获得 Transaction 管理对象
		userTx = (UserTransaction)getContext().lookup("java:comp/UserTransaction");
		connA = getDataSourceA().getConnection();// 从数据库 A 中取得数据库连接
		connB = getDataSourceB().getConnection();// 从数据库 B 中取得数据库连接
		userTx.begin(); // 启动事务
		stmtA = connA.createStatement();// 将 A 账户中的金额减少 500
		stmtA.execute("update t_account set amount = amount - 500 where account_id = 'A'");
		// 将 B 账户中的金额增加 500
		stmtB = connB.createStatement();
		stmtB.execute("update t_account set amount = amount + 500 where account_id = 'B'");
		userTx.commit();// 提交事务
		// 事务提交：转账的两步操作同时成功（数据库 A 和数据库 B 中的数据被同时更新）
	} catch (SQLException sqle) {
		// 发生异常，回滚在本事务中的操纵
		userTx.rollback();// 事务回滚：数据库 A 和数据库 B 中的数据更新被同时撤销
	} catch (Exception ne) {
	}
}

两阶段提交

　　两阶段提交主要保证了分布式事务的原子性：即所有结点要么全做要么全不做，所谓的两个阶段是指：第一阶段：准备阶段；第二阶段：提交阶段。
avatar

准备阶段

　　事务协调者(事务管理器)给每个参与者(资源管理器)发送Prepare消息，每个参与者要么直接返回失败(如权限验证失败)，要么在本地执行事务，写本地的redo和undo日志，但不提交，到达一种“万事俱备，只欠东风”的状态。

提交阶段

　　如果协调者收到了参与者的失败消息或者超时，直接给每个参与者发送回滚(Rollback)消息；否则，发送提交(Commit)消息；参与者根据协调者的指令执行提交或者回滚操作，释放所有事务处理过程中使用的锁资源。(注意:必须在最后阶段释放锁资源)

　　将提交分成两阶段进行的目的很明确，就是尽可能晚地提交事务，让事务在提交前尽可能地完成所有能完成的工作。