洋葱架构下NUnit+FluentValidation测试失败问题排查

报错的核心原因是你的MediatR验证管道行为（PipelineBehavior）中，使用了同步的Validate方法调用带有异步规则的AddVehicleCommandValidator——你修改测试代码只是修正了断言的异步调用方式，但没解决验证器本身被同步触发的问题。

1. 检查并修改MediatR验证行为类 #

找到项目中实现IPipelineBehavior<TRequest, TResponse>的验证行为类（通常命名类似ValidationBehavior），如果是同步调用验证器的Validate方法，就会触发该异常。

错误实现示例：

public class ValidationBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
    where TRequest : IRequest<TResponse>
{
    private readonly IEnumerable<IValidator<TRequest>> _validators;

    public ValidationBehavior(IEnumerable<IValidator<TRequest>> validators)
    {
        _validators = validators;
    }

    public TResponse Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
    {
        // 同步Validate会触发异步验证器异常
        var context = new ValidationContext<TRequest>(request);
        var failures = _validators.Select(v => v.Validate(context))
                                  .SelectMany(result => result.Errors)
                                  .Where(f => f != null)
                                  .ToList();

        if (failures.Any())
            throw new ValidationException(failures);

        return next();
    }
}

修改为异步实现，使用ValidateAsync：

public class ValidationBehavior<TRequest, TResponse> : IPipelineBehavior<TRequest, TResponse>
    where TRequest : IRequest<TResponse>
{
    private readonly IEnumerable<IValidator<TRequest>> _validators;

    public ValidationBehavior(IEnumerable<IValidator<TRequest>> validators)
    {
        _validators = validators;
    }

    public async Task<TResponse> Handle(TRequest request, RequestHandlerDelegate<TResponse> next, CancellationToken cancellationToken)
    {
        var context = new ValidationContext<TRequest>(request);
        // 改用异步ValidateAsync并await
        var validationTasks = _validators.Select(v => v.ValidateAsync(context, cancellationToken));
        var results = await Task.WhenAll(validationTasks);

        var failures = results.SelectMany(r => r.Errors)
                              .Where(f => f != null)
                              .ToList();

        if (failures.Any())
            throw new ValidationException(failures);

        return await next();
    }
}

2. 确认服务注册正确性 #

确保验证行为按异步方式注册到DI容器中，通常在Startup的ConfigureServices里：

services.AddTransient(typeof(IPipelineBehavior<,>), typeof(ValidationBehavior<,>));

3. 验证器异步规则检查 #

确认AddVehicleCommandValidator中存在异步规则（比如使用MustAsync）：

public class AddVehicleCommandValidator : AbstractValidator<AddVehicleCommand>
{
    public AddVehicleCommandValidator(IVehicleRepository repository)
    {
        RuleFor(x => x.Vehicle.UniqueId)
            .MustAsync(async (id, cancellation) => 
                !await repository.ExistsByUniqueIdAsync(id, cancellation))
            .WithMessage("UniqueId已存在");
    }
}

这类异步规则必须通过ValidateAsync触发，同步调用Validate会抛出目标异常。

完成以上修改后，测试即可正常运行。

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