.net core 基于Hangfire+Mysql持久化实现定时任务配置方法

1.negut引入hangfire相关包

hangfire.aspnetcore，hangfire.core，hangfire.dashboard.basicauthorization，hangfire.mysqlstorage

2.appsetting 配置hangfire资源

"hangfire": {
    "connection": "server=127.0.0.1;uid=root;pwd=wakamysql666;database=hangfire_db;allowloadlocalinfile=true;allow user variables=true;",
    "pathmatch": "/hangfire",
    "login": "login",
    "passwordclear": "pwd"
  },

3.自定义扩展类

/// <summary>
    ///     任务调度
    /// </summary>
    public static class hangfiresetup
    {
        public static void addhangfiresetup(this iservicecollection services)
        {
            if (services == null) throw new argumentnullexception(nameof(services));
            if (services == null) throw new argumentnullexception(nameof(services));
            services.addhangfire(configuration => configuration
                .setdatacompatibilitylevel(compatibilitylevel.version_170)//此方法 只初次创建数据库使用即可
                .usesimpleassemblynametypeserializer()
                .userecommendedserializersettings()
                .usestorage(new mysqlstorage(appsettings.app("hangfire", "connection"), new mysqlstorageoptions
                {
                    transactionisolationlevel =
                        (isolationlevel?) system.data.isolationlevel.readcommitted, //事务隔离级别。默认是读取已提交
                    queuepollinterval = timespan.fromseconds(15), //- 作业队列轮询间隔。默认值为15秒。
                    jobexpirationcheckinterval = timespan.fromhours(1),
                    countersaggregateinterval = timespan.fromminutes(5),
                    prepareschemaifnecessary = false, // 如果设置为true，则创建数据库表。默认是true
                    dashboardjoblistlimit = 50000,
                    transactiontimeout = timespan.fromminutes(1),
                    tablesprefix = "hangfire"
                })));
            services.addhangfireserver();
        }
    }

4.在startupconfigureservices注入扩展

   services.addhangfiresetup();//任务调度

5.配置middleware

//任务调度中间件
    public static class hangfiremiddleware
    {
        public static void usehangfiremiddleware(this iapplicationbuilder app)
        {
            if (app == null) throw new argumentnullexception(nameof(app));
            app.usehangfireserver(); //配置服务//configureoptions()
            app.usehangfiredashboard(appsettings.app("hangfire", "pathmatch"), hfauthor()); //配置面板
            //backgroundjob.enqueue(() => console.writeline("hello world from hangfire!"));            
            hangfireservice(); //配置各个任务
        }

        /// <summary>
        ///     配置账号模板信息
        /// </summary>
        /// <returns></returns>
        public static dashboardoptions hfauthor()
        {
            var filter = new basicauthauthorizationfilter(
                new basicauthauthorizationfilteroptions
                {
                    sslredirect = false,
                    requiressl = false,
                    logincasesensitive = false,
                    users = new[]
                    {
                        new basicauthauthorizationuser
                        {
                            login = appsettings.app("hangfire", "login"), //可视化的登陆账号
                            passwordclear = appsettings.app("hangfire", "passwordclear") //可视化的密码
                        }
                    }
                });
            return new dashboardoptions
            {
                authorization = new[] {filter}
            };
        }

        /// <summary>
        ///     配置启动
        /// </summary>
        /// <returns></returns>
        public static backgroundjobserveroptions configureoptions()
        {
            return new()
            {
                queues = new[] {"job", nameof(hangfireconfigurequeue.picturetooss)}, //队列名称，只能为小写
                workercount = environment.processorcount * 5, //并发任务
                servername = "hangfireserver" //代表服务名称
            };
        }

        #region 配置服务

        public static void hangfireservice()
        {
            // "0 0 1 * * ? " 每天凌晨一点执行阿里云oss
            recurringjob.addorupdate<iorderiteminfoservice>(_ => _.joboss(), "0 0 1 * * ? ", timezoneinfo.local,
                nameof(hangfireconfigurequeue.picturetooss));

            // "0 0 1 * * ? " 每天早上七点执行定时任务更新汇率
            recurringjob.addorupdate<icurrencyinfosservice>(_ => _.updateratebyjob(), "0 0 7 * * ? ",
                timezoneinfo.local, nameof(hangfireconfigurequeue.picturetooss));
        }

        #endregion
    }

6.startupconfigure配置使用中间件

 app.usehangfiremiddleware();//job

效果图：

结语：到此hangfire实现定时任务的配置已经全部完成。

到此这篇关于.net core 基于hangfire+mysql持久化实现定时任务的文章就介绍到这了,更多相关.net core hangfire定时任务内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！