ICode9

精准搜索请尝试: 精确搜索
首页 > 其他分享> 文章详细

Hangfire-执行定时任务框架

2020-11-27 10:00:31  阅读:198  来源: 互联网

标签:框架 Hangfire System WriteLog 任务 using 定时 执行


Hangfire-执行定时任务框架

1、新建netframwork console 控制台项目ConsoleHangfireTest,nuget程序包 添加Hangfire

2、项目ConsoleHangfireTest右键,添加OWIN Startup 类

 

 代码内容:

复制代码
using System;
using System.Threading.Tasks;
using System.Web.Http;
using Hangfire;
using Microsoft.Owin;
using Owin;

[assembly: OwinStartup(typeof(ConsoleHangfireTest.Startup1))]

namespace ConsoleHangfireTest
{
    public class Startup1
    {
        public void Configuration(IAppBuilder app)
        {

            //HttpConfiguration configuration = new HttpConfiguration();
            //configuration.Routes.MapHttpRoute(
            //    name: "default",
            //    routeTemplate: "api/{controller}/{action}/{id}",
            //    defaults: new { id = RouteParameter.Optional }
            //    );
            //app.UseWebApi(configuration);

            // 有关如何配置应用程序的详细信息,请访问 https://go.microsoft.com/fwlink/?LinkID=316888
            //定时任务的持久化使用Sqlserver进行,当然也可以使用mongodb,redis等其他的
            GlobalConfiguration.Configuration.UseSqlServerStorage("Data Source=MOP6EXV9E5J1M1F;Initial Catalog=mydb;Integrated Security=True;");
            //启用Hangfire服务
            app.UseHangfireServer();
            //启用Hangfire Dashboard面板
            app.UseHangfireDashboard();
        }
    }
}
复制代码

 

3、项目ConsoleHangfireTest右键,添加TestHangfire

代码如下:

复制代码
using Hangfire;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleHangfireTest
{
    public static class TestHangfire
    {
        [Obsolete]
        public static void Start()
        {
            //支持基于队列的任务处理:任务执行不是同步的,而是放到一个持久化队列中,以便马上把请求控制权返回给调用者。
            var jobId = BackgroundJob.Enqueue(() => WriteLog("------Enqueue 队列任务"));

            //延迟任务执行:不是马上调用方法,而是设定一个未来时间点再来执行。
            BackgroundJob.Schedule(() => WriteLog("------Schedule 延时任务"), TimeSpan.FromSeconds(10));

            //循环任务执行:一行代码添加重复执行的任务,其内置了常见的时间循环模式,也可基于CRON表达式来设定复杂的模式。
            RecurringJob.AddOrUpdate(() => WriteLog("------AddOrUpdate 每分钟执行任务"), Cron.Minutely); //注意最小单位是分钟

            //延续性任务执行:类似于.NET中的Task,可以在第一个任务执行完之后紧接着再次执行另外的任务
            BackgroundJob.ContinueWith(jobId, () => WriteLog("------ContinueWith 连续任务"));

        }
        public static void WriteLog(string msg)
        {
            Trace.WriteLine($"Hangfire在 {DateTime.Now} 执行了任务:[{msg}]");
        }
    }
}
复制代码

 

 

4、项目ConsoleHangfireTest的Program.cs内容如下:

复制代码
using Hangfire;
using Microsoft.Owin.Hosting;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleHangfireTest
{
    class Program
    {
        static void Main(string[] args)
        {
            Console.WriteLine("启动服务。。。");
            WebApp.Start<Startup1>("http://localhost:8090/");//注意之后的斜杠不要忘记了

            //string baseAddress = "http://127.0.0.1:8090/";
            //WebApp.Start<Startup>(url: baseAddress);

            Console.WriteLine("服务启动成功。。。");

            //TestHangfire.Start();
            Start();
            Console.ReadLine();
        }
        [Obsolete]
        public static void Start()
        {
            //支持基于队列的任务处理:任务执行不是同步的,而是放到一个持久化队列中,以便马上把请求控制权返回给调用者。
            var jobId = BackgroundJob.Enqueue(() => WriteLog("Enqueue 队列任务"));

            //延迟任务执行:不是马上调用方法,而是设定一个未来时间点再来执行。
            BackgroundJob.Schedule(() => WriteLog("Schedule 延时任务"), TimeSpan.FromSeconds(10));

            //循环任务执行:一行代码添加重复执行的任务,其内置了常见的时间循环模式,也可基于CRON表达式来设定复杂的模式。
            RecurringJob.AddOrUpdate(() => WriteLog("AddOrUpdate 每分钟执行任务"), Cron.Minutely); //注意最小单位是分钟

            //延续性任务执行:类似于.NET中的Task,可以在第一个任务执行完之后紧接着再次执行另外的任务
            BackgroundJob.ContinueWith(jobId, () => WriteLog("ContinueWith 连续任务"));

        }
        public static void WriteLog(string msg)
        {
            Debug.WriteLine($"Hangfire在 {DateTime.Now} 执行了任务:[{msg}]");
        }
    }
}
复制代码

 

 

5、运行如下:

 

 

浏览器地址栏输入:http://localhost:8090/hangfire/

Hangfire的仪表盘显示

 

 

 

 

数据库显示:

 

 

注意:

    如果运行时报错误,“ System.MissingMemberException:找不到服务器工厂”

System.MissingMemberException: The server factory could not be located for the given input: Microsoft.Owin.Host.HttpListener

其实是缺少Microsoft.Owin.Host.HttpListener,使用NuGet添加一下即可

标签:框架,Hangfire,System,WriteLog,任务,using,定时,执行
来源: https://www.cnblogs.com/1175429393wljblog/p/14046409.html

本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享;
2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关;
3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关;
4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除;
5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

专注分享技术,共同学习,共同进步。侵权联系[81616952@qq.com]

Copyright (C)ICode9.com, All Rights Reserved.

ICode9版权所有