Ninject 和异步操作

Question

我现在已经在 Google 上搜寻了一下，以找到有关如何将 Ninject 与异步/等待操作一起使用的任何有用示例。我自己也尝试了一点，以找到任何可以使其实际工作而无需编写大量代码的模式，但我还没有设法使其工作。

对基本问题采取最简单的描述是实体框架DbContext是在每个请求范围的基础上创建的（它是一个 ASP.NET MVC 应用程序），但是如果您尝试调用任何*Async 方法它将失败并显示它已经在执行的信息（这很明显）。

所以，我需要的是调用 Kernel.Get<MyContext>() 使用 Ninject 创建唯一的 DbContext 对象，并且 Ninject 负责其生命周期。使用BeginBlock() 或将范围更改为InTransientScope() 并不是一个真正的选择，因为第一个选项会使代码非常繁重，带有单独的块并处理这些块，而后一组是负责处理DbContext 的调用者代码。

我想做的代码的POC示例：

var context1 = NinjectKernelReference.Get<MyContext>(); //I want this to be a unique reference
var context2 = NinjectKernelReference.Get<MyContext>(); //I want this to be a unique reference

var task1 = context1.Customers.Where(c => c.ZipCode == "4444")
                    .Select(c => new {
                                         c.Name,
                                         c.PhoneNumber
                                     })
                    .Take(50)
                    .ToArrayAsync();

var task2 = context2.Customers.CountAsync(c => c.ZipCode == "4444");

Task.WaitAll(task1, task2);

return new Result { task1.Result, task2.Result };

那么，有什么方法可以“简单”地解决这个问题？

Answer 1

这是您可以自己控制对象创建的方式：

public interface IContextFactory {
    MyContext Create();
}

kernel.Bind<IContextFactory>().ToFactory // requires ninjext.extensions.factory

(Factory Extension Link)

用法：

using(var context1 = IContextFactory.Create())
using(var context2 = IContextFactory.Create())
{
    var task1 = context1.Customers.Where(c => c.ZipCode == "4444")
                .Select(c => new {
                                     c.Name,
                                     c.PhoneNumber
                                 })
                .Take(50)
                .ToArrayAsync();

    var task2 = context2.Customers.CountAsync(c => c.ZipCode == "4444");

    Task.WaitAll(task1, task2);

    return new Result { task1.Result, task2.Result };
} // context get's disposed here

注意：这要求上下文不绑定.InRequestScope()，否则，两个.Create()调用将返回相同的对象。 如果您有时需要它们.InRequestScope() 有时不需要，您可以考虑使用ninject contextual binding

Answer 2

在挖掘并阅读了其他用户对这篇文章的回复后，我意识到这不是一个简单的方法。

所以我决定使用IKernel.BeginBlock 在我执行逻辑的并行线程执行中创建一个“本地”Ninject 范围。

它可能不像我想要的那么整洁，但它确实有效。

using( var block1 = NinjectKernelReference.BeginBlock())
using( var block2 = NinjectKernelReference.BeginBlock())
{
    var context1 = block1.Get<MyContext>(); 
    var context2 = block2.Get<MyContext>(); 

    var task1 = context1.Customers.Where(c => c.ZipCode == "4444")
                        .Select(c => new {
                                             c.Name,
                                             c.PhoneNumber
                                         })
                        .Take(50)
                        .ToArrayAsync();

    var task2 = context2.Customers.CountAsync(c => c.ZipCode == "4444");

    Task.WaitAll(task1, task2);

    return new Result { task1.Result, task2.Result };
}

它可能不是那么整洁，但它可以工作，我看不出它有任何缺点（除了 BeginBlock 和处理它的一些小性能问题之外）。