如何在DI环境中通过AddMediator()配置MassTransit的IConsumeMessageObserver？

我完全理解你遇到的困扰——手动构建ServiceProvider然后连接观察者的方式确实行不通，这是因为提前构建容器会打断MassTransit内部的DI注册流程，而且这种做法也不符合依赖注入的最佳实践。下面是正确的解决方案：

核心思路：利用MassTransit内置的DI集成注册观察者 #

MassTransit提供了专门的扩展方法，让你可以直接在AddMediator的配置委托中注册消费消息观察者，不需要手动解析实例。

步骤1：先将观察者注册到DI容器

首先确保你的观察者类已经被添加到服务集合中，根据业务需求选择合适的生命周期：

services.AddTransient<MailingObserver<RetrieveAddOnDownloadLinkContract>>();
services.AddTransient<IncrementAddOnDownloadCounterObserver<RetrieveAddOnDownloadLinkContract>>();

步骤2：在Mediator配置中注册观察者

有两种方式可以实现：

方式一：使用AddConsumeMessageObserver扩展方法（推荐）

这是最简单的方式，直接在配置委托中添加：

private static void BindInMemoryBroker(IServiceCollection services)
{
    // 先注册观察者到DI容器
    services.AddTransient<MailingObserver<RetrieveAddOnDownloadLinkContract>>();
    services.AddTransient<IncrementAddOnDownloadCounterObserver<RetrieveAddOnDownloadLinkContract>>();

    services.AddMediator(configuration =>
    {
        AddInMemoryAddOnBroker(configuration);

        // 直接注册消费消息观察者
        configuration.AddConsumeMessageObserver<MailingObserver<RetrieveAddOnDownloadLinkContract>>();
        configuration.AddConsumeMessageObserver<IncrementAddOnDownloadCounterObserver<RetrieveAddOnDownloadLinkContract>>();
    });
}

方式二：使用ConfigureMediator进行自定义连接

如果需要更灵活的初始化逻辑，可以用这个方法，它会提供DI上下文让你解析服务：

private static void BindInMemoryBroker(IServiceCollection services)
{
    services.AddTransient<MailingObserver<RetrieveAddOnDownloadLinkContract>>();
    services.AddTransient<IncrementAddOnDownloadCounterObserver<RetrieveAddOnDownloadLinkContract>>();

    services.AddMediator(configuration =>
    {
        AddInMemoryAddOnBroker(configuration);

        configuration.ConfigureMediator((context, mediator) =>
        {
            // 从DI上下文解析观察者实例
            var observer1 = context.GetRequiredService<MailingObserver<RetrieveAddOnDownloadLinkContract>>();
            var observer2 = context.GetRequiredService<IncrementAddOnDownloadCounterObserver<RetrieveAddOnDownloadLinkContract>>();
            
            // 连接到Mediator
            mediator.ConnectConsumeMessageObserver(observer1);
            mediator.ConnectConsumeMessageObserver(observer2);
        });
    });
}

为什么你的原方法无效？ #

你之前的代码在AddMediator之后立即调用BuildServiceProvider，这会导致：

• 提前构建的容器无法包含MassTransit后续注册的内部服务，导致Mediator实例未完全初始化
• 手动获取的Mediator实例和最终DI容器中注入的实例可能不是同一个，导致观察者连接没有生效

通过上面的方法，观察者会在Mediator初始化的过程中被正确连接，完全符合DI的工作流程。

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