开源一个跨平台运行的服务插件 - TaskCore.MainForm

 1 namespace TaskCore.Test
 2 {
 3     // This project can output the Class library as a NuGet Package.
 4     // To enable this option, right-click on the project and select the Properties menu item. In the Build tab select "Produce outputs on build".
 5     public class BlogsObj : TPlugin
 6     {
 7         public BlogsObj()
 8         {
 9 
10         }
11 
12         public override void TPlugin_Load()
13         {
14             var sbLog = new StringBuilder(string.Empty);
15             try
16             {
17                 sbLog.Append($"这里是BlogsObj，获取配置文件：{this.XmlConfig.Name}");
18 
19                 //代码块
20                 //
21 
22                 new WriteLog()._WriteLog($"{DateTime.Now}测试引用nuget包");
23 
24             }
25             catch (Exception ex)
26             {
27                 sbLog.Append($"异常信息：{ex.Message}");
28             }
29             finally
30             {
31 
32                 PublicClass._WriteLog(sbLog.ToString(), this.XmlConfig.Name);
33             }
34         }
35     }
36 }

 1 <!--
 2   1.xml配置模板
 3   2.utf-8文件
 4   3.复制到程序根目录下面PluginXml文件夹下
 5   4.每个任务建议创建和程序dll名称相同xml配置文件
 6 -->
 7 <TaskMain>
 8   <!--固定：执行任务时间计时器（分钟）-->
 9   <Timer>1</Timer>
10   <!--固定：任务名称-->
11   <Name>获取博客信息</Name>
12   <!--固定：账号-->
13   <UserName></UserName>
14   <!--固定：密码-->
15   <UserPwd></UserPwd>
16   <!--固定：key-->
17   <ApiKey></ApiKey>
18   <!--固定：key-->
19   <ApiUrl></ApiUrl>
20   <!--固定：是否关闭任务 1:是 0：否-->
21   <CloseTask>0</CloseTask>
22   
23 <!--固定：描述-->
24   <Des>获取博客信息</Des>
25   <!--自定义：其他配置信息-->
26   <Other>
27     <ShenNiuBuXing3>神牛步行3</ShenNiuBuXing3>
28   </Other>
29 </TaskMain>

1 <!--
2   CrossFiles指定对应任务的dll文件，必须存在的文件
3 -->
4 <TaskMain>
5   <File>TaskCore.Test.dll</File>
6 </TaskMain>

 1 {
 2   "version": "1.0.0-*",
 3   "buildOptions": {
 4     "emitEntryPoint": true
 5   },
 6 
 7   "dependencies": {
 8     "Microsoft.NETCore.App": {
 9       //"type": "platform",    跨平台发布需要注释
10       "version": "1.0.0"
11     },
12     "System.IO.FileSystem": "4.0.1",
13     "System.Reflection": "4.1.0",
14     "System.Text.Encoding.CodePages": "4.0.1",
15     "System.Threading.Timer": "4.0.1",
16     "System.Xml.XDocument": "4.0.11",
17     "TaskCore.Plugin": "1.0.0"
18   },
19 
20   "frameworks": {
21     "netcoreapp1.0": {
22       "imports": "dnxcore50"
23     }
24   },
25   //跨平台发布需要添加如下节点
26   "runtimes": {
27     "ubuntu.16.04-x64": { }, //运行在ubuntu.16.04的64位系统
28     "win7-x64": { }    //运行在win7的64位系统
29   }
30 }

  1 namespace TaskCore.MainForm
  2 {
  3     /// <summary>
  4     /// author 神牛步行3
  5     /// contact 841202396@qq.com
  6     /// des TaskCore.MainForm跨平台插件由神牛步行3提供
  7     /// </summary>
  8     public class Program
  9     {
 10 
 11         private static Dictionary<string, MoAssembly> dicTasks = new Dictionary<string, MoAssembly>();
 12 
 13         public static void Main(string[] args)
 14         {
 15             //注册编码，防止乱码
 16             Encoding.RegisterProvider(CodePagesEncodingProvider.Instance);
 17 
 18             //初始化程序集文件
 19             _Init();
 20 
 21             //是否继续开启任务，默认没有待执行任务，不提示
 22             if (dicTasks.Count <= 0) { _LoopAlert("是否退出？(Y/N)"); return; }
 23             _LoopAlert("是否开始执行任务？(Y / N)");
 24 
 25             //执行任务
 26             foreach (var item in dicTasks.Values)
 27             {
 28                 //使用Task防止异常后相互影响
 29                 Task.Run(() =>
 30                 {
 31                     try
 32                     {
 33 
 34                         //创建任务对象
 35                         var tp = item.Asm.CreateInstance(item.FullName) as TPlugin;
 36                         if (!string.IsNullOrEmpty(tp.XmlConfig.TpError)) { _Alert($"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{tp.XmlConfig.Name} - 异常信息：{tp.XmlConfig.TpError}"); }
 37                         else
 38                         {
 39 
 40                             //timer定时器
 41                             var timer = new Timer((param) =>
 42                             {
 43                                 var msg = $"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{tp.XmlConfig.Name}";
 44                                 try
 45                                 {
 46                                     var tpObj = param as TPlugin;
 47                                     //是否关闭暂停任务
 48                                     if (tpObj.XmlConfig.CloseTask) { return; }
 49                                     _Alert($"{msg} - 开始执行...{tp.XmlConfig.Timer}分钟一次");
 50                                     //任务入口
 51                                     tpObj.TPlugin_Load();
 52                                 }
 53                                 catch (Exception ex) { _Alert($"{msg} - 异常信息：{ex.Message}"); }
 54                             }, tp, 0, 1000 * 60 * tp.XmlConfig.Timer);
 55                         }
 56 
 57                     }
 58                     catch (Exception ex)
 59                     {
 60                         _Alert($"{DateTime.Now.ToString("yyyy/MM/dd HH:mm")}：{item.Name} - 异常信息：{ex.Message}");
 61                     }
 62                 });
 63             }
 64             _LoopAlert("正在监控执行的任务，是否退出？(Y / N)");
 65         }
 66 
 67         /// <summary>
 68         /// 初始化程序集文件
 69         /// </summary>
 70         private static void _Init()
 71         {
 72             try
 73             {
 74 
 75                 _Alert("初始化任务中...");
 76                 //获取文件
 77                 var files = PublicClass._GetPluginFile("");
 78                 if (files.Length <= 0) { _Alert("未能找到可用的程序集,请检查配置"); return; }
 79 
 80                 //读取任务文件
 81                 _Alert("读取CrossFiles.xml配置中...");
 82                 var baseAddr = Path.Combine(Directory.GetCurrentDirectory(), "PluginXml", "CrossFiles.xml");
 83                 var doc = XDocument.Load(baseAddr);
 84                 var fileables = files.AsEnumerable();
 85                 var taskFiles = new List<FileInfo>();
 86                 foreach (var item in doc.Root.Nodes())
 87                 {
 88                     var crossFile = item.ToString().ToUpper();
 89                     var choiceFiles = fileables.Where(b => crossFile.Contains(b.Name.ToUpper()));
 90                     if (!choiceFiles.Any()) { continue; }
 91 
 92                     taskFiles.AddRange(choiceFiles);
 93                 }
 94 
 95                 //展示文件信息
 96                 _Alert($"待遍历{taskFiles.Count}个文件信息...");
 97                 foreach (var item in taskFiles.OrderBy(b => b.CreationTime))
 98                 {
 99                     var asmName = new AssemblyName($"{item.Name.Replace(".dll", "")}");
100                     Assembly sm = Assembly.Load(asmName);
101                     if (sm == null) { continue; }
102                     var ts = sm.GetTypes();
103                     //判断特定的任务类，加入任务dic
104                     foreach (var t in ts.Where(b => b.Name != "TPlugin" && b.GetMethod("TPlugin_Load") != null))
105                     {
106 
107                         dicTasks.Add(
108                             t.FullName,
109                             new MoAssembly
110                             {
111                                 Asm = sm,
112                                 FullName = t.FullName,
113                                 Name = t.Name
114                             });
115                     }
116                 }
117                 _Alert($"获取待执行任务量：{dicTasks.Count}个");
118             }
119             catch (Exception ex)
120             {
121                 _Alert($"异常信息：{ ex.Message}");
122             }
123         }
124 
125         /// <summary>
126         /// 消息提醒
127         /// </summary>
128         /// <param name="msg">提示信息</param>
129         /// <param name="isReadLine">是否需要用户输入指令</param>
130         /// <returns>用户录入的指令</returns>
131         private static string _Alert(string msg = "神牛步行3-消息提醒", bool isReadLine = false)
132         {
133             Console.WriteLine(msg);
134             if (isReadLine) { return Console.ReadLine(); }
135             return "";
136         }
137 
138         private static void _LoopAlert(string msg = "是否开始执行任务？(Y/N)")
139         {
140             do
141             {
142                 var readKey = _Alert(msg, true);
143                 if (readKey.ToUpper().Contains("Y")) { break; }
144             } while (true);
145         }
146     }
147 
148     public class MoAssembly
149     {
150         public Assembly Asm { get; set; }
151         public string FullName { get; set; }
152 
153         public string Name { get; set; }
154     }
155 }