LindAgile.SchedulingTask~設計一個不錯的任務調度組件

回到目錄

SchedulingTask產生的原因

任務調試主要指定期執行某些任務代碼，之前用過quartz，感覺有些重，使用時需要添加包包，配置管理項時，對於簡單的項目用它就顯得有些臃腫了，不如直接上個簡單的東西來實現，所有才有了今天的SchedulingTask，它被大叔集成到了最新的lindAgile框架里，也是Modules的一個子單元，在項目啟動時由ModuleManager統一完成註冊！

SchedulingTask核心的設計圖

SchedulingTask的註冊

 ModuleManager.Create()
              .UseDefaultContainer()
              .UseLogger()
              .UseMockRepository()
              .UseDefaultMq();

而對於我們每個Job任務，需要開發人員根據業務要求去編寫，它們將繼承一個叫ScheduleBase的抽象類，此類為我們提供了調度周期，任務執行器等核心的邏輯！

        /// <summary>
        /// 啟動任務
        /// </summary>
        /// <param name="name"></param>
        /// <param name="action"></param>
        /// <param name="dueTime">執行方法前的延時時間,毫秒</param>
        /// <param name="interval">執行方法的時間間隔,毫秒</param>
        public void StartTask(string name, int interval)
        {
            lock (_lockObject)
            {
                if (_taskDict.ContainsKey(name)) return;
                var timer = new Timer(TaskCallback, name, Timeout.Infinite, Timeout.Infinite);
                _taskDict.Add(name, new TimerTaskModel
                {
                    Name = name,
                    Callback = Excute,
                    Timer = timer,
                    IntervalMillisecond = interval,
                    Stopped = false
                });
                timer.Change(interval, 0);
            }
        }

而它與其它具體JOB的關係，我們可以用一張圖來表示

對於任務的啟動，我們由ScheduleFactory來完成，它會將當前運行時下所有繼承ScheduleBase的Job類都載入到容器里，通過自己的調試周期去定時執行！

        /// <summary>
        /// 開始任務q
        /// 裝置所有任務，並啟動它的StartTask()方法
        /// </summary>
        public void Run()
        {
            foreach (var item in GetAllTypes())
            {
                var obj = Activator.CreateInstance(item, true);
                MethodInfo methodinfo = item.GetMethod("StartTask");
                _iLogger.Logger_Info(string.Format("{0}這個Job開始執行", item.Name));
                methodinfo.Invoke(obj,
                    new object[]
                    {
                        item.Name,
                        _intervalMillisecond > 0
                                   ? _intervalMillisecond
                                   : item.GetProperty("IntervalMillisecond").GetValue(obj)
                    });
            }
        }

而對於使用者來說，要做的就是建立自己的業務Job和在程式入口添加對Run的使用即可

            #region TaskJob
            sf.UseLogger().Run();
            Console.ReadKey();
            #endregion

結果如圖

希望各位繼續支持微軟，支持咱們自己的.net技術！

謝謝！

回到目錄