1

我正在尝试IMessageBus在 FluentScheduler 的作业中使用注入的对象 ()。

我的 autofac 设置如下所示：

var thisAssembly = Assembly.GetExecutingAssembly();
var umbracoAssembly = typeof(UmbracoApplication).Assembly;
var builder = new ContainerBuilder();

// Controllers
builder.RegisterControllers(thisAssembly);
builder.RegisterApiControllers(thisAssembly);

// Umbraco related stuff (http://issues.umbraco.org/issue/U4-4181)
builder.RegisterControllers(umbracoAssembly);
builder.RegisterApiControllers(umbracoAssembly);

builder.RegisterType<MessageBus>().As<IMessageBus>();

Container = builder.Build();

我有一个看起来像这样的预定工作：

public class CourseAgentJob : IJob
{
    private IMessageBus _bus;

    public CourseAgentJob(IMessageBus bus)
    {
        _bus = bus;
    }

    public async void Execute()
    {
        ErrorLog.GetDefault(HttpContext.Current).Log(new Error(new Exception("Fire course agent")));
    }
}

当我的工作触发/设置时，我收到以下错误：

System.AggregateException：发生一个或多个错误。---> System.MissingMethodException：没有为此对象定义无参数构造函数。在 System.RuntimeTypeHandle.CreateInstance（RuntimeType 类型，Boolean publicOnly，Boolean noCheck，Boolean& canBeCached，RuntimeMethodHandleInternal& ctor，Boolean& bNeedSecurityCheck）在 System.RuntimeType.CreateInstanceSlow（Boolean publicOnly，Boolean skipCheckThis，Boolean fillCache，StackCrawlMark& stackMark）在 System.Activator.CreateInstanceT在 FluentScheduler.JobFactory.FluentScheduler.IJobFactory.GetJobInstanceT 在 A:\GitHub\FluentScheduler\Library\JobFactory.cs:第 25 行在 FluentScheduler.JobManager.<>c__12 1.<GetJobAction>b__12_0() in A:\GitHub\FluentScheduler\Library\JobManager.cs:line 66 at System.Threading.Tasks.Task.Execute() --- End of inner exception stack trace --- at System.Threading.Tasks.Task.ThrowIfExceptional(Boolean includeTaskCanceledExceptions) at System.Threading.Tasks.Task.Wait(Int32 millisecondsTimeout, CancellationToken cancellationToken) at FluentScheduler.JobManager.<>c__DisplayClass43_0.<RunJob>b__0() in A:\GitHub\FluentScheduler\Library\JobManager.cs:line 447 at System.Threading.Tasks.Task.Execute() ---> (Inner Exception #0) System.MissingMethodException: No parameterless constructor defined for this object. at System.RuntimeTypeHandle.CreateInstance(RuntimeType type, Boolean publicOnly, Boolean noCheck, Boolean& canBeCached, RuntimeMethodHandleInternal& ctor, Boolean& bNeedSecurityCheck) at System.RuntimeType.CreateInstanceSlow(Boolean publicOnly, Boolean skipCheckThis, Boolean fillCache, StackCrawlMark& stackMark) at System.Activator.CreateInstance[T]() at FluentScheduler.JobFactory.FluentScheduler.IJobFactory.GetJobInstance[T]() in A:\GitHub\FluentScheduler\Library\JobFactory.cs:line 25 at FluentScheduler.JobManager.<>c__121.b__12_0() 在 A:\GitHub\FluentScheduler\Library\JobManager .cs：第 66 行，位于 System.Threading.Tasks.Task.Execute()<

哪个看起来没有正确注册？我以前没有做过很多 DI/IoC，所以我有点迷茫。

4

2 回答 2

1

您需要设置 FluentScheduler 以使用您的 DI 容器，如此处所述：

FluentScheduler 使您可以轻松使用您选择的 IoC 工具来创建作业实例。简单实现IJobFactory。

使用 StructureMap 的示例：

using FluentScheduler;
using StructureMap;

public class StructureMapJobFactory : IJobFactory
{
    public IJob GetJobInstance<T>() where T : IJob
    {
        return ObjectFactory.Container.GetInstance<T>();
    }
}

public class MyRegistry : Registry
{
    public MyRegistry()
    {
        // Schedule an IJob to run at an interval
        Schedule<MyJob>().ToRunNow().AndEvery(2).Seconds();
    }
}

向 JobManager 注册新的作业工厂：

protected void Application_Start()
{
    JobManager.JobFactory = new StructureMapJobFactory();
    JobManager.Initialize(new MyRegistry()); 
}
于 2016-12-13T12:49:44.480 回答
0

目前最好的解决方案是：

Schedule(myDIContainer.Resolve<MyJob>()).ToRunEvery(1).Days().At(13, 55);

这是封闭的问题。

于 2018-05-28T12:36:29.700 回答