TransactionScope的使用
- 简介
- 1. 命名空间
- 2.创建事务范围
- 3.嵌套事务
- 4.事务提交和回滚
- 5.支持分布式事务
- 6.配置选项
- 7.资源管理器
- 8.分布式事务协调器
- 应用
- 1.未设置分布式事务
- 2.设置分布式事务
简介
TransactionScope 是 .NET Framework 和 .NET Core 中的一个类,用于简化事务管理。它提供了一种简单的方式来创建分布式事务和本地事务,以确保一系列操作要么全部成功提交,要么全部回滚,以保持数据的一致性
1. 命名空间
在代码中使用 TransactionScope 时,需要导入以下命名空间:
using System.Transactions;
2.创建事务范围
要使用 TransactionScope,您可以通过创建一个新的 TransactionScope 对象来定义一个事务范围。这个事务范围将包裹一系列数据库或其他资源操作。
using (TransactionScope scope = new TransactionScope())
{
// 在这里执行事务性操作
}
3.嵌套事务
您可以在代码中嵌套多个 TransactionScope 对象,形成多层嵌套的事务。在这种情况下,只有最外层的事务范围会影响整个事务。如果内部的事务范围失败,它们会自动回滚,而最外层的事务范围可以选择提交或回滚整个事务
4.事务提交和回滚
在 TransactionScope 中,如果代码成功执行,您可以调用 Complete() 方法来提交事务,确保所有操作都成功。如果在 TransactionScope 中发生异常或其他问题,事务将自动回滚,所有操作都将撤销。
5.支持分布式事务
TransactionScope 支持分布式事务,这意味着您可以在不同的数据库或资源上执行操作,并将它们包装在一个分布式事务中,以确保一致性。
6.配置选项
TransactionScope 允许您配置事务的选项,如超时时间、隔离级别等,以满足特定的业务需求。
7.资源管理器
TransactionScope 使用资源管理器来管理事务,这包括数据库、消息队列、文件系统等。每个资源管理器需要提供一个事务参与者,以便 TransactionScope 能够协调它们的事务。
8.分布式事务协调器
在分布式事务中,TransactionScope 使用分布式事务协调器(DTC)来协调事务。DTC 协调器确保所有事务参与者在提交或回滚时协调一致性。
应用
1.未设置分布式事务
现有数据
这里没有设置事务,且通过NetCore+EF实现的增删改查功能
[HttpGet]
[Route("Transaction")]
public async Task Transaction(int id)
{
try
{
//using (System.Transactions.TransactionScope scope = new System.Transactions.TransactionScope())
//{
//增加Student
_studentService.Add(new Student { Name = "DX", Address = "上城1", Sex = "男", Phone = "123456" });
//获取指定Id的Student
Student item = _studentService.GetById(id).Result;
//更新数据
_studentService.Upate(item);
//删除数据
_studentService.Delete(item);
//抛出异常
throw new Exception();
//scope.Complete();
//}
}
catch (ThreadAbortException ex)
{
throw ex;
}
}
正常抛出异常
在不设置分布式事务的情况下,数据在抛出异常情况时,并未回滚操作,而是全部执行完成
2.设置分布式事务
[HttpGet]
[Route("Transaction")]
public async Task Transaction(int id)
{
try
{
using (System.Transactions.TransactionScope scope = new System.Transactions.TransactionScope())
{
_studentService.Add(new Student { Name = "DX", Address = "上城1", Sex = "男", Phone = "123456" });
Student item = _studentService.GetById(id).Result;
_studentService.Upate(item);
_studentService.Delete(item);
throw new Exception();
scope.Complete();
}
}
catch (ThreadAbortException ex)
{
throw ex;
}
}
抛出异常
数据没有改变,说明因为抛出了异常所以进行了操作的回滚