CQRS模式下批量删除用户的性能优化与代码复用方案咨询

针对你在.NET 6 + EF Core 6.0 Clean Architecture项目中遇到的批量删除问题，先梳理现有方案的核心痛点，再给出更合理的解决思路：

现有方案的问题 #

• 方案1（重复编写批量逻辑）：性能达标，但完全违反DRY原则。后续如果要扩展删除逻辑（比如同步删除第三方关联数据、添加业务日志、更新统计指标），必须同时修改单删和批量删两处代码，不仅维护成本高，还容易出现业务逻辑不一致的问题。
• 方案2（给单删命令加SaveChanges开关）：能复用业务逻辑，但污染了单删命令的职责——单删命令原本的设计就是完成独立的删除事务，添加开关后，命令的行为变得模糊，其他开发者调用时可能误设参数，而且如果单删逻辑中存在依赖SaveChanges()的操作（比如触发领域事件、获取变更后的状态），批量模式下会直接出错。

更优解决方案 #

1. 提取核心业务逻辑到领域服务 #

把单删中非持久化的业务规则（比如用户存在性校验、第三方数据清理、领域事件触发等）抽离到独立的领域服务中，让单删和批量删命令都依赖这个服务，各自处理持久化逻辑：

// 领域服务：封装所有用户删除的核心业务规则
public class UserDomainService
{
    public void EnsureUserExists(User user)
    {
        if (user is null)
            throw new NotFoundException("指定用户不存在");
    }

    public async Task CleanupThirdPartyAssociations(Guid userId)
    {
        // 调用第三方API删除关联数据、清理缓存等业务操作
    }
}

// 单删命令处理器：负责单个用户的完整事务
public class DeleteUserByIdCommandHandler : IRequestHandler<DeleteUserByIdCommand>
{
    private readonly AppDbContext _dbContext;
    private readonly UserDomainService _userDomainService;

    public DeleteUserByIdCommandHandler(AppDbContext dbContext, UserDomainService userDomainService)
    {
        _dbContext = dbContext;
        _userDomainService = userDomainService;
    }

    public async Task Handle(DeleteUserByIdCommand request, CancellationToken cancellationToken)
    {
        var user = await _dbContext.Users.FindAsync(request.Id, cancellationToken);
        _userDomainService.EnsureUserExists(user);
        
        await _userDomainService.CleanupThirdPartyAssociations(user.Id);
        
        _dbContext.Users.Remove(user);
        await _dbContext.SaveChangesAsync(cancellationToken);
    }
}

// 批量删命令处理器：负责批量场景的高效持久化
public class DeleteUsersByIdBulkCommandHandler : IRequestHandler<DeleteUsersByIdBulkCommand>
{
    private readonly AppDbContext _dbContext;
    private readonly UserDomainService _userDomainService;

    public DeleteUsersByIdBulkCommandHandler(AppDbContext dbContext, UserDomainService userDomainService)
    {
        _dbContext = dbContext;
        _userDomainService = userDomainService;
    }

    public async Task Handle(DeleteUsersByIdBulkCommand request, CancellationToken cancellationToken)
    {
        // 一次查询获取所有要删除的用户
        var users = await _dbContext.Users
            .Where(u => request.Ids.Contains(u.Id))
            .ToListAsync(cancellationToken);

        // 校验所有用户存在性（批量校验避免重复查询）
        var existingIds = users.Select(u => u.Id).ToHashSet();
        var missingIds = request.Ids.Except(existingIds).ToList();
        if (missingIds.Any())
            throw new NotFoundException($"不存在的用户ID：{string.Join(", ", missingIds)}");

        // 执行核心业务逻辑
        foreach (var user in users)
        {
            await _userDomainService.CleanupThirdPartyAssociations(user.Id);
            _dbContext.Users.Remove(user);
        }

        // 单次提交所有变更
        await _dbContext.SaveChangesAsync(cancellationToken);
    }
}

这种方式既保证了业务逻辑的复用，又让每个命令的职责清晰，批量操作只需要2次数据库请求（查询+提交），性能完全达标。

2. 纯数据库批量操作（适用于无复杂业务场景） #

如果你的批量删除只是单纯的数据库记录删除，不需要复杂的业务校验或第三方操作，可以直接用EF Core的批量删除能力（EF Core 6.0可以借助第三方库如EntityFrameworkCore.BulkExtensions，或者手写原生SQL）：

public async Task Handle(DeleteUsersByIdBulkCommand request, CancellationToken cancellationToken)
{
    // 校验用户存在性
    var existingCount = await _dbContext.Users
        .Where(u => request.Ids.Contains(u.Id))
        .CountAsync(cancellationToken);
    if (existingCount != request.Ids.Count)
        throw new NotFoundException("部分用户不存在");

    // 批量删除（仅需一次数据库请求）
    await _dbContext.Users
        .Where(u => request.Ids.Contains(u.Id))
        .ExecuteDeleteAsync(cancellationToken);
}

这种方案性能最优，但仅适合无额外业务逻辑的场景。

3. 借助Unit of Work控制事务边界 #

如果你的项目已经实现了Unit of Work模式，可以拆分单删命令的逻辑：

• 把单删中的业务逻辑和持久化操作分离成独立方法
• 批量删命令调用这些独立方法，最后由Unit of Work统一提交事务

这种方式同样能复用逻辑，但需要注意不要直接调用单删命令的Handle方法，避免重复触发提交。

规范准则参考 #

• DRY原则优先于代码简洁：业务逻辑必须复用，避免重复；但纯持久化代码（如批量删除的EF操作）可以独立实现，因为这属于不同命令的职责范围。
• CQRS命令要保持职责单一：单删命令负责单个用户的完整事务，批量删命令负责批量场景的高效处理，两者共享核心业务规则，但不互相调用。
• 避免给命令添加开关参数：命令的行为应该是明确的，不能通过参数改变其核心逻辑，否则会增加维护复杂度和出错概率。

内容的提问来源于stack exchange，提问作者Plamen Michev