一区二区三区在线-一区二区三区亚洲视频-一区二区三区亚洲-一区二区三区午夜-一区二区三区四区在线视频-一区二区三区四区在线免费观看

服務(wù)器之家:專注于服務(wù)器技術(shù)及軟件下載分享
分類導(dǎo)航

PHP教程|ASP.NET教程|Java教程|ASP教程|編程技術(shù)|正則表達式|C/C++|IOS|C#|Swift|Android|VB|R語言|JavaScript|易語言|vb.net|

服務(wù)器之家 - 編程語言 - ASP.NET教程 - .net core中Quartz的使用方法

.net core中Quartz的使用方法

2019-06-19 17:09♀影☆響 ASP.NET教程

這篇文章主要介紹了.net core中Quartz的使用方法,小編覺得挺不錯的,現(xiàn)在分享給大家,也給大家做個參考。一起跟隨小編過來看看吧

原來工作中有用到定時任務(wù)Quartz,不過是在MVC項目中,現(xiàn)在net core項目中也要用到,就開始改版。中間發(fā)現(xiàn)在網(wǎng)上的教程只有執(zhí)行定時計劃的過程,卻很少有人寫注冊的過程,覺得有點略坑。所以寫此文章一是自己做個記錄,二是希望能幫助到其他人。后面還把此功能做出了多任務(wù)定時執(zhí)行,網(wǎng)上關(guān)于net core的教程更是少了,花費了不少時間實現(xiàn)了出來。

Quartz版本:3.0.7

1.NuGet中下載安裝Quartz

2.新建Quartz幫助類

(1)新建QuartzJob類,代碼如下:

public class QuartzJob : IJob
  {
    public async Task Execute(IJobExecutionContext context)
    {
      var jobKey = context.JobDetail.Key;//獲取job信息
      var triggerKey = context.Trigger.Key;//獲取trigger信息

      LogHelper.Info($"{DateTime.Now} QuartzJob:==>>自動執(zhí)行.{jobKey.Name}|{triggerKey.Name}");
      await Task.CompletedTask;
    }
  }

ps: 上面代碼中的jobKey和triggerKey可獲取到自己定義的job和trigger的信息,這樣做多任務(wù)時可區(qū)分要執(zhí)行的是哪個任務(wù). 另LogHelper.Info是自己封裝好的日子記錄類,可替換為自己的日志類

(2)新建QuartzFactory類,代碼如下:

public class QuartzFactory : IJobFactory
  {
    private readonly IServiceProvider _serviceProvider;

    public QuartzFactory(IServiceProvider serviceProvider)
    {
      _serviceProvider = serviceProvider;
    }

    public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
    {
      var jobDetail = bundle.JobDetail;

      var job = (IJob)_serviceProvider.GetService(jobDetail.JobType);
      return job;
    }

    public void ReturnJob(IJob job)
    {
    }
  }

(3)新建QuartzService類,代碼如下:

#region 單任務(wù)
    public static void StartJob<TJob>() where TJob : IJob
    {
      var scheduler = new StdSchedulerFactory().GetScheduler().Result;

      var job = JobBuilder.Create<TJob>()
        .WithIdentity("job")
        .Build();

      var trigger1 = TriggerBuilder.Create()
        .WithIdentity("job.trigger")
        .StartNow()
        .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(5)).RepeatForever())
        .ForJob(job)
        .Build();

      scheduler.AddJob(job, true);
      scheduler.ScheduleJob(job, trigger1);
      scheduler.Start();
    }
    #endregion

    #region 多任務(wù)
    public static void StartJobs<TJob>() where TJob : IJob
    {
      var scheduler = new StdSchedulerFactory().GetScheduler().Result;

      var job = JobBuilder.Create<TJob>()
        .WithIdentity("jobs")
        .Build();

      var trigger1 = TriggerBuilder.Create()
        .WithIdentity("job.trigger1")
        .StartNow()
        .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(5)).RepeatForever())
        .ForJob(job)
        .Build();

      var trigger2 = TriggerBuilder.Create()
        .WithIdentity("job.trigger2")
        .StartNow()
        .WithSimpleSchedule(x => x.WithInterval(TimeSpan.FromSeconds(11)).RepeatForever())
        .ForJob(job)
        .Build();

      var dictionary = new Dictionary<IJobDetail, IReadOnlyCollection<ITrigger>>
      {
        {job, new HashSet<ITrigger> {trigger1, trigger2}}
      };
      scheduler.ScheduleJobs(dictionary, true);
      scheduler.Start();
    }
    #endregion

    #region 配置
    public static void AddQuartz(this IServiceCollection services, params Type[] jobs)
    {
      services.AddSingleton<IJobFactory, QuartzFactory>();
      services.Add(jobs.Select(jobType => new ServiceDescriptor(jobType, jobType, ServiceLifetime.Singleton)));

      services.AddSingleton(provider =>
      {
        var schedulerFactory = new StdSchedulerFactory();
        var scheduler = schedulerFactory.GetScheduler().Result;
        scheduler.JobFactory = provider.GetService<IJobFactory>();
        scheduler.Start();
        return scheduler;
      });
    }
    #endregion

3.在Startup.cs中注冊代碼

public void ConfigureServices(IServiceCollection services)
{
      services.AddQuartz(typeof(QuartzJob));

      //........
}


public void Configure(IApplicationBuilder app, IHostingEnvironment env, ILoggerFactory loggerFactory)
{
  QuartzService.StartJobs<QuartzJob>();
  //........
}

 ps: 因AddQuartz方法定義的是Type[]類型,所以可傳多個執(zhí)行類,如:services.AddQuartz(typeof(QuartzJob1), typeof(QuartzJob2)); 不過這樣做StartJob()方法就得另處理下,這里就略過

OK,大功告成,這個東西折騰了兩天終于塵埃落定了,執(zhí)行結(jié)果如下:

.net core中Quartz的使用方法

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持服務(wù)器之家。

延伸 · 閱讀

精彩推薦
主站蜘蛛池模板: 91视频免费网站 | 日本69视频在线观看 | 男人肌肌捅女人 | 欧美性videossex丝袜 | 17岁俄罗斯csgo | 4399h漫画| 含羞草传媒网站免费进入欢迎 | 青草视频在线观看免费资源 | 日韩精品一区二区三区毛片 | 全肉np巨肉一女np高h双龙 | 欧美日韩中文国产一区二区三区 | 日韩一区二区三区在线 | 日韩一级片在线观看 | 窝窝影院午夜色在线视频 | www91在线观看| 岛国免费大片 | 色综合图片 | kisssis无减删全集在线观看 | 精品一久久香蕉国产线看播放 | 午夜a一级毛片 | 91寡妇天天综合久久影院 | 亚洲国产精品无圣光一区二区 | 欧美整片在线 | 日本高清中文字幕视频在线 | 国产欧美成人免费观看 | 性色香蕉AV久久久天天网 | 欧美久久综合网 | 亚洲精品综合 | 国产成人啪精品午夜在线播放 | 色淫阁小说| 女人叉开腿让男人捅 | 亚洲天堂网在线观看视频 | 91麻豆精品 | 天天操夜夜操狠狠操 | 成人一区二区免费中文字幕 | 国产精品久久一区 | 成人黄色免费网站 | 我们中文在线观看免费完整版 | 扒开斗罗美女了的胸罩和内裤漫画 | 青青网| 精品国产欧美一区二区 |