开源跨平台运行服务插件TaskCore.MainForm
本次将要很大家分享的是一个跨平台运行的服务插件 - taskcore.mainform，此框架是使用.netcore来写的，现在netcore已经支持很多系统平台运行了，所以将以前的task.mainform改良成跨平台的服务共大家使用和相互交流；本来这篇应该分享的是nginx+iis+redis+task.mainform构建分布式架构后续文章，但使用.netcore来定义一个服务插件和跨平台测试经过让我既兴奋又头痛，不说了下次再分享分布式后续文章吧；那么开始今天的分享内容，希望各位多多支持：
. 框架结构介绍及运行效果图
. 如何生成nuget包和使用开源框架taskcore.mainform
. win7和ubuntu16.04运行taskcore.mainform的两种方式和测试截图（也可认为.netcore项目在win7和ubuntu系统运行的两种方式）
. 框架代码解读及感悟
下面一步一个脚印的来分享：
. 框架结构介绍及运行效果图
首先，咋们先来认识下项目源码的工程目录结构如图：
结构看上去应该够清晰了，源码文件量也很少，不过的确实现了动态加载程序集dll来执行任务，后面会给出相应的执行截图，我们再来看下taskcore.mainform项目通过vs2015生成之后bin文件夹中的文件如图：
如果安装了.netcore sdk的话在windows上您只需要上面截图的文件就能运行插件了；再来我们在已经安装过core sdk的win7系统上执行一下如下命令dotnet taskcore.mainform.dll就能看到如图的效果:
没错这就是插件运行起来的效果图，因为.netcore现目前暂时没有提供类似于winform那样的皮肤界面效果，所有只能通过命令行来做跨平台运行程序
. 如何生成nuget包和使用taskcore.mainform
首先，我们要明确服务是由两部分构成（taskcore.mainform和taskcore.plugin）；taskcore.mainform主要用来运行程序，taskcore.plugin用来作为子任务需要继承的父类插件；当我们下载taskcore.mainform运行包之后（如图2结构），我们还需要做的就是继承taskcore.plugin.dl中的tplugin这个类，来重写自己的任务内容，因此我们新建一个项目取名为：taskcore.test，再来我们通过vs2015引用功能直接添加taskcore.mainform运行包中的taskcore.plugin.dl引用，这个时候会提示一个错误：
错误意思是没法加载netcore版本的dll，因此这种直接在vs项目中引用方式添加dll依赖不行，需要通过nuget来添加依赖包（.netcore对类库的引用目前只能通过nuget来安装依赖，这个需要注意），所以我这里把taskcore.plugin项目通过dotnet pack命令来生成nuget包，然后以便我taskcore.test项目中来使用；
如何生成nuget包(win7系统dotnet命令来生成包的过程和下载)：
直接在vs中右键您需要打包的类库项目-》选择"在资源管理器中打开文件夹"-》这样就到了您类库的根目录，然后退到类库根目录的上一级文件夹中-》按住键盘”shift"键并同时鼠标右键要打包类库的项目文件件（我这里是taskcore.plugin文件夹）-》选择“在此处打开命令窗体” 这个时候就进入了cmd命令窗体，当然有些朋友直接喜欢直接先cmd再来找对应的磁盘，反正我觉得第一种更快点（不同人不同选择吧），下面看下操作截图:
由上图可以看到，通过命令生成了nupkg文件，这文件就是咋们需要在项目中下载安装的taskcore.plugin插件包；接下来我们来在taskcore.test项目中安装这个插件如下步奏，右键taskcore.plugin项目中的“引用”-》选择“管理nuget程序包”-》然后选择右上角的这个图标
-》选择“nuget包管理器”-》“程序包源”-》
-》然后选择新创建的包源，下面设置如图
这里的“源(s)”指定的本地路径就是刚才我们生成的nupkg文件文件的磁盘（当然我这里是吧刚才pack命令生成的文件复制到了mynugpackage文件夹中方便测试）-》然后点击”确定“按钮-》然后在返回到
选择我们的包源mynugpackage-》再浏览这里就能看到我们创建的nuget包了
-》选择并安装-》好安装好后我们可以查看“引用”下面有了如下变化
并且project.json文件中自动添加了依赖项：
好了到我们的taskcore.test项目中就可以使用task.plugin包里面的方法很类等信息了；
使用taskcore.mainform：
由上面的操作taskcore.test项目已经安装了task.plugin包，那么我们在项目中分别创建3个子类并继承自task.plugin包的父类tplugin并重写方法tplugin_load()，对应文件名称分别为：blogsobj.cs，blogsobj01.cs，blogsobj02.cs，分别添加入下代码内容：
blogsobj.cs：
namespace taskcore.test
{
// this project can output the class library as a nuget package.
// to enable this option, right-click on the project and select the properties menu item. in the build tab select "produce outputs on build".
public class blogsobj : tplugin
{
public blogsobj()
{
}
public override void tplugin_load()
{
var sblog = new stringbuilder(string.empty);
try
{
sblog.append($"这里是blogsobj，获取配置文件：{this.xmlconfig.name}");
//代码块
//
new writelog()._writelog($"{datetime.now}测试引用nuget包");
}
catch (exception ex)
{
sblog.append($"异常信息：{ex.message}");
}
finally
{
publicclass._writelog(sblog.tostring(), this.xmlconfig.name);
}
}
}
}
blogsobj01.cs：
using system;
using system.collections.generic;
using system.linq;
using system.text;
using system.threading.tasks;
using taskcore.plugin;
namespace taskcore.test
{
// this project can output the class library as a nuget package.
// to enable this option, right-click on the project and select the properties menu item. in the build tab select "produce outputs on build".
public class blogsobj01 : tplugin
{
public blogsobj01()
{
}
public override void tplugin_load()
{
var sblog = new stringbuilder(string.empty);
try
{
sblog.append($"这里是blogsobj01，获取配置文件：{this.xmlconfig.name}");
//代码块
//
}
catch (exception ex)
{
sblog.append($"异常信息：{ex.message}");
}
finally
{
//console.writeline($"这里是blogs，获取配置文件：{this.xmlconfig.name}");
publicclass._writelog(sblog.tostring(), this.xmlconfig.name);
}
}
}
}
blogsobj02.cs：
using system;
using system.collections.generic;
using system.linq;
using system.threading.tasks;
using taskcore.plugin;
namespace taskcore.test
{
// this project can output the class library as a nuget package.
// to enable this option, right-click on the project and select the properties menu item. in the build tab select "produce outputs on build".
public class blogsobj02 : tplugin
{
public blogsobj02()
{
}
public override void tplugin_load()
{
//console.writeline($"这里是blogs，获取配置文件：{this.xmlconfig.name}");
publicclass._writelog($"这里是blogsobj02，获取配置文件：{this.xmlconfig.name}", this.xmlconfig.name);
}
}
}
好了测试代码写完，咋们生成一下，然后把这个taskcore.test.dll拷贝到taskcore.mainform运行包中，还需要在pluginxml文件夹中分别创建继承tplugin的子类的配置文件对应的截图如（注：这里xml配置文件名称必须和子类名称一样）：
配置文件内容如blogsobj.xml：
<!-- 1.xml配置模板 2.utf-8文件 3.复制到程序根目录下面pluginxml文件夹下 4.每个任务建议创建和程序dll名称相同xml配置文件 --> <taskmain> <!--固定：执行任务时间计时器（分钟）--> <timer>1</timer> <!--固定：任务名称--> <name>获取博客信息</name> <!--固定：账号--> <username></username> <!--固定：密码--> <userpwd></userpwd> <!--固定：key--> <apikey></apikey> <!--固定：key--> <apiurl></apiurl> <!--固定：是否关闭任务 1:是 0：否--> <closetask>0</closetask> <!--固定：描述--> <des>获取博客信息</des> <!--自定义：其他配置信息--> <other> <shenniubuxing3>神牛步行3</shenniubuxing3> </other> </taskmain>
最后在crossfiles.xml配置文件中添加taskcore.test.dll文件名称如：
<!-- crossfiles指定对应任务的dll文件，必须存在的文件 --> <taskmain> <file>taskcore.test.dll</file> </taskmain>
好了完成了，我们在windows开发环境上运行看下效果图：
到这里我们来简单总结下怎么使用taskcore.mainform插件，在自己项目中安装taskcore.plugin的nuget包-》重写父类tplugin的tplugin_load()方法-》生成自己的项目，拷贝项目的dll到taskcore.mainform运行包中-》在运行包中pluginxml文件夹中增加任务子类相同类名的xml文件并配置如上的配置信息-》增加crossfiles.xml中的任务dll文件配置-》使用命令dotnet taskcore.mainform.dll运行服务插件，挺简单的吧
. win7和ubuntu16.04运行taskcore.mainform的两种方式和测试截图（也可认为.netcore项目在win7和ubuntu系统运行的两种方式）
由于环境影响，这里跨平台运行测试我只测试win7和ubuntu16.04，其他系统的发布测试希望朋友们在使用过程中得到结果告知我下谢谢；先来讲在win7中运行：
1. 安装了netcore sdk环境的发布运行
安装了sdk后直接可以在cmd命令中dotnet taskcore.mainform.dll来运行服务，开篇上面讲解的示例都是在安装了sdk后的截图，服务运行所需要的文件如图：
就只有这些文件(当然程序需要的某些平台依赖项使用的是安装的sdk中的文件，所以看起来很少实际应该包含netcore sdk里面的文件才能运行)，通过命令运行的效果图：
2. 未安装netcore sdk环境的发布运行
在为安装sdk平台上系统上运行才是重点，这样才可以说是跨平台；首先，为了更好看效果我们复制一份如图的两个文件到taskcore.mainform01文件夹中：
没错，只需要这两个文件，然后我们需要修改project.json文件的内容如下注释的地方：
{
"version": "1.0.0-*",
"buildoptions": {
"emitentrypoint": true
},
"dependencies": {
"microsoft.netcore.app": {
//"type": "platform", 跨平台发布需要注释
"version": "1.0.0"
},
"system.io.filesystem": "4.0.1",
"system.reflection": "4.1.0",
"system.text.encoding.codepages": "4.0.1",
"system.threading.timer": "4.0.1",
"system.xml.xdocument": "4.0.11",
"taskcore.plugin": "1.0.0"
},
"frameworks": {
"netcoreapp1.0": {
"imports": "dnxcore50"
}
},
//跨平台发布需要添加如下节点
"runtimes": {
"ubuntu.16.04-x64": { }, //运行在ubuntu.16.04的64位系统
"win7-x64": { } //运行在win7的64位系统
}
}
然后使用cmd分别录入并回车运行指令dotnet restore此时taskcore.mainform01文件夹中会自动生成一个project.lock.json文件(大家注意看下)，然后再录入指令dotnet publish -r win7-x64，可以看到命令窗信息如：
就表示成功了，并且有返回生成运行文件的路径，我们按照路径找到生成的文件publish文件夹，里面没有pluginxml配置文件夹和配置文件和测试项目taskcore.test.dll，我们为了方便直接复制上面配置好的配置文件到publish文件夹中如下截图就是生成的发布文件：
没错taskcore.mainform01.exe这个就是自动生成的运行文件，然后我们双击运行效果图：
运行成功了，有朋友会问您之前系统不是安装了sdk么，这种测试能算么，我想说的是这个我通过qq发给qq群里面的朋友@南宫亦琦（不要怪我贴出了您的昵称）测试过了，她没有安装过sdk的；
ubuntu16.04运行：
1. 安装了netcore sdk环境的发布运行
首先，我们需要把在win7上生成的项目复制到ubuntu系统磁盘中(我们使用上面配置好的taskcore.mainform包)，我这里采用共享目录的方式把文件拷贝到ubuntu系统磁盘上，如图：
然后，鼠标右键点击空白地方，选择“在终端打开”，然后在窗体中录入如下指令dotnet taskcore.mainform.dll，能看到如下运行起的结果：
这个命令方式是不是很上面win7上的方式很相同，本来就是一样的，只要安装了.netcore sdk这种方式几乎可以共用
2. 未安装netcore sdk环境的发布运行
不安装sdk环境运行才是咋们需要关注的，下面就来看下怎么生成再ubuntu系统上能运行的文件；我们复制一份上面的taskcore.mainform01项目到taskcore.mainform02中来测试，由于之前我们在讲生成win7执行文件时候，执行了命令dotnet restore和dotnet publish -r win7-x64命令所以文件中有project.lock和bin文件夹，为了测试我们需要删除掉部分文件，只剩下如图文件，这里需要注意的是之前已经配置过project.xml我们无需在修改了：
然后，分别执行和生成win7运行文件几乎相同的命令dotnet restore和dotnet publish -r ubuntu.16.04-x64不同之处在于生成的文件存放的位置不同和使用的运行环境不同，运行结果如图：
publish文件夹中的文件就是在ubuntu系统执行的文件，然后我们需要把任务配置文件夹pluginxml和测试项目taskcore.test.dll复制到该目录中，再来咋们通过共享吧taskcore.mainform02目录中的publish复制到ubuntu中；然后我们需要把taskcore.mainform02可执行文件设置下权限，鼠标右键点击taskcore.mainform02可执行文件，选择“属性”，再选择“权限”选项卡，勾选“允许作为程序执行”，如图：
然后，我们右键文件夹中空白处，选择“在终端打开”，再执行如下命令./taskcore.mainform02，最后看运行效果图：
好了，发布在ubuntu系统上执行文件和运行的步奏就这些，几乎和win7上相同
. 框架代码解读及感悟
怎么使用跨平台taskcore.mainform任务框架讲解完了，下面来具体看下主要代码program.cs文件中：
namespace taskcore.mainform
{
/// <summary>
/// author 神牛步行3
/// contact 841202396@qq.com
/// des taskcore.mainform跨平台插件由神牛步行3提供
/// </summary>
public class program
{
private static dictionary<string, moassembly> dictasks = new dictionary<string, moassembly>();
public static void main(string[] args)
{
//注册编码，防止乱码
encoding.registerprovider(codepagesencodingprovider.instance);
//初始化程序集文件
_init();
//是否继续开启任务，默认没有待执行任务，不提示
if (dictasks.count <= 0) { _loopalert("是否退出？(y/n)"); return; }
_loopalert("是否开始执行任务？(y / n)");
//执行任务
foreach (var item in dictasks.values)
{
//使用task防止异常后相互影响
task.run(() =>
{
try
{
//创建任务对象
var tp = item.asm.createinstance(item.fullname) as tplugin;
if (!string.isnullorempty(tp.xmlconfig.tperror)) { _alert($"{datetime.now.tostring("yyyy/mm/dd hh:mm")}：{tp.xmlconfig.name} - 异常信息：{tp.xmlconfig.tperror}"); }
else
{
//timer定时器
var timer = new timer((param) =>
{
var msg = $"{datetime.now.tostring("yyyy/mm/dd hh:mm")}：{tp.xmlconfig.name}";
try
{
var tpobj = param as tplugin;
//是否关闭暂停任务
if (tpobj.xmlconfig.closetask) { return; }
_alert($"{msg} - 开始执行...{tp.xmlconfig.timer}分钟一次");
//任务入口
tpobj.tplugin_load();
}
catch (exception ex) { _alert($"{msg} - 异常信息：{ex.message}"); }
}, tp, 0, 1000 * 60 * tp.xmlconfig.timer);
}
}
catch (exception ex)
{
_alert($"{datetime.now.tostring("yyyy/mm/dd hh:mm")}：{item.name} - 异常信息：{ex.message}");
}
});
}
_loopalert("正在监控执行的任务，是否退出？(y / n)");
}
/// <summary>
/// 初始化程序集文件
/// </summary>
private static void _init()
{
try
{
_alert("初始化任务中...");
//获取文件
var files = publicclass._getpluginfile("");
if (files.length <= 0) { _alert("未能找到可用的程序集,请检查配置"); return; }
//读取任务文件
_alert("读取crossfiles.xml配置中...");
var baseaddr = path.combine(directory.getcurrentdirectory(), "pluginxml", "crossfiles.xml");
var doc = xdocument.load(baseaddr);
var fileables = files.asenumerable();
var taskfiles = new list<fileinfo>();
foreach (var item in doc.root.nodes())
{
var crossfile = item.tostring().toupper();
var choicefiles = fileables.where(b => crossfile.contains(b.name.toupper()));
if (!choicefiles.any()) { continue; }
taskfiles.addrange(choicefiles);
}
//展示文件信息
_alert($"待遍历{taskfiles.count}个文件信息...");
foreach (var item in taskfiles.orderby(b => b.creationtime))
{
var asmname = new assemblyname($"{item.name.replace(".dll", "")}");
assembly sm = assembly.load(asmname);
if (sm == null) { continue; }
var ts = sm.gettypes();
//判断特定的任务类，加入任务dic
foreach (var t in ts.where(b => b.name != "tplugin" && b.getmethod("tplugin_load") != null))
{
dictasks.add(
t.fullname,
new moassembly
{
asm = sm,
fullname = t.fullname,
name = t.name
});
}
}
_alert($"获取待执行任务量：{dictasks.count}个");
}
catch (exception ex)
{
_alert($"异常信息：{ ex.message}");
}
}
/// <summary>
/// 消息提醒
/// </summary>
/// <param name="msg">提示信息</param>
/// <param name="isreadline">是否需要用户输入指令</param>
/// <returns>用户录入的指令</returns>
private static string _alert(string msg = "神牛步行3-消息提醒", bool isreadline = false)
{
console.writeline(msg);
if (isreadline) { return console.readline(); }
return "";
}
private static void _loopalert(string msg = "是否开始执行任务？(y/n)")
{
do
{
var readkey = _alert(msg, true);
if (readkey.toupper().contains("y")) { break; }
} while (true);
}
}
public class moassembly
{
public assembly asm { get; set; }
public string fullname { get; set; }
public string name { get; set; }
}
}
tplugin.cs文件中代码：
using system;
using system.collections.generic;
using system.io;
using system.linq;
using system.threading.tasks;
using system.xml.linq;
namespace taskcore.plugin
{
/// <summary>
/// 插件基类
/// </summary>
public class tplugin : idisposable
{
public tplugin()
{
xmlconfig = _initconfig();
}
#region 初始化xml配置文件 _initconfig +xmlconfig
/// <summary>
/// xml配置信息
/// </summary>
public xmlconfig xmlconfig;
/// <summary>
/// 初始化配置信息
/// </summary>
/// <param name="configpath">配置文件对应路径</param>
/// <returns></returns>
public virtual xmlconfig _initconfig(string configpath = "")
{
xmlconfig config = new xmlconfig();
config.timer = 1;
config.name = this.gettype().name;
try
{
if (string.isnullorempty(configpath))
{
//默认各个dllxml配置
var defaultconfigfolder = "pluginxml";
var baseaddr = directory.getcurrentdirectory();
configpath = path.combine(baseaddr, defaultconfigfolder, config.name + ".xml");
}
var doc = xdocument.load(configpath);
config.doc = doc;
var taskmain = doc.root;
config.timer = convert.toint32(taskmain.element(xname.get("timer", "")).value);
config.name = taskmain.element(xname.get("name", "")).value;
config.des = taskmain.element(xname.get("des", "")).value;
config.username = taskmain.element(xname.get("username", "")).value;
config.userpwd = taskmain.element(xname.get("userpwd", "")).value;
config.apikey = taskmain.element(xname.get("apikey", "")).value;
config.apiurl = taskmain.element(xname.get("apiurl", "")).value;
config.closetask = taskmain.element(xname.get("closetask", "")).value == "1";
}
catch (exception ex)
{
config.tperror = ex.message;
publicclass._writelog($"{config.name}初始化配置信息异常：{ex.message}", "baselog");
throw new exception(ex.message);
}
return config;
}
#endregion
#region 初始化-开始加载 _load
/// <summary>
/// 初始化-开始起
/// </summary>
public virtual void tplugin_load()
{
publicclass._writelog("测试");
}
#endregion
#region 释放资源
public void dispose()
{
gc.suppressfinalize(this);//不需要再调用本对象的finalize方法
}
public virtual void dispose(action action)
{
action();
}
#endregion
}
#region 配置文件 xmlconfig
public class xmlconfig
{
public xmlconfig()
{
}
/// <summary>
/// 定制器时间（分钟）
/// </summary>
public int timer { get; set; }
/// <summary>
/// 运行名称
/// </summary>
public string name { get; set; }
/// <summary>
/// 描述(第一次获取dll描述，后面获取xml配置文件描述)
/// </summary>
public string des { get; set; }
/// <summary>
/// 接口账号
/// </summary>
public string username { get; set; }
/// <summary>
/// 接口密码
/// </summary>
public string userpwd { get; set; }
/// <summary>
/// 接口秘钥
/// </summary>
public string apikey { get; set; }
/// <summary>
/// 接口地址
/// </summary>
public string apiurl { get; set; }
/// <summary>
/// 是否关闭任务
/// </summary>
public bool closetask { get; set; }
/// <summary>
/// 插件中错误
/// </summary>
public string tperror { get; set; }
/// <summary>
/// xml信息
/// </summary>
public xdocument doc { get; set; }
}
#endregion
}
具体的说明和逻辑处理代码中都有注释，各位可以详细看下；这里要诉说的是该框架主要原理是动态加载任务dll来创建对象，netcore的程序集类assembly不像framework里面的assembly一样那么多可以用方法，我这里用的assembly.load()，netcore只能加载当前系统根目录的dll（这里我花了几个小时测试，有不同结果的朋友，请及时联系我谢谢），框架使用task.run()方法创建不同任务，实现并行执行的效果，并且各个容易出错地方使用try...catch来容错，避免了某个子任务异常后，导致框架全部中断运行，个人觉得其实还是不错的是吧；
下面给出几个不同环境下的压缩包，以供使用和参考：
taskcore.mainform-纯文件 taskcore.mainform01 git源码地址
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。