基於Quartz.net的遠程任務管理系統 一

来源:https://www.cnblogs.com/COOLK/archive/2018/11/04/9905006.html
-Advertisement-
Play Games

在上一篇緒中，已經介紹了整個項目的情況下了，接下來就是開始一步步做起來了。 首先：先整個我們的Job任務表，以及Job執行日誌表。SQL如下: 1 drop table if exists job_info; 2 create table job_info 3 ( 4 id int not null ...


在上一篇緒中，已經介紹了整個項目的情況下了，接下來就是開始一步步做起來了。

首先：先整個我們的Job任務表，以及Job執行日誌表。SQL如下:

 1 drop table if exists job_info;
 2 create table job_info
 3 (
 4     id int not null AUTO_INCREMENT comment '主鍵',
 5     job_name varchar(150) null default null comment '任務名稱',
 6     job_assembly varchar(200) null default null comment '執行的方式的dll名稱',
 7     job_class varchar(300) null default null comment '執行的方法類',
 8     job_corn varchar(100) null default null comment '執行任務的corn表達式',
 9     job_type int not null default 1 comment '任務類型，預設為1 簡單，2 複雜',
10     job_execount int null default 0 comment '任務的執行總次數,0表示無限次',
11     job_starttime datetime null default null comment '任務開始時間',
12     job_state int null default 0 comment '任務的狀態 0 準備中，1 執行中,2 暫定，3 停止，4 結束',
13     addtime TIMESTAMP null default CURRENT_TIMESTAMP comment '任務的創建時間',
14     PRIMARY KEY (`id`)
15 );
16 drop table if exists job_log;
17 create table job_log
18 (
19     id int not null AUTO_INCREMENT comment '主鍵',
20     job_name varchar(150) null default null comment '任務名稱',
21     job_result varchar(200) null default null comment '執行的結果',
22     job_exception text null default null comment '執行任務的異常信息',
23     job_exetime int not null default 0 comment '執行耗時，單位ms',
24     job_exedate datetime null default 0 comment '任務的執行的日期時間',
25     job_exestate int null default 0 comment '執行結果 0 正常，1 異常',
26     addtime TIMESTAMP null default CURRENT_TIMESTAMP comment '任務的執行時間',
27     PRIMARY KEY (`id`)
28 );
View Code

相關實體類與操作方法，如下：

 1 /// <summary>
 2     /// Job信息表
 3     /// </summary>
 4     public class Job_Info : BaseEntity
 5     {
 6         private int _id = 0;
 7         private string _job_name;
 8         private string _job_assembly;
 9         private string _job_class;
10         private string _job_corn;
11         private int _job_type = 1;
12         private int _job_execount = 0;
13         private DateTime _job_starttime;
14         private int _job_state = 0;
15         private DateTime _addtime;
16 
17         /// <summary>
18         /// 主鍵
19         /// </summary>
20         public int Id { get => _id; set => _id = value; }
21         /// <summary>
22         /// 任務名稱
23         /// </summary>
24         public string Job_name { get => _job_name; set => _job_name = value; }
25         /// <summary>
26         /// 執行的方式的dll名稱
27         /// </summary>
28         public string Job_assembly { get => _job_assembly; set => _job_assembly = value; }
29         /// <summary>
30         /// 執行的方法類
31         /// </summary>
32         public string Job_class { get => _job_class; set => _job_class = value; }
33         /// <summary>
34         /// 執行任務的corn表達式
35         /// </summary>
36         public string Job_corn { get => _job_corn; set => _job_corn = value; }
37         /// <summary>
38         /// 任務類型，預設為1 簡單，2 複雜
39         /// </summary>
40         public int Job_type { get => _job_type; set => _job_type = value; }
41         /// <summary>
42         /// 任務的執行總次數,0表示無限次
43         /// </summary>
44         public int Job_execount { get => _job_execount; set => _job_execount = value; }
45         /// <summary>
46         /// 任務開始時間
47         /// </summary>
48         public DateTime Job_starttime { get => _job_starttime; set => _job_starttime = value; }
49         /// <summary>
50         /// 任務的狀態 0 準備中，1 執行中,2 暫定，3 停止，4 結束
51         /// </summary>
52         public int Job_state { get => _job_state; set => _job_state = value; }
53         /// <summary>
54         /// 任務的創建時間
55         /// </summary>
56         public DateTime Addtime { get => _addtime; set => _addtime = value; }
57         
58     }
View Code 
/// <summary>
    /// Job運行日誌表
    /// </summary>
    public class Job_Log : BaseEntity
    {
        private int _id = 0;
        private string _job_name;
        private string _job_result;
        private string _job_exception;
        private int _job_exetime;
        private DateTime _job_exedate;
        private int _job_exestate;
        private DateTime _addtime;

        /// <summary>
        /// 主鍵
        /// </summary>
        public int Id { get => _id; set => _id = value; }
        /// <summary>
        /// 任務名稱
        /// </summary>
        public string Job_name { get => _job_name; set => _job_name = value; }
        /// <summary>
        /// 執行的結果
        /// </summary>
        public string Job_result { get => _job_result; set => _job_result = value; }
        /// <summary>
        /// 執行任務的異常信息
        /// </summary>
        public string Job_exception { get => _job_exception; set => _job_exception = value; }
        /// <summary>
        /// 執行耗時，單位ms
        /// </summary>
        public int Job_exetime { get => _job_exetime; set => _job_exetime = value; }
        /// <summary>
        /// 任務的執行的日期時間
        /// </summary>
        public DateTime Job_exedate { get => _job_exedate; set => _job_exedate = value; }
        /// <summary>
        /// 執行結果 0 正常，1 異常
        /// </summary>
        public int Job_exestate { get => _job_exestate; set => _job_exestate = value; }
        /// <summary>
        /// 任務的執行時間
        /// </summary>
        public DateTime Addtime { get => _addtime; set => _addtime = value; }
    }
View Code 
  1  /// <summary>
  2     /// Job信息邏輯類
  3     /// </summary>
  4     public class JobInfoBLL
  5     {
  6         /// <summary>
  7         /// 添加Job信息
  8         /// </summary>
  9         /// <param name="jobInfo"></param>
 10         /// <returns></returns>
 11         public int AddInfo(Job_Info jobInfo)
 12         {
 13             int result = 0;
 14 
 15             if (jobInfo == null)
 16                 return result;
 17             try
 18             {
 19                 string SqlStr = string.Format("insert into job_info(job_name,job_assembly,job_class,job_corn,job_type,job_execount,job_starttime,job_state) values('{0}','{1}','{7}','{2}',{3},{4},'{5}',{6})",
 20                     jobInfo.Job_name, jobInfo.Job_assembly, jobInfo.Job_corn, jobInfo.Job_type, jobInfo.Job_execount, jobInfo.Job_starttime.ToString("yyyy-MM-dd HH:mm:ss"), 0, jobInfo.Job_class);
 21                 result = MySqlHelper.ExceuteSql(SqlStr);
 22             }
 23             finally
 24             {
 25 
 26             }
 27 
 28             return result;
 29         }
 30 
 31         /// <summary>
 32         /// 更新Job的狀態
 33         /// </summary>
 34         /// <param name="jobInfo"></param>
 35         /// <returns></returns>
 36         public int UpdateJobState(Job_Info jobInfo)
 37         {
 38             int result = 0;
 39 
 40             if (jobInfo == null)
 41                 return result;
 42             try
 43             {
 44                 string SqlStr = string.Format("update job_info set job_state={0} where ", jobInfo.Job_state);
 45                 if(jobInfo.Id > 0)
 46                 {
 47                     SqlStr += string.Format(" id={0};", jobInfo.Id);
 48                 }else if (!string.IsNullOrEmpty(jobInfo.Job_name))
 49                 {
 50                     SqlStr += string.Format(" job_name='{0}'", jobInfo.Job_name);
 51                 }
 52                 result = MySqlHelper.ExceuteSql(SqlStr);
 53             }
 54             finally
 55             {
 56 
 57             }
 58 
 59             return result;
 60         }
 61 
 62         /// <summary>
 63         /// job列表
 64         /// </summary>
 65         /// <returns></returns>
 66         public List<Job_Info> GetJobList()
 67         {
 68             List<Job_Info> list = null;
 69 
 70             try
 71             {
 72                 string SqlStr = "select * from job_info";
 73                 var ds = MySqlHelper.GetDataSet(SqlStr);
 74                 if(ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
 75                 {
 76                     list = new List<Job_Info>();
 77                     Job_Info info = new Job_Info();
 78                     foreach (System.Data.DataRow row in ds.Tables[0].Rows)
 79                     {
 80                         info = Job_Info.ToEntity<Job_Info>(row, info);
 81                         if (info != null)
 82                             list.Add(info);
 83                     }
 84                 }
 85             }
 86             finally
 87             {
 88 
 89             }
 90 
 91             return list;
 92         }
 93 
 94         /// <summary>
 95         /// job列表
 96         /// </summary>
 97         /// <returns></returns>
 98         public List<Job_Info> GetJobList(int pageIndex,int pageSize)
 99         {
100             List<Job_Info> list = null;
101 
102             try
103             {
104                 string SqlStr = "select * from job_info";
105                 SqlStr += string.Format(" limit {0},{1};", (pageIndex - 1) * pageSize, pageSize);
106                 var ds = MySqlHelper.GetDataSet(SqlStr);
107                 if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
108                 {
109                     list = new List<Job_Info>();
110                     Job_Info info = new Job_Info();
111                     foreach (System.Data.DataRow row in ds.Tables[0].Rows)
112                     {
113                         info = Job_Info.ToEntity<Job_Info>(row, info);
114                         if (info != null)
115                             list.Add(info);
116                     }
117                 }
118             }
119             finally
120             {
121 
122             }
123 
124             return list;
125         }
126 
127         public Job_Info GetOne(int id)
128         {
129             Job_Info job = null;
130 
131             try
132             {
133                 string SqlStr = "select * from job_info where id="+id;
134                 var ds = MySqlHelper.GetDataSet(SqlStr);
135                 if (ds != null && ds.Tables.Count > 0 && ds.Tables[0].Rows.Count > 0)
136                 {
137                     job = new Job_Info();
138                     foreach (System.Data.DataRow row in ds.Tables[0].Rows)
139                     {
140                         job = Job_Info.ToEntity<Job_Info>(row, job);
141                     }
142                 }
143             }
144             catch (Exception ex)
145             {
146 
147             }
148 
149             return job;
150         }
151 
152         /// <summary>
153         /// job數量
154         /// </summary>
155         /// <returns></returns>
156         public int GetJobCount()
157         {
158            int list = 0;
159 
160             try
161             {
162                 string SqlStr = "select count(0) from job_log";
163                 var ds = MySqlHelper.GetReader(SqlStr);
164                 if (ds != null)
165                 {
166                     int.TryParse(ds.ToString(), out list);
167                 }
168             }
169             finally
170             {
171 
172             }
173 
174             return list;
175         }
176 
177     }
View Code 
/// <summary>
    /// Job 日誌邏輯類
    /// </summary>
    public class JobLogBLL
    {

        /// <summary>
        /// 添加Job日誌信息
        /// </summary>
        /// <param name="jobLog"></param>
        /// <returns></returns>
        public int AddLog(Job_Log jobLog)
        {
            int result = 0;

            if (jobLog == null)
                return result;
            try
            {
                string SqlStr = string.Format("insert into job_log(job_name,job_result,job_exception,job_exetime,job_exedate,job_exestate) values('{0}','{1}','{2}',{3},'{4}',{5})",
                    jobLog.Job_name, jobLog.Job_result, jobLog.Job_exception, jobLog.Job_exetime, jobLog.Job_exedate.ToString("yyyy-MM-dd HH:mm:ss"), jobLog.Job_exestate);
                result = MySqlHelper.ExceuteSql(SqlStr);
            }
            finally
            {

            }

            return result;
        }
        
        /// <summary>
        /// job日誌列表
        /// </summary>
        /// <returns></returns>
        public List<Job_Log> GetJobLogList()
        {
            List<Job_Log> list = null;

            try
            {
                string SqlStr = "select * from job_log";
                var ds = MySqlHelper.GetDataSet(SqlStr);
                if (ds != null && ds.Tables[0].Rows.Count > 0)
                {
                    list = new List<Job_Log>();
                    Job_Log info = new Job_Log();
                    foreach (System.Data.DataRow row in ds.Tables[0].Rows)
                    {
                        info = Job_Log.ToEntity<Job_Log>(row, info);
                        if (info != null)
                            list.Add(info);
                    }
                }
            }
            finally
            {

            }

            return list;
        }

        /// <summary>
        /// job日誌列表
        /// </summary>
        /// <returns></returns>
        public List<Job_Log> GetJobLogList(int pageIndex, int pageSize)
        {
            List<Job_Log> list = null;

            try
            {
                string SqlStr = "select * from job_log";
                SqlStr += string.Format(" limit {0},{1};", (pageIndex - 1) * pageSize, pageSize);
                var ds = MySqlHelper.GetDataSet(SqlStr);
                if (ds != null && ds.Tables[0].Rows.Count > 0)
                {
                    list = new List<Job_Log>();
                    Job_Log info = new Job_Log();
                    foreach (System.Data.DataRow row in ds.Tables[0].Rows)
                    {
                        info = Job_Log.ToEntity<Job_Log>(row, info);
                        if (info != null)
                            list.Add(info);
                    }
                }
            }
            finally
            {

            }

            return list;
        }

        public int GetJobLogCount(int state = -1)
        {
            int count = 0;

            try
            {
                string SqlStr = "select count(0) from job_log";
                if (state > -1)
                {
                    SqlStr += " where job_exestate=" + state;
                }
                var ds = MySqlHelper.GetReader(SqlStr);
                if (ds != null)
                {
                    int.TryParse(ds.ToString(), out count);
                }
            }
            finally
            {

            }

            return count;
        }

    }
View Code

這些都是資料庫的基本操作，我就直接貼出來了。為了規範，我們就定了一個介面，供所有Job任務來實際業務，介面很簡單，具體如下：

 /// <summary>
    /// 基Job
    /// </summary>
    public interface IJob
    {        
        /// <summary>
        /// 執行任務
        /// </summary>
        bool Exceute();
    }
View Code

好了，下麵我們就開始我們的Job托管器-Window Server。為了方便，我就使用Topshelf，因為創建JobManage.Service這個項目時，一定要選擇Console項目(我一開始就直接使用了Service項目，然後一直運行不起來)。

那現在來創建一個JobServer類，實現ServiceControl, ServiceSuspend 兩大介面的方法，在服務啟動的時候，實例化Schedule，然後加入檢查Job的Job任務，定期增加或刪除Schedule里的Job。

實現如下： 

public bool Start(HostControl hostControl)
        {
            if (JobConfig.factory == null)
            {
                JobConfig.factory = new StdSchedulerFactory();
                JobConfig.scheduler = JobConfig.factory.GetScheduler();
                JobConfig.scheduler.Start();

                //創建迴圈Job
                IJobDetail job = JobBuilder.Create<LoopJob>().WithIdentity("LoopJob", "group1").Build();
                ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("LoopJobtrigger
您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Cannot load php5apache2_4.dll into server
    配置PHP開發環境的時候，當進行到在Apache的httpd.conf文件中配置載入PHP模塊時發生如下錯誤 httpd: Syntax error on line 185 of D:/wamp/Apache24/conf/httpd.conf: Cannot load D:/wamp/php 5. ...
  • Beginning Python Games Development(2nd)
    Like music and movies, video games are rapidly becoming an integral part of our lives. Over the years, youve yearned for every new gaming console, mas ...
  • PHP合併數組
    1.arrary_merge 示例代碼： 運行上面的代碼，輸出結果如下圖所示: 普通數組合併時，會把第二個數組放到第一個數組後面，拼接後返回。 但是對於鍵值對的數組來說，如果有相同的鍵，那麼第二個數組會覆蓋第一個數組相同的鍵所對應的值。 2.通過 合併 示例代碼: 運行上面的代碼，輸出結果如下圖所示 ...
  • C#Datetimepicker出現問題及解決方法
    datetimepicker造成的問題，年、月和日參數描述無法表示的 DateTime ...
  • C#設計模式原則
    原則的誕生：面向對象：封裝、繼承、多態三大支柱蘊含了用抽象來封裝變化，降低耦合，實現復用的精髓； 封裝：隱藏內部的實現，保護內部信息； 繼承：實現復用，歸納共性； 多態：改寫對象行為，實現更高級別的繼承 要實現這些目的，就必須遵守一些原則：封裝變化、對介面編程、少繼承多聚合 實現系統的可擴展、可復用 ...
  • asp.net後臺管理系統-登陸模塊-是否自動登陸
    FormsAuthentication.SetAuthCookie(UserFlag, createPersistentCookie); createPersistentCookie是否永久保存cookie https://www.cnblogs.com/joeylee/p/3521131.html ...
  • 《CLR Via C#》讀書筆記：26.線程基礎
    一、線程開銷 操作系統創建線程是有代價的，其主要開銷在下麵列舉出來了。 記憶體開銷 1. 線程內核對象 擁有線程描述屬性與線程上下文，線程上下文占用的記憶體空間為 x86 架構 占用 700 位元組、x64 架構 1240 位元組 、ARM 架構 350 位元組。 2. 線程環境塊(TEB) TEB 消耗一個 ...
  • 《CLR Via C#》讀書筆記：24.運行時序列化
    一、什麼是運行時序列化 序列化的作用就是將對象圖(特定時間點的對象連接圖)轉換為位元組流，這樣這些對象圖就可以在文件系統/網路進行傳輸。 二、序列化/反序列化快速入門 一般來說我們通過 FCL 提供的 對象就可以將一個對象序列化為位元組流進行存儲，或者通過該 Formatter 將一個位元組流反序列化為一 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 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 ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類