c# - 将 Ninject 与 EasyNetQ/RabbitMQ 消息处理程序一起使用

我正在尝试使用 EasyNetQ 和 Ninject 来记录消息。

我已经设法将 Ninject 设置为 EasyNetQ DI(我认为)，但是当消息到达没有无参数构造函数的处理程序时(例如，我需要在其中绑定(bind)一个存储库)，它无法解析。或者至少我相信这是问题所在，因为我在控制台上遇到了一个非常普遍的错误。

我告诉 EasyNetQ 像这样使用 Ninject:

RabbitHutch.SetContainerFactory(() => new NinjectAdapter(container));

我想这就是我需要设置的全部内容。 Ninject Adapter 来自 EasyNetQ。

我的处理程序如下所示:

public class ProfileDeactivatedUpdateHandler : IConsume<ProfileDeactivatedUpdate>
{
    private readonly IProfileRepository _profileRepository;

    public ProfileDeactivatedUpdateHandler(IProfileRepository profileRepository)
    {
        _profileRepository = profileRepository;
    }

    public void Consume(ProfileDeactivatedUpdate message)
    {
        //Do Stuff.
    }
}

如果我添加一个无参数构造函数，而是将 Ninject 设置为通过 ServiceLocator(呃)可用，那么它就可以工作了。处理程序被调用得很好，我可以通过 ServiceLocator 找到我的存储库，所以我知道至少 Ninject 知道存储库。

尝试处理消息时弹出的错误是。

System.AggregateException: One or more errors occurred. ---> System.Exception: E
xception of type 'System.Exception' was thrown.
   at EasyNetQ.ReflectionHelpers.DefaultFactories`1.Get()
   at EasyNetQ.ReflectionHelpers.CreateInstance[T]()
   at EasyNetQ.AutoSubscribe.DefaultAutoSubscriberMessageDispatcher.Dispatch[TMe
ssage,TConsumer](TMessage message)
   at EasyNetQ.RabbitBus.<>c__DisplayClass6`1.<Subscribe>b__5(T msg)
   --- End of inner exception stack trace ---
---> (Inner Exception #0) System.Exception: Exception of type 'System.Exception'
 was thrown.
   at EasyNetQ.ReflectionHelpers.DefaultFactories`1.Get()
   at EasyNetQ.ReflectionHelpers.CreateInstance[T]()
   at EasyNetQ.AutoSubscribe.DefaultAutoSubscriberMessageDispatcher.Dispatch[TMe
ssage,TConsumer](TMessage message)
   at EasyNetQ.RabbitBus.<>c__DisplayClass6`1.<Subscribe>b__5(T msg)<---

最佳答案

所以我已经解决了这个问题。显然，当 EasyNetQ 实例化处理程序时，它不使用指定的 DI 框架来执行此操作(嘘!)。您必须单独指定“MessageDispatcher”实现。惊人的!哦... 但是... Autofac 只有一个实现，而不是 Ninject (Boo! x2)。

所以，我的拉取请求在这里是为 Ninject 实现事件调度器的代码在这里:
https://github.com/mikehadlow/EasyNetQ/pull/309

现在，您可以将该类复制并粘贴到您的项目中。然后在您的 NinjectModule 或您设置绑定(bind)的任何地方，您可以执行以下操作:

//Bind Message Dispatcher to Ninject event message dispatcher
NinjectMessageDispatcher messageDispatcher = new NinjectMessageDispatcher(Kernel);
Bind<IAutoSubscriberMessageDispatcher>().ToConstant(messageDispatcher);

然后，无论您在何处设置订阅者，都可以执行以下操作(请注意，这是使用 EasyNetQ 的 IConsume 接口(interface)进行自动订阅。

var subscriber = new AutoSubscriber(_serviceBus, "ProfileServices");
subscriber.AutoSubscriberMessageDispatcher = _dispatcher;
subscriber.Subscribe(Assembly.GetExecutingAssembly());

重要的部分是手动将 MessageDispatcher 设置为 ninject 调度程序的实例。您想如何实现这一目标取决于您。

我认为将来，EasyNetQ 可能需要自动执行此操作。显然，如果您将工厂设置为使用 Ninject，那么您的处理程序很可能也希望使用 Ninject。

哦!您可以修改上述代码以使用您选择的 DI。这需要为与 EasyNetQ 一起使用的任何 DI 完成(我认为)，而不仅仅是 Ninject。

关于c# - 将 Ninject 与 EasyNetQ/RabbitMQ 消息处理程序一起使用，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/26744781/