原文链接:

写在前面

有几天没更新博客了,一方面因为比较忙,另一方面是因为最近在准备组织我们霸都合肥的.NET技术社区首次非正式的线下聚会,忙着联系人啊,这里欢迎有兴趣的小伙伴加我wx:进行详细的了解,当然也欢迎同行加我微信,然后我拉你进入我们合肥.NET技术社区微信群跟大伙进行交流。

概念

开始之前还有必要跟大伙说一下abp vNext以及是什么,防止有小白。如果对这两个概念非常熟悉的话可以直接阅读下一节。项目最终实现的效果如下图所示:

abp vNext是什么

说起abp vNext就要从另一个概念开始说起了,那就是大名鼎鼎的ABP了。

ABP 官方的介绍是:ASP.NET 是一个用最佳实践和流行技术开发现代 WEB 应用程序的新起点,它旨在成为一个通用的 WEB 应用程序基础框架和项目模板。基于 DDD 的经典分层架构思想,实现了众多 DDD 的概念(但没有实现所有 DDD 的概念)。

而的出现是为了抛弃掉.net 版本下的包袱,重新启动的 abp 框架,目的是为了放弃对传统技术的支持,让 core 能够自身做到更加的模块化,目前这块的内容还不够成熟。原因是缺少组件信息和内容。

如果你想用于生产环境建议你可以使用ABP,如果你敢于尝试,勇于创新的话可以直接使用abp vNext进行开发的。

abp vNext官网:

文档:

.NET是什么

.NET是一个强大、开源、轻量的作业调度框架,你能够用它来为执行一个作业而创建简单的或复杂的作业调度。它有很多特征,如:数据库支持,集群,插件,支持cron-like表达式等等。目前已经正式支持了.NET Core 和async/await。

说白了就是你可以使用.NET可以很方便的开发定时任务诸如平时的工作中,定时轮询数据库同步,定时邮件通知,定时处理数据等。

实例演练

这一节我们通过实例进行操作,相信跟着做的你也能够把代码跑起来。

ABP vNext代码

既然我们此次演练的项目是使用的abp vNext这个 core的快速开发框架来完成的,所以首先在项目开始之前quartz插件,你需要到ABP vNext的官网上去下载项目代码。英文站打开慢的话,可以访问中文子域名进行访问:。下面给出具体步骤:

打开 然后如图填写对应的项目名称,这里我用的Czar.项目类型选择ASP.NET Core MVC应用程序,因为这个是带有UI界面的web项目,数据库提供程序选择这个大家都比较熟悉,然后点击创建就可以了。

下载后,解压到一个文件夹下面,然后用vs打开解决方案,看到如下图所示的项目结构

图片

这里简单介绍下,每个项目的作用,具体的就不过多介绍了,在下面的实战代码中慢慢体会吧

解决方案还包含配置好的的单元&集成测试项目, 以便与于EF Core和数据库配合使用.

查看.Web项目下.json文件中的连接字符串并进行相应的修改,怎么改不要问我:

{
"ConnectionStrings": {
"Default": "Server=localhost;Database=CzarAbpDemo;Trusted_Connection=True;MultipleActiveResultSets=true"
}
}

右键单击.Web项目并将其设为启动项目

打开包管理器控制台( ), 选择.项目作为默认项目并运行-命令:

现在可以运行应用程序,它将会打开home页面:

点击“Login” 输入用户名admin, 密码*, 登录应用程序.

启动模板包括身份管理( )模块. 登录后将提供身份管理菜单,你可以在其中管理角色,用户及其权限. 这个不过多讲解了,自己去动手操作一番吧

集成.NET管理功能

这部分我们将实现.NET定时任务的管理功能,为了进行.NET定时任务的管理,我们还需要定义一个表来进行.NET定时任务的信息的承载,并完成这个表的增删改查功能,这样我们在对这个表的数据进行操作的同时来进行.NET定时任务的操作即可实现我们的需求。话不多说,开始吧。这部分我们再分成两个小节:的增删改查功能的实现,.NET调度任务功能的增删改查的实现。

的增删改查功能的实现

这个部分你将体会到我为什么使用abp vNext框架来进行开发了,就是因为快~~~~

创建领域实体对象,这个在领域层代码如下:

将我们的实体添加到中,这样应该在EF层

添加新的并更新到数据库中,这个应该算的基础了吧,两个步骤,一个“Add-” 然后“-”更新到数据库即可

Add-Migration "Add_JobInfo_Entity"
Update-Database

应用层创建页面显示实体用来在基础设施层和应用层传递数据

同样的你还需要在应用层创建一个用来传递增改的Dto对象

万事俱备,只欠服务了,接下来我们创建一下的服务接口以及服务接口的实现了,这里有个约定,就是所有的服务结尾,就跟控制器都以结尾的概念差不多。

服务实现:

注释还算清真,相信你应该能看懂。

这里abp vNext框架就会自动为我们实现增删改查的API 接口的实现(可以通过进行查看),还会自动为所有的API接口创建了代理.因此,你可以像调用 一样调用任何接口.

如下图所示

是不是,感觉什么都还没做,所有接口都已经实现的感觉。

新增一个菜单任务调度的菜单,如下代码所示:

对应的,我们需要在Pages/这个路径下面创建对应的Index.页面,以及新增,编辑的页面。由于内容太多,这里就不贴代码了,只给大家贴下图:

Index.

.代码如下:

然后我们运行起来查看下:

点击,右上角的新增,会弹出新增界面,点击每一行的操作,会弹出删除(删除,这里只做了一个假功能),编辑的两个选项。

到此,的增删改查就做好了,是不是很简单,这就是abp vNext赋予我们的高效之处。

.NET调度任务功能的增删改的实现

在使用.NET之前,你需要通过Nuget进行下安装,然后才能进行调用。这里我不会给你详细讲解.NET的使用,因为这将占用大量的篇幅,并偏离本文的主旨

安装.NET的Nuget包:

新建一个的任务调度中心,代码如下所示:

  /// 
/// 任务调度中心
///

public class ScheduleCenter
{
private readonly ILogger _logger;
public ScheduleCenter(ILogger logger)
{
_logger = logger;
}

///
/// 任务计划
///

public IScheduler scheduler = null;
public async Task GetSchedulerAsync()
{
if (scheduler != null)
{
return scheduler;
}
else
{
// 从Factory中获取Scheduler实例
NameValueCollection props = new NameValueCollection
{
{ "quartz.serializer.type", "binary" },
//以下配置需要数据库表配合使用,表结构sql地址:https://github.com/quartznet/quartznet/tree/master/database/tables
//{ "quartz.jobStore.type","Quartz.Impl.AdoJobStore.JobStoreTX, Quartz"},
//{ "quartz.jobStore.driverDelegateType","Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz"},
//{ "quartz.jobStore.tablePrefix","QRTZ_"},
//{ "quartz.jobStore.dataSource","myDS"},
//{ "quartz.dataSource.myDS.connectionString",AppSettingHelper.MysqlConnection},//连接字符串
//{ "quartz.dataSource.myDS.provider","MySql"},
//{ "quartz.jobStore.usePropert ies","true"}

};
StdSchedulerFactory factory = new StdSchedulerFactory(props);
return await factory.GetScheduler();

}
}

///
/// 添加调度任务
///

/// 任务名称
/// 任务分组
///
public async Task<bool> AddJobAsync(CreateUpdateJobInfoDto infoDto)
{
try
{
if (infoDto!=null)
{
if (infoDto.StarTime == null)
{
infoDto.StarTime = DateTime.Now;
}
DateTimeOffset starRunTime = DateBuilder.NextGivenSecondDate(infoDto.StarTime, 1);
if (infoDto.EndTime == null)
{
infoDto.EndTime = DateTime.MaxValue.AddDays(-1);
}
DateTimeOffset endRunTime = DateBuilder.NextGivenSecondDate(infoDto.EndTime, 1);
scheduler = await GetSchedulerAsync();
JobKey jobKey = new JobKey(infoDto.JobName, infoDto.JobGroup);
if (await scheduler.CheckExists(jobKey))
{
await scheduler.PauseJob(jobKey);
await scheduler.DeleteJob(jobKey);
}
IJobDetail job = JobBuilder.Create()
.WithIdentity(jobKey)
.Build();
ICronTrigger trigger = (ICronTrigger)TriggerBuilder.Create()
.StartAt(starRunTime)
.EndAt(endRunTime)
.WithIdentity(infoDto.JobName, infoDto.JobGroup)
.WithCronSchedule(infoDto.CronExpress)
.Build();
await scheduler.ScheduleJob(job, trigger);
await scheduler.Start();
return true;
}

return false;//JobInfo为空
}
catch (Exception ex)
{
_logger.LogException(ex);
return false;//出现异常
}
}

///
/// 暂停指定任务计划
///

/// 任务名
/// 任务分组
///
public async Task<bool> StopJobAsync(string jobName, string jobGroup)
{
try
{
JobKey jobKey = new JobKey(jobName, jobGroup);
scheduler = await GetSchedulerAsync();
if (await scheduler.CheckExists(jobKey))
{
await scheduler.PauseJob(new JobKey(jobName, jobGroup));
return true;
}
else
{
return false;//任务不存在
}
}
catch (Exception ex)
{
_logger.LogException(ex);
return false;//出现异常
}
}

///
/// 恢复指定的任务计划,如果是程序奔溃后 或者是进程杀死后的恢复,此方法无效
///

/// 任务名称
/// 任务组
///
public async Task<bool> ResumeJobAsync(string jobName, string jobGroup)
{
try
{
JobKey jobKey = new JobKey(jobName, jobGroup);
scheduler = await GetSchedulerAsync();
if (await scheduler.CheckExists(jobKey))
{
//resumejob 恢复
await scheduler.ResumeJob(new JobKey(jobName, jobGroup));
return true;
}
else
{
return false;//不存在任务
}

}
catch (Exception ex)
{
_logger.LogException(ex);
return false;//出现异常
}
}

///
/// 恢复指定的任务计划,如果是程序奔溃后 或者是进程杀死后的恢复,此方法无效
///

/// 任务名称
/// 任务组
///
public async Task<bool> DeleteJobAsync(string jobName, string jobGroup)
{
try
{
JobKey jobKey = new JobKey(jobName, jobGroup);
scheduler = await GetSchedulerAsync();
if (await scheduler.CheckExists(jobKey))
{
//DeleteJob 恢复
await scheduler.DeleteJob(jobKey);
return true;
}
else
{
return false;//不存在任务
}

}
catch (Exception ex)
{
_logger.LogException(ex);
return false;//出现异常
}
}
}

新建一个的计划任务,代码如下所示,需要继承IJob接口:

至此.NET调度任务功能完成

集成

这里我们按照之前的思路对跟.NET任务进行集成

新增时,启动任务:

编辑时,更新任务

这里细心的网友,可能注意到任务的删除是在编辑里面进行实现的。而列表页面的删除功能并没有实现真正意义的功能的删除。

功能演示

上面我们演示的任务是一个每5秒写入当前时间的一个任务,并实现了对这个任务的新增,删除,编辑的功能,这里大伙可以自行实现进行测试,也可以下载我的代码进行尝试。效果图如下所示:

图片

功能扩展

目前只能对既定义好任务进行调度,后期可以根据任务的名称,如我们实例中的测试任务的名字找到这个任务,然后动态的进行处理。这样就可以在界面实现对多个任务进行调度了!当然还有其他的扩展,本文只是作为引子。

源码地址

总结

本文只是简单的利用abp vNext框架进行.NET任务调度进行UI的管理,实现的功能也比较简单,大家完全可以在此基础上进行扩展完善quartz插件,最后感谢大伙的阅读。


限时特惠:
本站持续每日更新海量各大内部创业课程,一年会员仅需要98元,全站资源免费下载
点击查看详情

站长微信:Jiucxh

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注