C# RabbitMQ EventHandler 中的依赖注入

Question

RabbitMQ 在收到消息时公开一个AsyncEventingBasicConsumer.Received EventHandler。

因为这是一个顶级事件，所以没有可用的依赖注入，除非为它创建了一个特定的范围并作为封闭变量传递。

#pragma warning disable CA2000 // Dispose objects before losing scope
var serviceScope = this.serviceProvider.CreateScope();
#pragma warning restore CA2000 // Dispose objects before losing scope

consumer.Received += async (object sender, BasicDeliverEventArgs eventArgs) => 
{
    try 
    {
         // Do something
    }
    finally
    {
        scope.Dispose();
    }
}

有没有更好的方法来处理像这样的顶级事件的 DI？

Answer 1

作为Received 处理程序的一部分运行的代码可以被视为您的Composition Root 的一部分。这是您将启动一个新的 DI 范围并从该范围解析您的服务并调用该服务的地方。

这类似于将 DI 应用于基于计时器触发的操作。我的书Dependency Injection Principles, Practices, and Patterns 的Section 8.3.3 包含一个这样的例子：

// Listing 8.14
public static class Program
{
    private static Composer composer;

    public static void Main(string[] args)
    {
        var money = new Money(    
            currency: new Currency(code: args[0]),    
            amount: decimal.Parse(args[1]));    

        composer = new Composer(LoadConnectionString());

        var timer = new Timer(interval: 60000);    
        timer.Elapsed += (s, e) => DisplayRates(money);  
        timer.Start();    

        Console.WriteLine("Press any key to exit.");
        Console.ReadLine();    
    }

    private static void DisplayRates(Money money)
    {
        CurrencyRateDisplayer displayer =
            composer.CreateRateDisplayer();    

        displayer.DisplayRatesFor(money);
    }

    private static string LoadConnectionString() { ... }
}