.NET定时任务组件Hangfire解析

Myth丶恋晨 2021-06-26 16:06 725阅读 0赞

项目慢慢就要开工了，很多园友都在问这个事情，看来大伙对这事很上心啊，事情需要一步步的来，尽量写出一个我们都满意的项目。以前每次在博客前面都会扯淡一下，不过很多人都抱怨这样做不好，加上我这人扯淡起来就停不住，有时候还会很感性的说出一些话，所以以后写博文尽量少扯淡。（如果博文有不足之处，还望多多指正，我也会及时的修改，如果只是单纯的刷存在感，说一些过激的话，那我就不怎么高兴了）

项目中很多时候都会使用到定时任务这样一个功能需求，在`.NET`中对于完成定时任务的技术还是不怎么多的，`.NET Framework`具有“内置”定时器功能，通过`System.Timers.Timer`类。  
在使用`Timer`类需要面对的问题：  
计时器没有持久化机制；  
计时器具有不灵活的计划（仅能设置开始时间和重复间隔，没有基于日期，时间等）；  
计时器不使用线程池（每个定时器一个线程）；  
计时器没有真正的管理方案 - 你必须编写自己的机制，以便能够记住，组织和检索任务的名称等。如果需要在.NET实现定时器的功能，可以尝试使用以下这款开源免费的组件`Quartz.Net`组件。

上面介绍了两种方式，在这里就介绍另外一种组件，那就是`Hangfire`组件。

## 一.`Hangfire`组件概述 ##

[在.NET和.NET][.NET_.NET] Core应用程序中执行后台处理的简单方法。无需Windows服务或单独的进程。由持久存储支持,存储方式有`sqlserver、redis，mongodb`等等。`Hangfire`支持所有类型的后台任务 **`- 短时间运行和长时间运行，CPU密集型和I / O密集型，一次性和周期性`**。

1.组件特点：  
![在这里插入图片描述][20190108105108223.png]  
2.组件功能：  
![在这里插入图片描述][20190108105122398.png]  
上面是对`Hangfire`组件背景的一些简单介绍，下面我们具体来了解一下`Hangfire`组件的使用方法。

## 二.`Hangfire`组件使用方法介绍 ##

既然想要学习了解一个组件，当然需要知道是怎么样取使用，如果不能使用，学着也没有什么很大的用处，下面介绍一下`Hangfire`组件的一些常用方法。

[1.ASP.NET][] MVC设置方式：

public void Configuration(IAppBuilder app)
    { 
        GlobalConfiguration.Configuration.UseSqlServerStorage("<connection string or its name>");
        app.UseHangfireDashboard();
        app.UseHangfireServer();
    }

`GlobalConfiguration`类是配置`Hangfire`的首选方式。这是一些方法的入口点，包括来自第三方存储实现或其他扩展的方法。用法很简单，只需`Hangfire`在应用程序初始化类中包含命名空间，并发现`GlobalConfiguration.Configuration`属性的扩展方法

2.控制台设置方式：

GlobalConfiguration.Configuration
                    .UseColouredConsoleLogProvider()               
    　　　　　　　　　 .UseSqlServerStorage(@"Server=.\sqlexpress;Database=Hangfire.Sample;Trusted_Connection=True;")
                    .UseMsmqQueues(@".\Private$\hangfire{0}", "default", "critical");

3.基于队列的任务处理：

var jobId = BackgroundJob.Enqueue(
        () => Console.WriteLine("Fire-and-forget!"));

4.延迟任务执行：

var jobId = BackgroundJob.Schedule(
        () => Console.WriteLine("Delayed!"),
        TimeSpan.FromDays(7));

5.循环任务执行：

RecurringJob.AddOrUpdate(
        () => Console.WriteLine("Recurring!"),
        Cron.Daily);

6.继续在其父作业完成时执行：

BackgroundJob.ContinueWith(
        jobId,
        () => Console.WriteLine("Continuation!"));

7.批处理方法：

var batchId = BatchJob.StartNew(x =>
    { 
        x.Enqueue(() => Console.WriteLine("Job 1"));
        x.Enqueue(() => Console.WriteLine("Job 2"));
    });

8.当父批次中的所有后台作业完成时，批处理继续：

BatchJob.ContinueWith(batchId, x =>
    { 
        x.Enqueue(() => Console.WriteLine("Last Job"));
    });

9.使用IoC容器：

public  class  ContainerJobActivator  ： JobActivator 
    {  
        private  IContainer  _container ;
        public  ContainerJobActivator （IContainer  container ）
        {  
            _container  =  container ; 
        }}
        public  override  object  ActivateJob （Type  type ）
        {  
            return  _container 。Resolve （type ）; 
        } 
    }

在启动`Hangfire`服务器之前将其注册为当前作业启动器。

var container = new Container();
    GlobalConfiguration.Configuration.UseActivator(new ContainerJobActivator(container));
    ...
    app.UseHangfireServer();

`Hangfire`将作业保存到持久存储中，并以可靠的方式处理它们。这意味着你可以中止`Hangfire`工作线程，卸载应用程序域甚至终止进程，工作将被处理。`Hangfire`将作业标记为已完成，只有当代码的最后一行执行，并知道作业可能会失败，最后一行。它包含不同的自动重试功能，可以处理代码中的存储错误或错误。

## 三.`Hangfire`组件核心对象解析 ##

上面介绍了`Hangfire`组件的常用方法，`Hangfire`组件的功能非常多，这里就做介绍了，有兴趣可以去官网进行查看api。下面介绍一下`Hangfire`组件的一些核心对象，初探`Hangfire`组件深层次的问题。

### 1.`RecurringJob.AddOrUpdate()`： ###

public static void AddOrUpdate(
                Expression<Action> methodCall,
                string cronExpression,
                TimeZoneInfo timeZone = null,
                string queue = EnqueuedState.DefaultQueue)
            { 
                var job = Job.FromExpression(methodCall);
                var id = GetRecurringJobId(job);
    
                Instance.Value.AddOrUpdate(id, job, cronExpression, timeZone ?? TimeZoneInfo.Utc, queue);
            }

该方法用于定期作业在指定的`CRON`计划上触发多次。该方法具有16个重载，`Job.FromExpression(methodCall);`用于获取基于`Job`类的新实例给定的方法调用的表达式树。`GetRecurringJobId(job)`方法根据`Job`对象获取对应的`JobID`。

### 2.`BackgroundJob.Enqueue()`： ###

public static string Enqueue([NotNull, InstantHandle] Expression<Action> methodCall)
            { 
                var client = ClientFactory();
                return client.Enqueue(methodCall);
            }

该方法基于给定的方法调用表达式创建一个新的`fire-and-forget`作业。该方法接受一个参数，表示将被编组到服务器的方法调用表达式。接下来我们看一下`var client = ClientFactory();`方法的具体实现

internal static Func<IBackgroundJobClient> ClientFactory
            { 
                get
                { 
                    lock (ClientFactoryLock)
                    { 
                        return _clientFactory ?? DefaultFactory;
                    }
                }
                set
                { 
                    lock (ClientFactoryLock)
                    { 
                        _clientFactory = value;
                    }
                }
            }

该属性定义了一个`Func<IBackgroundJobClient>`的泛型委托。该属性是一个可读可写的操作，对`ClientFactoryLock`加锁，确保不发生死锁情况。

## 四.总结 ##

上面简单的介绍了`Hangfire`组件的背景和一些简单的应用，也着重的介绍了一些对象。这个组件的功能很强大，需要了解的地方也较多，这一篇文章不可能全部介绍，用做抛砖引玉的作用。在这里吐槽一句，微软最近技术发展太快，很多技术还没有来得及发展，就有新的技术出来，让我们这些底层的人着实难受，事物发展有规律，不是以前缺的东西可以在很短的时间就可以补上，还是需要留下足够的空间。

[.NET_.NET]: http://xn--3ds.xn--NET-cj4e.NET
[20190108105108223.png]: /images/20210626/08a4a50228db406d88a7b6f2e88eff09.png
[20190108105122398.png]: /images/20210626/f1adc02566054c44a456547700b2c9f5.png
[1.ASP.NET]: http://1.ASP.NET