使用MassTransit.Testing测试含Mediator的消费者为何断言失败？

1. 关联消费者与消息接收端点 #

测试代码仅注册了消费者，但未将其与CarCreatedEvent的接收端点绑定，导致TestHarness无法把发送的消息路由到消费者。修改SetUp方法中的配置：

_provider = new ServiceCollection()
    .AddMassTransitInMemoryTestHarness(cfg =>
    {
        // 注册消费者
        cfg.AddConsumer<CarCreatedConsumer>();
        
        // 配置内存总线，绑定消费者到接收端点
        cfg.UsingInMemory((context, busConfig) =>
        {
            busConfig.ReceiveEndpoint("car-created-event-endpoint", endpointConfig =>
            {
                // 将消费者配置到该端点，处理CarCreatedEvent
                endpointConfig.ConfigureConsumer<CarCreatedConsumer>(context);
            });
        });
    })
    .AddMediator()
    .BuildServiceProvider(true);

2. 采用正确的消息发送方式 #

如果CarCreatedEvent是事件类型，更适合用发布（Publish）而非发送（Send）到特定队列，这样所有订阅该事件的消费者都会收到消息：

await _harness.Bus.Publish<CarCreatedEvent>(new 
{
    CarId = Guid.NewGuid().ToString(), // 确保与CarCreatedEvent的属性类型一致
    CarOwnerName = "John Stuart"
    // 补充其他必填属性
});

如果需要发送到指定的消费者队列，可获取对应端点的SendEndpoint：

var sendEndpoint = await _harness.GetSendEndpoint(new Uri("queue:car-created-event-endpoint"));
await sendEndpoint.Send<CarCreatedEvent>(new 
{
    // 属性内容
});

3. 等待异步消费完成 #

消息消费是异步操作，直接断言可能因未处理完成导致失败。使用TestHarness提供的异步断言方法，等待消息被消费：

// 等待最多2秒，直到消息被消费
Assert.True(await _harness.Consumed.Any<CarCreatedEvent>(TimeSpan.FromSeconds(2)));

4. 验证消息属性匹配 #

确保发送的匿名对象属性与CarCreatedEvent的属性名称、类型完全一致：

• 如果CarCreatedEvent.CarId是Guid类型，发送时应使用Guid.NewGuid()而非Guid.NewGuid().ToString()
• 所有必填属性必须完整提供，避免因消息类型不匹配导致无法路由

额外检查：IMediator注入是否正常 #

消费者依赖IMediator，测试中通过.AddMediator()注册了Mediator，可添加调试代码验证依赖注入是否正常：

var consumer = _provider.GetRequiredService<CarCreatedConsumer>();
Assert.NotNull(consumer); // 验证消费者能被正确创建，间接验证IMediator注入正常

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