使用 Ninject 进行依赖注入
以下示例显示如何使用 Ninject 作为 IoC 容器设置依赖注入。
首先将 CustomModule 类添加到 WebJob 项目中,然后在其中添加任何依赖项绑定。
public class CustomModule : NinjectModule
{
public override void Load()
{
Bind<IMyInterface>().To<MyService>();
}
}
然后创建一个 JobActivator 类:
class JobActivator : IJobActivator
{
private readonly IKernel _container;
public JobActivator(IKernel container)
{
_container = container;
}
public T CreateInstance<T>()
{
return _container.Get<T>();
}
}
在 Program 类的 Main 函数中设置 JobHost 时,将 JobActivator 添加到 JobHostConfiguration
public class Program
{
private static void Main(string[] args)
{
//Set up DI
var module = new CustomModule();
var kernel = new StandardKernel(module);
//Configure JobHost
var storageConnectionString = "connection_string_goes_here";
var config = new JobHostConfiguration(storageConnectionString) { JobActivator = new JobActivator(kernel) };
//Pass configuration to JobJost
var host = new JobHost(config);
// The following code ensures that the WebJob will be running continuously
host.RunAndBlock();
}
}
最后在 Functions.cs 类中,注入你的服务。
public class Functions
{
private readonly IMyInterface _myService;
public Functions(IMyInterface myService)
{
_myService = myService;
}
public void ProcessItem([QueueTrigger("queue_name")] string item)
{
_myService .Process(item);
}
}