Hangfire_hangfire的基本特征与优点「建议收藏」

Hangfire_hangfire的基本特征与优点「建议收藏」1.Hangfire是什么?Hangfire是一个后台作业执行服务组件,可以集成在ASP.NET、ASP.NETCore、控制台应用程序、Windows服务等

Hangfire_hangfire的基本特征与优点「建议收藏」"

1.Hangfire是什么?

Hangfire是一个后台作业执行服务组件,可以集成在ASP.NET、ASP.NET Core、控制台应用程序、Windows服务等。

2.Hangfire特点?

(1)无需Windows服务或单独的进程。

(2)支持持久化存储,存储方式可支持sqlserver、redis,mongodb等。

(3)支持分布式作业处理

(4)支持自动维护 ,无需执行手动存储清理 – hangfire会尽可能保持清洁并自动删除旧纪录。

(5)提供集成化面板,方便查看作业及监控

3.Hangfire作业流程

客户端:创建作业,序列化数据。

存储器:存储作业,存储序列化后的数据到Job中

服务器:执行作业,Hangfire Server定时轮询获取待执行的Job,同时Hangfire Server还负责保持存储器清洁并自动删除旧数据。

4.数据库表说明

(1)Job表生成准备执行计划数据

(2)State表中记录作业的状态变化(状态:计划中、等待、处理中、成功、失败)。

(3)Set表中记录定时任务信息,到时间后会生产一条数据到job表中

(4)Server表记录服务器信息

State表状态:

Scheduled(计划中)

Failed(失败)

Enqueued(排队中)

Processing(处理中)

Succeeded(成功)

Deleted(删除)

状态先后变化顺序:排队中->计划中->处理中->成功

5.如何使用Hangfire

(1)安装Hangfire使用命令或在NuGet中安装。

(2)配置Hangfire

ASP.NET Core配置示例:

  public class Startup
    {
        public void ConfigureServices(IServiceCollection services)
        {
            services.AddHangfire(x => x.UseSqlServerStorage("<connection string>"));
        }

        public void Configure(IApplicationBuilder app)
        {
            app.UseHangfireServer();//启动Hangfire服务
            app.UseHangfireDashboard();//启动Hangfire面板
        }
    }

运行无异常并且能查看仪表盘表示配置成功,查看仪表盘地址:https://your-site/hangfire/

6.Hangfire作业类型

(1)“队列”作业

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

“队列”作业执行步骤如下:

① 序列化方法信息及其所有参数。

② 根据序列化信息创建新的后台作业。

③ 将后台作业保存到持久存储。

④ 将后台作业排入队列。

⑤ Hangfire Server的Hangfire组件检查持久存储查找排队的后台作业并执行后删除作 业,排队作业由专用的工作线程池处理。

只有在处理成功后才会删除该作业。即使在作业期间终止了一个过程,Hangfire也会执行补偿逻辑以保证每个作业的处理。

(2)”延迟”作业

Hangfire Server会定期检查计划,将计划的作业排入队列执行。


BackgroundJob.Schedule(() => Console.WriteLine("Reliable!"), TimeSpan.FromDays(1));

(3)“重复”作业

操作重复执行的作业,重复时间设置可以设定每分、每时、每天、每周、每月和每年,还可以使用CRON表达式指定更复杂的计划。


RecurringJob.AddOrUpdate(() => Console.Write("Easy!"), Cron.Daily);
//设置时区为本地时区(每天10点49执行一次)
 RecurringJob.AddOrUpdate(() => Console.Write("Easy!"), "0 49 10 * * ?",TimeZoneInfo.Local);

CRON表达式:

每隔5秒执行一次:”*/5 * * * * ?”

每隔一分钟执行一次:”0 */1 * * * ?”

每天10点49分执行一次:”0 49 10 * * ?”

(4)“连续”作业

连续作业可以过将多个后台作业链接在一起来定义复杂的作业流程。


var id = BackgroundJob.Enqueue(() => Console.WriteLine("Hello, "));

BackgroundJob.ContinueWith(id, () => Console.WriteLine("world!"));

7.配置作业队列

配置作业队列可以配置优先执行作业顺序,ASP.NET Core在Startup.Configure中配置。

配置作业队列代码示例:

var options = new BackgroundJobServerOptions{

Queues = new[] { "a", "default" },// 队列名称,只能为小写

 WorkerCount = Environment.ProcessorCount * 5, //并发任务数

 ServerName = "hangfire1",//服务器名称
 
SchedulePollingInterval= TimeSpan.FromSeconds(3),//未设置轮询间隔Hangfire默认是15秒轮询间隔

};
app.UseHangfireServer(options);

注意:未设置轮询间隔时Hangfire默认是15秒的轮询间隔,如果对于实时性要求比较高可以自定义轮询间隔。

如何添加作业到指定的配置队列中

配置作业队列,在创建作业时要加上标识特性,在指定的类或方法上面加上如下标识[Queue(“a”)]

8.删除队列

(1)使用Hangfire仪表板删除

(2)使用函数删除

BackgroundJob.Delete(“jobID“);//返回值为true为删除成功,否则为失败

(3)自定义删除:

作业队列存储在存储器中的job表,如果需要取消队列可以执 行SQL修改状态为删除,SQL示例如下:

UPDATE a SET a.StateName=’Deleted’ FROM HangFire.Job a(xlock) where Id=4932 and StateName=’Enqueued’

说明:因为只有状态在“排队中”、“计划中”的才能删除。

状态如下:

Scheduled(计划中)

Failed(失败)

Enqueued(排队中)

Processing(处理中)

Succeeded(成功)

Deleted(删除)

状态先后变化顺序:排队中->计划中->处理中->成功

9.使用Redis存储

(1).NeGet中引用”Hangfire.Redis.StackExchange”

(2).在ConfigureServices方法中添加以下配置

Services.AddHanfire(x=>x.UseResisStorage(“redis连接字符串”));

说明:Hangfire.Redis.StackExchange非Hangfire官方组件,因官方组件Hangfire.pro是商业产品,需收费。

10使用IIS作为宿主时应用程序池空闲超时影响作业停止解决方案

问题:IIS会在20分钟不活动后将应用程序池设置为“超时”、此时“重复”作业和“延迟”作业将不会排队,并且不会处理排队的作业。

解决:查看官方解决方案 https://docs.hangfire.io/en/latest/deployment-to-production/making-aspnet-app-always-running.html

11.Hangfire仪表盘自定义配置远程访问

  1. 新添类实现接口IDashboardAuthorizationFilter

var httpContext = context.GetHttpContext();

return httpContext.User.Identity.IsAuthenticated;//验证是否通过

说明:该接口实现的方法返回true=验证通过,false=验证不通过

  1. StartupConfigure方法中添加如下代码:

 app.UseHangfireDashboard(“/hangfire”, new DashboardOptions

 {

      Authorization = new[] { new RestrictiveAuthorizationFilter() }

     //IsReadOnlyFunc = (DashboardContext context) => true, //只读视图

 });

 public class RestrictiveAuthorizationFilter : IDashboardAuthorizationFilter
    {
        private static System.Web.Caching.Cache cache = HttpRuntime.Cache;

        public bool Authorize([NotNull] DashboardContext context)
        {
            if (cache["admin"] == null)
            {
                string userName = context.Request.GetQuery("username");
                string pwd = context.Request.GetQuery("pwd");
                if (userName == "admin" && pwd == "123456")
                {
                    cache.Remove(userName);
                    cache.Insert(userName, pwd, null, DateTime.Now.AddHours(10), System.Web.Caching.Cache.NoSlidingExpiration);
                    return true;
                }
                else
                {
                    return false;
                }
            }
            else
            {
                return true;
            }
        }
    }

说明:请求/hangfire get方式传递参数验证

context.Request.GetQuery(“d”) //读取参数

今天的文章Hangfire_hangfire的基本特征与优点「建议收藏」分享到此就结束了,感谢您的阅读。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/71409.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注