当前位置：首页 > news >正文

ABP UnitOfWork（工作单元）是什么？

news 2026/5/12 20:11:34

在 ABP 框架中，UnitOfWork（工作单元）是核心的数据库操作模式，本质是把一组相关的数据库操作（增 / 删 / 改 / 查）封装成一个 “原子单元”—— 要么这组操作全部成功提交，要么全部失败回滚，以此保证数据的一致性。

你可以把它理解成：去超市买东西，所有商品先放进购物车（对应收集数据库操作），到收银台才一次性结账（对应提交事务）；如果中途不想买了，购物车清空（对应回滚事务），而不是拿一件结一次账（避免部分操作成功、部分失败）。

1. UnitOfWork 的核心作用

事务管理：自动为数据库操作创建并管理事务，确保一组操作的原子性。
连接管理：统一管理数据库连接的打开 / 关闭，避免频繁创建连接导致性能损耗。
自动提交 / 回滚：默认情况下，操作无异常则自动提交事务，有异常则自动回滚。
跨方法共享：支持在多个方法间共享同一个工作单元（比如 Service 层调用多个 Repository 方法，共用一个事务）。

2. ABP 中 UnitOfWork 的使用方式

ABP 框架对 UnitOfWork 做了高度封装，大部分场景下无需手动控制，核心使用方式分两种：

（1）自动生效（最常用）

ABP 默认对以下方法自动启用 UnitOfWork：

应用服务（Application Service）的公共方法
领域服务（Domain Service）的公共方法
仓储（Repository）的公共方法

示例：自动启用 UnitOfWork 的应用服务

public class OrderAppService : ApplicationService { private readonly IRepository<Order, Guid> _orderRepository; private readonly IRepository<OrderItem, Guid> _orderItemRepository; public OrderAppService(IRepository<Order, Guid> orderRepository, IRepository<OrderItem, Guid> orderItemRepository) { _orderRepository = orderRepository; _orderItemRepository = orderItemRepository; } // ABP自动为这个方法创建UnitOfWork，包含事务 public async Task CreateOrderAsync(CreateOrderDto input) { // 1. 创建订单（操作1） var order = new Order { CustomerName = input.CustomerName, CreateTime = DateTime.Now }; await _orderRepository.InsertAsync(order); // 2. 创建订单项（操作2） foreach (var itemInput in input.Items) { var orderItem = new OrderItem { OrderId = order.Id, ProductName = itemInput.ProductName, Quantity = itemInput.Quantity }; await _orderItemRepository.InsertAsync(orderItem); } // 无需手动提交！ABP会自动提交事务；如果代码抛出异常，自动回滚 } }

（2）手动启用（特殊场景）

如果方法不在上述自动生效的范围内（比如普通类的方法），可以通过[UnitOfWork]特性或IUnitOfWorkManager手动开启。

示例 1：用特性手动启用

public class CustomService { private readonly IRepository<Product, Guid> _productRepository; public CustomService(IRepository<Product, Guid> productRepository) { _productRepository = productRepository; } // 手动标记开启UnitOfWork [UnitOfWork] public async Task UpdateProductAsync(Guid id, string newName) { var product = await _productRepository.GetAsync(id); product.Name = newName; await _productRepository.UpdateAsync(product); } }

示例 2：手动控制事务（高级场景）

public class AdvancedService : ITransientDependency { private readonly IUnitOfWorkManager _unitOfWorkManager; private readonly IRepository<Product, Guid> _productRepository; public AdvancedService(IUnitOfWorkManager unitOfWorkManager, IRepository<Product, Guid> productRepository) { _unitOfWorkManager = unitOfWorkManager; _productRepository = productRepository; } public async Task DoComplexOperationAsync() { // 手动创建工作单元 using (var uow = _unitOfWorkManager.Begin()) { try { // 执行多个数据库操作 await _productRepository.InsertAsync(new Product { Name = "产品1" }); await _productRepository.InsertAsync(new Product { Name = "产品2" }); // 手动提交 await uow.CompleteAsync(); } catch (Exception) { // 异常时自动回滚（无需手动操作，using块会释放并回滚） throw; } } } }