如何为配置了过滤器的MassTransit消费者编写单元测试

直接在现有测试配置中引入过滤器 #

你只需要在原有测试的服务注册和配置逻辑中补充过滤器相关的配置即可，和生产环境的配置逻辑对齐：

• 先将消费过滤器MyFilterConsumer<>及它依赖的所有服务注册到测试的DI容器中
• 通过AddConfigureEndpointsCallback方法给内存接收端添加和生产环境一致的过滤器配置

修改后的测试构造函数示例如下：

public ConsumerUnitTests()
{
    _provider = new ServiceCollection()
        // 注册过滤器及过滤器依赖的服务，比如日志、自定义业务服务等
        .AddScoped(typeof(MyFilterConsumer<>))
        .AddLogging()
        .AddMassTransitInMemoryTestHarness(cfg =>
        {
            cfg.AddConsumer<AssetEventUpdatedConsumer>();
            cfg.AddConsumerTestHarness<AssetEventUpdatedConsumer>();

            // 配置接收端规则，和生产逻辑对齐
            cfg.AddConfigureEndpointsCallback((provider, endpointName, cfg) =>
            {
                if (cfg is IInMemoryReceiveEndpointConfigurator inMemoryEp)
                {
                    inMemoryEp.UseConsumeFilter(typeof(MyFilterConsumer<>), provider);
                }
            });
        })
        .BuildServiceProvider(true);
    
    _harness = _provider.GetRequiredService<InMemoryTestHarness>();
    // 同步等待harness启动完成，避免偶发的异步时序问题
    _harness.Start().Wait();
}

复用生产环境现有配置 #

如果不想重复写配置逻辑，可以把生产环境的接收端配置抽为公共扩展方法，生产和测试场景共用同一套配置：

1. 首先在项目中新增公共配置扩展方法：

public static class MassTransitConfigExtensions
{
    public static void ConfigureMyAppReceiveEndpoint(this IReceiveEndpointConfigurator ep, IServiceProvider provider)
    {
        // 把你生产环境的所有接收端配置都移到这里
        ep.UseConsumeFilter(typeof(MyFilterConsumer<>), provider);
        ep.ConfigureConsumer<MyConsumer>(provider);
    }
}

2. 生产环境的配置直接调用该扩展方法：

cfg.ReceiveEndpoint("queue", ep =>
{
    ep.ConfigureMyAppReceiveEndpoint(provider);
});

3. 测试场景也直接调用同一扩展方法即可，不需要重新写配置：

cfg.AddConfigureEndpointsCallback((provider, endpointName, cfg) =>
{
    // 匹配你要测试的队列名，对应生产环境的接收端配置
    if (cfg is IInMemoryReceiveEndpointConfigurator inMemoryEp && endpointName == "queue")
    {
        inMemoryEp.ConfigureMyAppReceiveEndpoint(provider);
    }
});

如果你的过滤器依赖了外部资源（比如数据库、远程接口），只需要在测试的服务注册阶段把这些依赖替换为Mock实现即可，不需要修改公共配置逻辑。

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