.net任务调度平台 Dyd.BaseService.TaskManager

た入场券 2023-06-01 05:41 4阅读 0赞

国外网速慢,最新版本迁移至[http://git.oschina.net/chejiangyi/Dyd.BaseService.TaskManager][http_git.oschina.net_chejiangyi_Dyd.BaseService.TaskManager]

## .net 简单任务调度平台 ##

用于.net dll,exe的任务的挂载，任务的隔离，调度执行，访问权限控制，监控，管理，日志，错误预警，性能分析等。

1.  平台基于quartz.net进行任务调度功能开发，采用C\#代码编写, 支持corn表达式和第三方自定义的corn表达式扩展。
2.  架构以插件形式开发，具有良好的功能扩展性，稳定性，简单性，便于第三方开发人员进一步进行功能扩展。
3.  支持多节点集群，便于集群服务器的资源有效分配，任务的相互隔离。
4.  支持邮件形式的错误预警，便于运维及时处理任务异常等。

\-- 车江毅 2015-06-17

## Dyd.BaseService.TaskManager源码部署须知： ##

*  1、删除各个项目中Newtonsoft.Json.dll的引用
 *  2、检查各项目中XXF.dll的引用，确保引用了“引用”文件夹中的XXF.dll
 *  3、执行,建模脚本.txt中的sql server脚本语句
 *  4、【Dyd.BaseService.TaskManager.Web】 任务管理后台，部署此站点，修改web.config数据库的字符串连接
 *  5、修改登录代码和用户权限（看源码），不用源码内部通过crm登录
 *  6、【Dyd.BaseService.TaskManager.MonitorTasks】 监控任务，此任务需要重新生成，打包此此文件（原有的打包文件可以直接删除）
 *  7、【Dyd.BaseService.TaskManager.WinService】 进行服务安装，修改安装包的实际路径
 *  8、管理后台，可以正常访问后，请参照 “任务调度平台安装->任务调度平台部署流程(示例).xls”,来新建任务，调通任务可以正常进行，则为成功

\*(感谢俞忠亮同学整理)\*

\#\# 开源相关群: .net 开源基础服务 238543768 \#\# (大家都有本职工作，也许不能及时响应和跟踪解决问题，请谅解。)

## 任务demo示例 ##

using System;
    using System.Collections.Generic;
    using System.Diagnostics;
    using System.Linq;
    using System.Text;
    using System.Threading.Tasks;
     
    namespace Dyd.BaseService.TaskManager.Demo
    {
        /// <summary>
        /// 任务调度平台 任务插件的写法demo及说明
        /// </summary>
        public class DemoTask : XXF.BaseService.TaskManager.BaseDllTask
        {
            /// <summary>
            /// 任务调度平台根据发布的任务时间配置，定时回调运行方法
            /// 开发人员的任务插件必须要重载并该方法
            /// </summary>
            public override void Run()
            {
                /* 
                 * this.OpenOperator 用于任务调度平台提供给第三方使用的所有api接口封装
                 */
     
                /*获取当前任务dll安装目录*/
                this.OpenOperator.GetTaskInstallDirectory();
     
                /*打印一条日志到任务调度平台,因为日志会存到平台数据库，所以日志要精简，对任务出错时有分析价值【注意：不要频繁打印无用的，非必要的，对分析无价值的日志信息】*/
                this.OpenOperator.Log("这里打印一条日志到任务调度平台");
     
                /*打印一条错误到任务调度平台,因为日志会存到平台数据库，所以日志要精简，对任务出错时有分析价值【注意：不要频繁打印无用的，非必要的，对分析无价值的日志信息】
                 *后续任务会有增加优先级区分，根据任务的优先级,错误的出现频率等,错误日志会定期推送到开发者邮箱和短信*/
                this.OpenOperator.Error("这里打印一条错误日志到任务调度平台", new Exception("错误msg信息"));
     
                /*从数据库获取任务的临时数据，临时数据以jason的形式保存在数据库里面，便于任务上下文的恢复和信息传递【注意：不应用于"频繁的"存储"大量的"临时数据，会操作网络耗时和数据库性能差】*/
                var databasetempinfo = this.OpenOperator.GetDataBaseTempData<DemoTaskDatabaseTempInfo>();
                if (databasetempinfo == null)//若任务第一次运行，可能没有临时数据。当然也可以在发布任务的时候配置临时数据也可。
                {
                    databasetempinfo = new DemoTaskDatabaseTempInfo();
                    databasetempinfo.LastLogID = 0;
                }
     
                /*将任务的临时数据持久化到数据库中，临时数据以json的形式保存在数据库里面，便于任务上下文的恢复和信息传递【注意：不应用于"频繁的"存储"大量的"临时数据，会操作网络耗时和数据库性能差】
                  若临时数据用于下一次使用，必须要执行此方法，否则下次无法获取【注意:执行此方法,当前临时数据有可能被重置为null，便于内存资源释放】*/
                this.OpenOperator.SaveDataBaseTempData(databasetempinfo);
     
                /*从本地安装目录中获取任务的临时数据，临时数据以jason的形式保存在本地，便于任务上下文的恢复和信息传递【注意：本地临时数据一般用于保存"大量的"临时数据】*/
                var localtempinfo = this.OpenOperator.GetLocalTempData<DemoTaskLocalTempInfo>();
                if (localtempinfo == null)//若任务第一次运行，可能没有临时数据。当然也可以在发布任务的时候上传临时数据json至安装压缩包中也可。
                {
                    localtempinfo = new DemoTaskLocalTempInfo();
                    localtempinfo.file = new byte[0];
                }
     
                /*将任务的临时数据持久化到本地安装目录中，临时数据以json的形式保存在本地安装目录里面，便于任务上下文的恢复和信息传递【注意：本地临时数据一般用于保存"大量的"临时数据】
                  若临时数据用于下一次使用，必须要执行此方法，否则下次可能无法获取【注意:执行此方法,当前临时数据有可能被重置为null，便于内存资源释放】*/
                this.OpenOperator.SaveLocalTempData(localtempinfo);
     
                {
                    string msg = "执行业务中...."+ this.AppConfig["sendmailhost"];
                    Debug.WriteLine(msg);
                    System.IO.File.AppendAllText(this.OpenOperator.GetTaskInstallDirectory()+"业务.txt", msg);
                }
            }
            /// <summary>
            /// 开发人员自测运行入口
            /// 需要将项目配置为->控制台应用程序，写好Program类和Main入口函数
            /// </summary>
            public override void TestRun()
            {
                /*测试环境下任务的配置信息需要手工填写,正式环境下需要配置在任务配置中心里面*/
                this.AppConfig = new XXF.BaseService.TaskManager.SystemRuntime.TaskAppConfigInfo();
                this.AppConfig.Add("sendmailhost", "smtp.163.com");
                this.AppConfig.Add("sendmailname", "fengyeguigui@163.com");
                this.AppConfig.Add("password", "******");
     
                base.TestRun();
            }
        }
     
        /// <summary>
        /// 任务调度平台之临时数据信息,用于任务上下文的信息传递。
        /// 将会以json形式保存在任务调度平台数据库中,便于下一次回调运行时恢复并使用。【注意：不应用于"频繁的"存储"大量的"临时数据，会操作网络耗时和数据库性能差】
        /// </summary>
        public class DemoTaskDatabaseTempInfo
        {
            public int LastLogID { get; set; }
        }
     
        /// <summary>
        /// 任务调度平台之临时数据信息,用于任务上下文的信息传递。
        /// 将会以json形式保存在任务调度平台本地安装文件夹中,便于下一次回调运行时恢复并使用。【注意：本地临时数据一般用于保存"大量的"临时数据】
        /// </summary>
        public class DemoTaskLocalTempInfo
        {
            public byte[] file { get; set; }
        }
    }

## web后端部分截图及安装 ##

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f344b76415f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f344b76415f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f64695a4d5f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f64695a4d5f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f4d6459565f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f4d6459565f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f723749525f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f723749525f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f344876645f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f344876645f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f575630335f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f575630335f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f396d34435f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f396d34435f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f776d69465f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f776d69465f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f7a4176565f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f7a4176565f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7a4972575f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7a4972575f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7653704d5f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7653704d5f323337393834322e706e67]

[![687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f456342455f323337393834322e706e67][]][687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f456342455f323337393834322e706e67]

## 未来构想： ##

*  1.  任务故障转移: 检测到任务持续故障n次或者故障频率，判定进行异地节点/节点集群内的任务启动，可支持n次故障恢复。
 *  2）任务负载均衡: 多个任务并行执行，用于高资源负载任务的多节点运行。
 *  3）任务拆分: 一个父级任务可以创建多个子任务，并对任务进行管理，调度，故障恢复，预警等。

转载于:https://www.cnblogs.com/Jeely/p/11358861.html

[http_git.oschina.net_chejiangyi_Dyd.BaseService.TaskManager]: http://git.oschina.net/chejiangyi/Dyd.BaseService.TaskManager
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f344b76415f323337393834322e706e67]: /images/20230601/313e1d324cc44d04bb445065ff2584eb.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f64695a4d5f323337393834322e706e67]: /images/20230601/85fbe55817244e939121a701d2e16bba.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f4d6459565f323337393834322e706e67]: /images/20230601/265a5eebf4e24344a7ac680ceefe98f1.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531375f723749525f323337393834322e706e67]: /images/20230601/68217feb43604a0da30636e911e0715c.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f344876645f323337393834322e706e67]: /images/20230601/e9efb074cea24ba3aa043ff7ee38af42.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f575630335f323337393834322e706e67]: /images/20230601/f8a289fc613b4fd3af41292cebe991f7.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f396d34435f323337393834322e706e67]: /images/20230601/bdd6d13135c34d08927e2dd5a03a84ed.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f776d69465f323337393834322e706e67]: /images/20230601/d365ee303b6e4eac8dedb689721bc17d.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531385f7a4176565f323337393834322e706e67]: /images/20230601/6ebe7097c45644cfba9c6efdbd501a58.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7a4972575f323337393834322e706e67]: /images/20230601/a61cfea1639c4987a8b4ba11fdd87b19.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f7653704d5f323337393834322e706e67]: /images/20230601/7abce5f08dd640b184d2eb562f2040d8.png
[687474703a2f2f7374617469632e6f736368696e612e6e65742f75706c6f6164732f73706163652f323031352f303932352f3039333531395f456342455f323337393834322e706e67]: /images/20230601/04f6690519284b78b0c2427acdf8c30e.png