Hangfire源码解析-任务是如何执行的?

一、Hangfire任务执行的流程

  1. 任务创建时:
    • 将任务转换为Type并存储(如:HangFireWebTest.TestTask, HangFireWebTest, Version=1.0.0.0, Culture=neutral, PublicKeyToken=null)
    • 将参数序列化后存储
  2. 任务执行时:
    • 根据Type值判断是否是静态方法,若非静态方法就根据Type从IOC容器中取实例。
    • 反序列化参数
    • 使用反射调用方法:MethodInfo.Invoke

二、Hangfire执行任务

从源码中找到“CoreBackgroundJobPerformer”执行任务的方法

internal class CoreBackgroundJobPerformer : IBackgroundJobPerformer
{
private readonly JobActivator _activator; //IOC容器
....省略 //执行任务
public object Perform(PerformContext context)
{
//创建一个生命周期
using (var scope = _activator.BeginScope(
new JobActivatorContext(context.Connection, context.BackgroundJob, context.CancellationToken)))
{
object instance = null; if (context.BackgroundJob.Job == null)
{
throw new InvalidOperationException("Can't perform a background job with a null job.");
} //任务是否为静态方法,若是静态方法需要从IOC容器中取出实例
if (!context.BackgroundJob.Job.Method.IsStatic)
{
instance = scope.Resolve(context.BackgroundJob.Job.Type); if (instance == null)
{
throw new InvalidOperationException(
$"JobActivator returned NULL instance of the '{context.BackgroundJob.Job.Type}' type.");
}
} var arguments = SubstituteArguments(context);
var result = InvokeMethod(context, instance, arguments); return result;
}
}
//调用方法
private static object InvokeMethod(PerformContext context, object instance, object[] arguments)
{
try
{
var methodInfo = context.BackgroundJob.Job.Method;
var result = methodInfo.Invoke(instance, arguments);//使用反射调用方法 ....省略 return result;
}
....省略
}
}
上一篇:一个控制台贪吃蛇小游戏(wsad控制移动)


下一篇:python 列表(list)常用操作