• 首页 首页 icon
  • 工具库 工具库 icon
    • IP查询 IP查询 icon
  • 内容库 内容库 icon
    • 快讯库 快讯库 icon
    • 精品库 精品库 icon
    • 问答库 问答库 icon
  • 更多 更多 icon
    • 服务条款 服务条款 icon

C# 定时服务:Hangfire使用、和Quartz的对比

武飞扬头像
一锦一瑟思华年
帮助1

Querz:Windows任务计划程序位于ASP.NET环境之外。它可以用来运行任何类型的Windows程序。要添加Windows任务,您需要登录到服务器。

Hangfire通常在IIS进程中运行(尽管它也可以在控制台应用程序中运行)。 Hangfire的主要优点是开发人员无需登录IIS服务器即可创建计划任务 - 在供应商托管的IIS环境中,服务器访问不可用时尤其有用。

定时任务调度问题,是一个老生常谈的问题。网上有许多定时任务调度的解决方案,对于我而言很早以前主要是使用Window计划和Window服务来做任务定时执行,然后就开始使用定时任务调度框架Quartz.Net。但是却一直没有上手过Hangfire这个自带后台任务调度面板,可以在后台手动执行任务的神奇的任务调度框架。前段时间终于开始对他下手了,通过在网上查阅了一些资料和查看了Hangfire在Github中的demo,终于在我自己的项目中用上了Hangfire。在该篇文章中主要简单介绍一下什么是Hangfire,Hangfire的基本特征与优点和使用PostgreSql作为存储使用。

一、Hangfire是什么:

  Hangfire是一个开源的.NET任务调度框架,提供了内置集成化的控制台,可以直观明了的查看作业调度情况,并且Hangfire不需要依赖于单独的应用程序执行(如:windows服务,window计划)。并且支持持久性存储。

二、Hangfire使用条件:

Hangfire与特定的.NET应用程序类型无关。您可以在ASP.NET Web应用程序,非ASP.NET Web应用程序,控制台应用程序或Windows服务中使用它。以下是要求:

1.NET Framework 4.5

2.永久存储(Hangfire将后台作业和其他与处理有关的信息保留在永久性存储器中,所以需要存储库来存储如:MS SQL Server,Redis,MySQL,PostgreSql等)

3.Newtonsoft.Json库≥5.0.1

三、Hangfire的基本特征与优点:

通过官网中的一张图片便可知道它是一个多么优秀的任务调度框架,如下图所示:

学新通

四、Hangfire安装和使用:

在NuGet上有关于Hangfire的 一系列软件包:

详情地址: NuGet Gallery | Packages matching Hangfire

1、安装Hangfire所需NuGet包:

Hangfire、Hangfire.Core、Hangfire.PostgreSql 

如下图:

学新通

 2、注册Hangfire

在startup.cs入口文件中添加

  1.  
    public void ConfigureServices(IServiceCollection services)
  2.  
    {
  3.  
    services.AddCustomHangfire(Configuration);
  4.  
    }

 注册

  1.  
    public static class CustomExtension
  2.  
    {
  3.  
     
  4.  
    /// <summary>
  5.  
    /// 注册Hangfire
  6.  
    /// </summary>
  7.  
    /// <param name="services"></param>
  8.  
    /// <param name="configuration"></param>
  9.  
    /// <returns></returns>
  10.  
    public static IServiceCollection AddCustomHangfire(this IServiceCollection services, IConfiguration configuration)
  11.  
    {
  12.  
     
  13.  
    #region Job
  14.  
    services.AddHostedService<WisdomReportMonthJob>();
  15.  
     
  16.  
    services.AddHostedService<WisdomReportDayJob>();
  17.  
    #endregion
  18.  
     
  19.  
    var vDbType = configuration["CurrentDbType"];
  20.  
     
  21.  
    services.AddHangfire(x => x.UsePostgreSqlStorage(configuration[$"DataBase:{vDbType}:JYTDBConnString"], new PostgreSqlStorageOptions
  22.  
    {
  23.  
    //如果设置为true,则创建数据库表。默认是true
  24.  
    PrepareSchemaIfNecessary = Convert.ToBoolean(configuration["Hangfire:PrepareSchemaIfNecessary"]),
  25.  
    QueuePollInterval = TimeSpan.FromSeconds(1)
  26.  
    }));
  27.  
    services.AddHangfireServer();
  28.  
     
  29.  
    return services;
  30.  
    }
  31.  
    }
学新通

3、定义具体要执行的定时任务

  1.  
    public class WisdomReportMonthJob : IHostedService
  2.  
    {
  3.  
    private readonly IConfiguration _Configuration;
  4.  
     
  5.  
    /// <summary>
  6.  
    ///
  7.  
    /// </summary>
  8.  
    public WisdomReportMonthJob(IConfiguration configuration)
  9.  
    {
  10.  
    _Configuration = configuration;
  11.  
    }
  12.  
     
  13.  
    /// <summary>
  14.  
    /// 开启
  15.  
    /// </summary>
  16.  
    /// <param name="cancellationToken"></param>
  17.  
    /// <returns></returns>
  18.  
    public Task StartAsync(CancellationToken cancellationToken)
  19.  
    {
  20.  
    try
  21.  
    {
  22.  
    Hangfire.RecurringJob.AddOrUpdate("WisdomRunReportMonthJob", () => WisdomReportMonthJobExec(), Cron.Hourly(10),TimeZoneInfo.Local);
  23.  
    }
  24.  
    catch (Exception ex)
  25.  
    {
  26.  
    Log.Error(ex, "接口错误:" ex.Message);
  27.  
    }
  28.  
    return Task.CompletedTask;
  29.  
    }
  30.  
    /// <summary>
  31.  
    /// 执行
  32.  
    /// </summary>
  33.  
    public async Task WisdomReportMonthJobExec()
  34.  
    {
  35.  
    //TOdo 具体业务逻辑
  36.  
    }
  37.  
     
  38.  
    /// <summary>
  39.  
    /// 停止
  40.  
    /// </summary>
  41.  
    /// <param name="cancellationToken"></param>
  42.  
    /// <returns></returns>
  43.  
    public async Task StopAsync(CancellationToken cancellationToken)
  44.  
    {
  45.  
    await Task.Run(() =>
  46.  
    {
  47.  
    Log.Information("已停止运行!");
  48.  
    }, cancellationToken);
  49.  
    }
  50.  
    }
学新通

其中定时周期可以 

每个小时的哪一分钟开始执行 Cron.Hourly(10);

每天的具体哪个时间点执行 Cron.Daily(0, 9);

当然还有其他的一些执行的周期格式,按照官方文档的使用方式使用即可。

程序运行后会自动生成对应的Hangfire数据库,这里需要注意的是,执行周期运行后是持久性、周期性的,如果你变更了其中的周期,就需要重新将生成的Hangfire数据库清空,然后重新运行,保证定时任务能在你新修改的周期内运行。

如图,即为自动生成的数据库:

学新通

这篇好文章是转载于:学新通技术网

  • 版权申明: 本站部分内容来自互联网,仅供学习及演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系,请提供相关证据及您的身份证明,我们将在收到邮件后48小时内删除。
  • 本站站名: 学新通技术网
  • 本文地址: /boutique/detail/tanhgbikkf
系列文章
更多 icon
同类精品
更多 icon
继续加载