AspNet Core結合Quartz使用定時任務且通過註入緩存或者配置參數

来源:https://www.cnblogs.com/lxshwyan/archive/2019/05/17/10880112.html
-Advertisement-
Play Games

一、經常在項目會用到定時任務同步數據或更新緩存等操作,在很久以前我們可能經常會用一個多線程或timer來做定時任務,這樣能實現比較簡單輕量級的任務;對於任務多且都調用頻率不一樣的任務,我們都會用到Quartz.Net這個組件; Quartz.NET是一個強大、開源、輕量的作業調度框架,你能夠用它來為 ...


         一、經常在項目會用到定時任務同步數據或更新緩存等操作,在很久以前我們可能經常會用一個多線程或timer來做定時任務,這樣能實現比較簡單輕量級的任務;對於任務多且都調用頻率不一樣的任務,我們都會用到Quartz.Net這個組件;

                Quartz.NET是一個強大、開源、輕量的作業調度框架,你能夠用它來為執行一個作業而創建簡單的或複雜的作業調度。它有很多特征,如:資料庫支持,集群,插件,支持cron-like表達式等等

        二、  接下來簡單演示一下Quartz使用:

          2.1  首先新建一個AspNet Core API 項目,通過nuget包管理器安裝引用Quartz

 

            2.2  新建一個模擬任務類UserInfoSyncjob 必須繼承IJob介面

namespace QuartzDemo.Quarzs
{
    public class UserInfoSyncjob : IJob
    {
          
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(() =>
                        {  
                             //.....
                             Console.WriteLine($"{DateTime.Now.ToString()}:開始執行同步第三方數據");
                             //....同步操作
                           
                        });
        }
    }
}

      2.2  聲明一個啟動類QuartzStartup,來控制任務啟動關閉等方法

            添加啟動方法

   public async Task<string> Start()                                           
        {
            //1、聲明一個調度工廠
            _schedulerFactory = new StdSchedulerFactory();
            //2、通過調度工廠獲得調度器
            _scheduler = await _schedulerFactory.GetScheduler();  
            //3、開啟調度器
            await _scheduler.Start();
            //4、創建一個觸發器
            var trigger = TriggerBuilder.Create()
                            .WithSimpleSchedule(x => x.WithIntervalInSeconds(2).RepeatForever())//每兩秒執行一次
                            .Build();
            //5、創建任務
            var jobDetail = JobBuilder.Create<UserInfoSyncjob>()
                            .WithIdentity("job", "group")
                            .Build();
            //6、將觸發器和任務器綁定到調度器中
            await _scheduler.ScheduleJob(jobDetail, trigger);
            return await Task.FromResult("將觸發器和任務器綁定到調度器中完成");
        }

         2.3  在網站啟動完成時調用QuartzStartup的Start方法開啟任務

                   先註入 Quartz調度類

          

                      添加網站啟動開始方法

       2.4、運行效果,運行之前將控制台開啟(方便查看任務是否在執行,實際環境可寫日誌)

 

    該調度任務完成,上方定義的觸發器是2秒一次,所以該任務每隔2秒執行;(也可以通過配置文件,控制執行平率,cron表達式可以很好控制)

     三、第二結簡單演示了Quartz的基本用法,本文重點不是主要講解Quartz的用法,上方只是為了沒使用過Quartz的同行有個簡單映像,如果想詳細學習,博客園有很多類似的文章,也可以和我探討一下!

            本文重點是每個任務類怎麼通過註入獲取其他類的使用及參數配置類等等;

         假如有這樣一個需求,UserInfoSyncjob同步任務裡面需要配置資料庫連接參數和日誌記錄、緩存記錄等,在之前我們可能通過配置類、日誌類、緩存類以工廠形式單例創建獲取。

在AspNet Core自帶IOC容器框架,很多配置類、日誌類、緩存類等等,在全局很多地方都會使用,我們現在做法就是把這些類註入到IOC容器中,如果需要的只需要從構造方法中獲取;

        我們都知道如果一個從構造方法中獲取IOC容器裡面的類型實例,必須該類型也要主要到IOC容器中,這樣我們就要想辦法把UserInfoSyncjob通過容器來創建生產;

        通過源碼發現在Quartz有一個預設的生成job的工廠類Quartz.Simpl.SimpleJobFactory  

using System;
using Quartz.Logging;
using Quartz.Spi;
using Quartz.Util;
namespace Quartz.Simpl
{
 /// <summary> 
 /// The default JobFactory used by Quartz - simply calls 
 /// <see cref="ObjectUtils.InstantiateType{T}" /> on the job class.
 /// </summary>
 /// <seealso cref="IJobFactory" />
 /// <seealso cref="PropertySettingJobFactory" />
 /// <author>James House</author>
 /// <author>Marko Lahma (.NET)</author>
 public class SimpleJobFactory : IJobFactory
 {
  private static readonly ILog log = LogProvider.GetLogger(typeof (SimpleJobFactory));
 
  /// <summary>
  /// Called by the scheduler at the time of the trigger firing, in order to
  /// produce a <see cref="IJob" /> instance on which to call Execute.
  /// </summary>
  /// <remarks>
  /// It should be extremely rare for this method to throw an exception -
  /// basically only the case where there is no way at all to instantiate
  /// and prepare the Job for execution. When the exception is thrown, the
  /// Scheduler will move all triggers associated with the Job into the
  /// <see cref="TriggerState.Error" /> state, which will require human
  /// intervention (e.g. an application restart after fixing whatever
  /// configuration problem led to the issue with instantiating the Job).
  /// </remarks>
  /// <param name="bundle">The TriggerFiredBundle from which the <see cref="IJobDetail" />
  /// and other info relating to the trigger firing can be obtained.</param>
  /// <param name="scheduler"></param>
  /// <returns>the newly instantiated Job</returns>
  /// <throws> SchedulerException if there is a problem instantiating the Job. </throws>
  public virtual IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
  {
   IJobDetail jobDetail = bundle.JobDetail;
   Type jobType = jobDetail.JobType;
   try
   {
    if (log.IsDebugEnabled())
    {
     log.Debug($"Producing instance of Job '{jobDetail.Key}', class={jobType.FullName}");
    }
 
    return ObjectUtils.InstantiateType<IJob>(jobType);
   }
   catch (Exception e)
   {
    SchedulerException se = new SchedulerException($"Problem instantiating class '{jobDetail.JobType.FullName}'", e);
    throw se;
   }
  }
 
  /// <summary>
  /// Allows the job factory to destroy/cleanup the job if needed. 
  /// No-op when using SimpleJobFactory.
  /// </summary>
  public virtual void ReturnJob(IJob job)
  {
   var disposable = job as IDisposable;
   disposable?.Dispose();
  }
 }
}

      SimpleJobFactory 實現了IJobFactory介面,通過源碼發現我們如果要替換該工廠來控制job的生成,只需要創建一個IOCJobFactory來替換預設job工廠就行

 

public class IOCJobFactory : IJobFactory
    {
        private readonly IServiceProvider _serviceProvider;
        public IOCJobFactory(IServiceProvider serviceProvider)
        {
           _serviceProvider = serviceProvider;      
        }
        public IJob NewJob(TriggerFiredBundle bundle, IScheduler scheduler)
        {    
            return _serviceProvider.GetService(bundle.JobDetail.JobType) as IJob;
        
        }

        public void ReturnJob(IJob job)
        {
            var disposable = job as IDisposable;
            disposable?.Dispose();

        }
    }

     在調度任務類裡面重新設置job工廠  _scheduler.JobFactory = _iocJobfactory;

      在IOC中註入 UserInfoSyncjob、StdSchedulerFactory、IOCJobFactory    

 services.AddTransient<UserInfoSyncjob>();      // 這裡使用瞬時依賴註入
            services.AddSingleton<ISchedulerFactory, StdSchedulerFactory>();//註冊ISchedulerFactory的實例。
            services.AddSingleton<QuartzStartup>();
            services.AddSingleton<IJobFactory,IOCJobFactory>();

 

  修改UserInfoSyncjob任務類,可以通過構造方法註入的方式從容器中拿到日誌實現類、緩存類等等

   

 public class UserInfoSyncjob : IJob
    {
        private readonly ILogger<UserInfoSyncjob> _logger;
      //  private readonly ICache _cache;
        public UserInfoSyncjob(ILogger<UserInfoSyncjob> logger)
        {
            //_cache = cache;
            _logger = logger;// EnginContext.Current.Resolve<ILogger<UserInfoSyncjob>>();
        }
        public Task Execute(IJobExecutionContext context)
        {
            return Task.Run(() =>
                        {  
                             //.....
                            // Console.WriteLine($"{DateTime.Now.ToString()}:開始執行同步第三方數據");
                            _logger.LogInformation ($"{DateTime.Now.ToString()}:開始執行同步第三方數據");
                             //....同步操作
                             //  我們都知道如果一個從構造方法中獲取IOC容器裡面的類型,必須該類型也要主要到IOC容器中;
                           
                        });
        }
    }

     調整後運行截圖

具體詳細步驟請看源碼:https://github.com/lxshwyan/QuartzDemo.git

 

    

        

          

  

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • fireasy 面世都有六個年頭了,至今依舊是默默無聞,知道它的人可能僅限於本人朋友圈內的人士。本人也在寫一本關於如何使用該框架的書籍,但苦於事務繁忙,至今也才寫了一半,可以說最為實用最為核心的部分,仍然還沒有寫出來。思來想去,還是通過博文這種方式,通過一個實例的講解,讓朋友們對 fireasy 有 ...
  • 作者:依樂祝 原文地址:https://www.cnblogs.com/yilezhu/p/10880884.html 我們都知道.NET Core是一個可以用來構建現代、可伸縮和高性能的跨平臺軟體應用程式的通用開發框架。可用於為Windows、Linux和MacOS構建軟體應用程式。與其他軟體框架 ...
  • 在C#的編程開發過程中,很多時候涉及到數據類型的轉換,如果強行轉換數據類型,有時候可能會出現程式運行時錯誤,C#語言中提供了is關鍵字可以檢查對象是否與給定類型相容,可先判斷類型相容後再進行對象的轉換。使用is關鍵字可以有效地方防止類型轉換中出現的異常。 例如有個A類的對象entityA,需要判斷e ...
  • 在C#的編程開發過程中,有時候判斷字元串是否相等時,並不關註字母的大小寫,此時在C#中可以使用ToUpper方法將字元串中所有的字母轉換為大寫,使用ToLower方法可以將字元串中所有字母轉換為小寫。 例如有個字元串string testStr=“AbcDefg”; (1)轉換為大寫:string ...
  • Response對象是Asp.Net應用程式中非常重要的一個內置對象,其作用為負責將伺服器執行好的信息輸出給客戶端,可以使用Response.WriteFile方法來像客戶端輸出文件或者圖片,輸出圖片的時候需要將文件類型設置為"image/JPEG"、"image/GIF"等等。 例如我們要出tes ...
  • 在很多人面試C#開發工程師的時候,會遇到一個面試題,就是C#中String和string有啥區別。其實針對這個問題C#中String和string沒有本質上的區別,兩者在程式中都可使用,稍微的一個區別在於小寫string是大寫String的別名,具體區別分析如下: MSDN中對string的說明:s ...
  • Cookie對象是伺服器為用戶訪問存儲的特定信息,這些信息一般存儲在瀏覽器中,伺服器可以從提交的數據中獲取到相應的Cookie信息,Cookie的最大用途在於伺服器對用戶身份的確認,即票據認證,用戶會話分配的SessionId會存儲在Cookie中,通過這個Cookie中的SessionId可以提供 ...
  • SmartSql = MyBatis + Cache(Memory | Redis) + R/W Splitting +Dynamic Repository + Diagnostics ...... ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...