Abp後臺工作者類使用hangfire

来源:http://www.cnblogs.com/94pm/archive/2017/05/04/6803829.html
-Advertisement-
Play Games

一、Abp中的後臺工作及後臺工作者類 請閱讀這篇文章 二 、Abp官方實現的缺點 Abp官方實現方式很簡單,也很容易上手,但缺點是工作者類依賴了具體的基類(PeriodicBackgroundWorkerBase),就會存在應用程式耦合。 為什麼會耦合呢,假設以後想採用HangFire或Quartz ...


一、Abp中的後臺工作及後臺工作者類

請閱讀這篇文章

二 、Abp官方實現的缺點

Abp官方實現方式很簡單,也很容易上手,但缺點是工作者類依賴了具體的基類(PeriodicBackgroundWorkerBase),就會存在應用程式耦合。

 

為什麼會耦合呢,假設以後想採用HangFire或Quartz.NET來調度工作者,我們就需要把所有工作類的基類進行修改,這不利於系統的維護和可擴展,而且採用官方實現無法監測和管控工作者。

 

三、開始改造

1、核心庫

 要消除工作者類對具體調度類的依賴,則只能讓後臺工作者類繼承自不含調度實現的基類(BackgroundWorkerBase)或直接實現介面(IBackgroundWorker)。我定義了一個泛型基類(BackgroundWorker<T>),該基類繼承ABP核心庫的BackgroundWorkerBase,同時該基類必須實現我自定定義的IBackgroundWorkerDo介面。

BackgroundWorker<T>:所有後臺工作者類都該繼承的基類,加泛型參數的目的是Hangfire的RecurringJob.AddOrUpdate<T>方法在創建輪詢任務時必須知道它該調用哪個類的哪個方法

IBackgroundWorkerDo:  約束所有後臺工作者類必須實現DoWork,配合泛型參數,Hangfire的輪詢任務便可以知道T類型一定會有一個DoWork方法,然後在RecurringJob.AddOrUpdate<T>的方法體中便可以調用T類型實的DoWork方法

WorkerConfig類: 每個後臺工作者都應該有一個唯一的標識,執行間隔時間,這樣輪詢代理類才知道如何處理

IBackgroudWorkerProxy: 代替後臺工作者類執行其DoWork方法,所有輪詢調度類都應該實現該介面

    /// <summary>
    /// 所有的後臺工作者類都應實現該介面
    /// </summary>
    public interface IBackgroundWorkerDo
    {
        /// <summary>
        /// 執行具體的任務
        /// </summary>
        void DoWork();
    }

 

    /// <summary>
    /// 所有後臺工作者類都應繼承該類
    /// </summary>
    public abstract class BackgroundWorker<T> : BackgroundWorkerBase, IBackgroundWorkerDo where T : IBackgroundWorkerDo
    {
        protected readonly IBackgroudWorkerProxy _workProxy;
        protected readonly WorkerConfig _config;
        protected BackgroundWorker(IBackgroudWorkerProxy workProxy, WorkerConfig config)
        {
            _workProxy = workProxy;
            _config = config;
        }
        /// <summary>
        /// 任務啟動
        /// </summary>
        public override void Start()
        {
            Logger.Debug("輪詢任務啟動");
            _workProxy.Excete<T>(DoWork, _config); //主要指定當前任務類,不然hangfire無法調用,不然可以移到父類去
        }
        /// <summary>
        /// 具體的任務執行
        /// </summary>
        public abstract void DoWork();
    }

 

    /// <summary>
    /// 工作任務配置
    /// </summary>
    public class WorkerConfig
    {
        /// <summary>
        /// 輪詢秒數
        /// </summary>
        public int IntervalSecond { get; set; }
        /// <summary>
        /// 工作唯一編號
        /// </summary>
        public string WorkerId { get; set; }
    }
    public interface IBackgroudWorkerProxy
    {
        /// <summary>
        /// 執行
        /// </summary>
        /// <param name="method"></param>
        void Excete<T>(Action method, WorkerConfig config) where T : IBackgroundWorkerDo;
    }

 

以上便是解耦的核心代碼,在核心代碼中,仿照Abp官方的PeriodicBackgroundWorkerBase類提供了一個基於Timer的輪詢調度實現:

   public class PeriodicWorkerPxoxy : IBackgroudWorkerProxy
    {
        private Action ExetuteMethod { get; set; }
        protected readonly AbpTimer Timer;
        public PeriodicWorkerPxoxy(AbpTimer timer)
        {
            Timer = timer;
            Timer.Elapsed += Timer_Elapsed;
        }

        private void Timer_Elapsed(object sender, EventArgs e)
        {
            try
            {
                DoWork();
            }
            catch (Exception ex)
            {

            }
        }

        public void Excete<T>(Action method, WorkerConfig config) where T: IBackgroundWorkerDo
        {
            ExetuteMethod = method;
            Timer.Period = config.IntervalSecond*1000;//將傳入的秒數轉化為毫秒
            Timer.Start();
        }

        protected  void DoWork()
        {
            ExetuteMethod();
        }
    }

作為一個核心模塊,所以還需要定義一個模塊啟動配置文件

public class FastWorkWorkerPxoxyModule : AbpModule
    {
        public override void Initialize()
        {
            IocManager.RegisterAssemblyByConvention(Assembly.GetExecutingAssembly());
        }
        public override void PreInitialize()
        {
            IocManager.RegisterIfNot<IBackgroudWorkerProxy, PeriodicWorkerPxoxy>();
        }
    }

 

核心庫解決方案圖如下,(記住要引用Abp核心庫)

在需要的項目中引入該Dll,然後按照模塊啟動配置依賴進行配置

    [DependsOn(typeof(AbpZeroCoreModule), typeof(AbpZeroLdapModule), typeof(AbpAutoMapperModule), typeof(FastWorkWorkerPxoxyModule))]
    public class FastWorkCoreModule : AbpModule
    {
          ...
    }

後臺工作者類示例:

namespace ORS.FastWork.Core.Sms
{
    /// <summary>
    /// 清理簡訊日誌
    /// </summary>
    public class SmsWorker : BackgroundWorker<SmsWorker>, ISingletonDependency
    {
        private readonly IRepository<SmsSendLog, long> _smsLogRepository;
        public SmsWorker(IRepository<SmsSendLog, long> smsLogRepository,IBackgroudWorkerProxy workMiddleware) : base(workMiddleware, new WorkerConfig { IntervalSecond=60,WorkerId="smsworker"})
        {
            _smsLogRepository = smsLogRepository;
        }
        public override void DoWork()
        {
            //_smsLogRepository.Insert(new SmsSendLog { IsOk = true, Content = "輪詢任務創建的", CreationTime = DateTime.Now });
        }
    }
}

 

 

2、HangFire實現

主要的類有兩個,一個是啟動配置,一個實現了IBackgroudWorkerProxy介面,解決方案目錄如下:

解決方案記得引用上面定義好的核心庫,Hangfire實現輪詢的代碼如下:

  public class HangfireWorkerPxoxy : IBackgroudWorkerProxy
    {
        public HangfireWorkerPxoxy()
        {

        }
        private WorkerConfig Config { get; set; }
        public void Excete<T>(Action method, WorkerConfig config) where T: IBackgroundWorkerDo
        {
            Config = config;
            string workerId = config.WorkerId;
            string cron = Cron.MinuteInterval(config.IntervalSecond/60);
            RecurringJob.AddOrUpdate<T>(config.WorkerId, (t)=>t.DoWork(), cron,TimeZoneInfo.Local);
            RecurringJob.Trigger(config.WorkerId);
        }
    }

 模塊啟動文件中的代碼很關鍵,當後臺工作採用了Hangfire來調度時(即在web模塊的啟動文件中使用了 Configuration.BackgroundJobs.UseHangfire(...)),則後臺工作者類的調度也將由我們核心庫中的PeriodicWorkerPxoxy變更為Hangfire來接管

 public class HangFireWorkerModule : AbpModule
 {
        public override void Initialize()
        {
            IocManager.RegisterAssemblyByConvention(Assembly.GetExecutingAssembly());
        }
        public override void PreInitialize()
        {
            IocManager.RegisterIfNot<IBackgroudWorkerProxy, HangfireWorkerPxoxy>();
        }
        public override void PostInitialize()
        {
            //判斷是否啟用了hangfire,如果啟用了,則將IBackgroudWorkerProxy的實例改為hangfire
            var hangfireConfig = IocManager.Resolve<IAbpHangfireConfiguration>();
            if (hangfireConfig?.Server!= null) {
                IocManager.IocContainer.Register(Component.For<IBackgroudWorkerProxy>().ImplementedBy<HangfireWorkerPxoxy>().IsDefault());
            }
        }
}

 

 在Web項目中引用該項目,然後在模塊啟動中加入對該模塊的依賴

在PostInitialize方法中向後臺工作管理類加入具體的工作

最終效果如下:

 

3.進一步優化

該方案目前已在我們公司的項目中投入使用,由於時間和精力關係,我個人沒有對該方案進行進一步優化。在web模塊啟動文件中,還是需要做兩步工作:1.引用了dll 2.啟動文件上標註依賴關係,每增加一種輪詢調度方式我們都需要重覆這兩步,如果想做得更靈活的話,可以弄成插件模塊(拷入dll到站點PlugIns目錄,然後再後臺設置一下即可),下一篇文章我會以簡訊網關插件實戰來演示Abp插件模塊的妙用。


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

-Advertisement-
Play Games
更多相關文章
  • Oulipo Time Limit: 1000MS Memory Limit: 65536K Total Submissions: 40168 Accepted: 16135 Description The French author Georges Perec (1936–1982) once w ...
  • 策略模式定義了演算法族,分別封裝起來,讓它們之間可以互相替換,此模式讓演算法的變化獨立於使用演算法的客戶。 ...
  • 模板模式:定義一個操作中的演算法的骨架,而將一些步驟延遲到子類中。模板方法使得子類可以不改變一個演算法的結構即可重定義該演算法的某些特定步驟。 模板模式通過把不變的行為搬移到超類,去除子類中的重覆代碼來體現它的優勢。 通過繼承和多態來實現。 行為型模式。 spp業務框架中的server_task(CSer ...
  • 咱不要多, 就一個隱身技能, 嘿嘿嘿 定義 橋接模式(bridge): 在軟體系統中, 某些由於自身的邏輯, 它具有兩個或多個維度的變化, 那麼如何應對這種"多維度的變化"? 如何利用面向對象的技術來使得該類型能夠輕鬆的沿著多個方向進行變化, 而又不引入額外的複雜度?這就是Bridge模式. 而具體 ...
  • 任何事都是平衡的,沒有完美,得到了一些東西,自然會失去一些東西。 捨得!捨得!做人做事都是這樣。關鍵想好最想要的是什麼,接受由此失去的。 系統設計也是這樣,需要關註重點,深入思考,架構要簡單、可控、模塊化、直覺化; 當時間有限時,抓大放小,不要在過於瑣碎的地方浪費太多的時間。 此外:每種技術、方案都 ...
  • 回到目錄 SchedulingTask產生的原因 任務調試主要指定期執行某些任務代碼,之前用過quartz,感覺有些重,使用時需要添加包包,配置管理項時,對於簡單的項目用它就顯得有些臃腫了,不如直接上個簡單的東西來實現,所有才有了今天的SchedulingTask,它被大叔集成到了最新的lindAg ...
  • 簡單工廠模式的類圖如下: 簡單工廠根據具體的指令創建指定的對象,簡單工廠能創建的對象各類事先都是在代碼裡面寫好的。 工廠方法模式的類圖如下: 兩種方式做一個對比,以需求的變化,來顯示更改的內容和位置 什麼樣的需求?計算器要求添加新的運算種類 開平方 簡單工廠裡面需要加上開平方的功能類,然後去更改工廠 ...
  • 1 #include 2 #include 3 4 using namespace std; 5 6 class CPrototype 7 { 8 public: 9 CPrototype() 10 { 11 12 } 13 CPrototype(int iAge): m_iAge(iAge) 14... ...
一周排行
    -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.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...