quartz.net动态创建任务(quartz.net怎样知道执行结果)

本文主要讲解“如何在中使用石英。NET”，感兴趣的朋友不妨看看。本文介绍的方法简单、快速、实用。让边肖带你学习“如何使用石英。NET”！

00-1010比如某个月需要更新或同步数据库中的一些数据，或者需要定期执行一部分代码调用接口，但不需要手动执行。

对于这种业务，您可以使用“计划任务”。市面上有很多调度任务框架，甚至你可以用定时器结合Windows服务做一个简单版本的任务调度器。这里我们研究Quartz，因为Quartz是一个强大的、开源的、轻量级的任务调度框架，支持cron类表达式的其他优秀特性。

一、背景

1.基本概念

SchedulerTriggerJob scheduler是quartz工作时的一个独立的容器触发器，它定义了调度任务的时间规则，并为任务要执行的特定操作调用容器。2.初步使用

1.Nuget推出石英组件

2.创建调度器任务调度容器

3.指定要执行的特定任务作业和触发器。

4.将策略和任务放入调度程序并启动它。

publicclassQuartzManager

{

publicasyncstaticvoidInit()

{

stdschedulerfactory=newtdschedulerfactory()；

//创建调度器任务调度容器

ISchedulerscheduler=awaitfactory。GetScheduler()；

//指定要执行的特定任务作业。

IJobDetailsendEmailJob=job builder。CreateSendMailJob()。WithIdentity('sendEmailJob '，' sendEmailJobGrop ')。带有描述(“定期发送邮件”)。build()；

//将触发条件设置为每五秒执行一次。

ITriggersendEmailTrigger=TriggerBuilder。创建()。WithIdentity('sendEmailTrigger '，' sendEmailJobGrop '。带描述(“石英”)。带时间表(' 3/5****？')。build()；

//把战略和

任务放入到Scheduler
        await scheduler.ScheduleJob(sendEmailJob, sendEmailTrigger);
        //执行任务
        await scheduler.Start();
    } 
}

//增加特性保证任务不会重叠执行
[DisallowConcurrentExecution]
public class SendMailJob : IJob
{
    //Job类
    public async Task Execute(IJobExecutionContext context)
    {
        await  Task.Run(() =>
        {
            //doSomthing
            Console.WriteLine($"开始发送邮件{DateTime.Now}");
        });
    }
}

三、传递参数

有时候我们想在Job执行时需要一些参数，并根据这些参数来做一些逻辑处理,这时候就需要使用Quartz传参了。
在Quartz中传参主要有一些几种方式

1.job传参

2.Trigger传参

1.job传参和Trigger传参

使用JobDataMap.Add添加参数，在job内部使用上下文的JobDataMap.GetString获取

IJobDetail sendEmailJob = JobBuilder.Create<SendMailJob>().Build(); 
//往Job传一个参数
sendEmailJob.JobDataMap.Add("params","job测试传参");

ITrigger trigger = TriggerBuilder.Create().Build();
//往trigger传一个参数
trigger.JobDataMap.Add("params", "trigger测试传参");

//在job中获取参数
public async Task Execute(IJobExecutionContext context)
{
    await  Task.Run(() =>
    {
        //获取job传参
        string paramJob = context.JobDetail.JobDataMap.GetString("params");
        
        //获取Trigger传参
        string paramTrigger = context.Trigger.JobDataMap.GetString("params");
        //doSomthing
        Console.WriteLine($"开始发送邮件{DateTime.Now}");
    });
}

四、在scheduler中注册监听器

监听器是为调度程序中发生的事件执行操作而创建的对象,主要有一下三种监听器

1.调度监听器ISchedulerListener主要用于调度过程的监听。

2.触发器监听器ITriggerListener主要用于接收和触发器相关的事件监听。

3.作业监听器IJobListener用于接收Job运行生命周期相关事件监听。

1.实现监听器

以作业监听器为例,因为触发和调度监听一样的实现。

1.自定义作业监听器需要继承自IJobListener接口并实现方法.

2.在调度器的监听管理中添加自定义监听器.

//实现监听器
public class CustomJobListener :  IJobListener
{
    public string Name => "CustomJobListener";  
}

//添加到监听管理中
scheduler.ListenerManager.AddJobListener(new CustomJobListener());

五、可视化管理界面

用于可视化工具来查看当前运行Job的信息。

1.需要新建一个web项目或者控制台项目。

2.在web项目中 Nuget 引入Quartz 和CrystalQuartz.Remote程序包

3.在Job调度中配置StdSchedulerFactory相关信息指定监听端口

 var properties = new NameValueCollection();
 properties["quartz.scheduler.instanceName"] = "Test Monitor System";

 // 设置线程池
 properties["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz";
 properties["quartz.threadPool.threadCount"] = "5";
 properties["quartz.threadPool.threadPriority"] = "Normal";

// 远程输出配置
properties["quartz.scheduler.exporter.type"] = "Quartz.Simpl.RemotingSchedulerExporter, Quartz";
properties["quartz.scheduler.exporter.port"] = "8081";
properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";
properties["quartz.scheduler.exporter.channelType"] = "tcp";

var schedulerFactory = new StdSchedulerFactory(properties);
IScheduler _scheduler = await schedulerFactory.GetScheduler();

4.web监控端去访问统一的端口号下的CrystalQuartzPanel.axd即可查看。

六、配置文件配置任务

我们除了在代码中定义任务的各种调度和触发器之外，还可以使用xml配置文件的方式来创建Job任务

1.准备配置文件，配置Job+trigger相关信息,一定要将此文件属性设为"始终复制"

<?xml version="1.0" encoding="UTF-8"?>
<job-scheduling-data xmlns="http://quartznet.sourceforge.net/JobSchedulingData" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.0">

  <processing-directives>
    <overwrite-existing-data>true</overwrite-existing-data>
  </processing-directives>
  <schedule>
    <job>
      <name>sendEmailJob</name>
      <group>Test Mail Job</group>
      <description>This is Test Mail Job</description>
      <!--此处为Job所在的类，及程序集-->
      <job-type>DispatcherProject.Job.SendMailJob,DispatcherProject</job-type>
      <durable>true</durable>
      <recover>false</recover>
    </job>
    <trigger>
      <cron>
        <name>sendEmailTrigger</name>
        <group>sendEmailJobGrop</group>
        <job-name>sendEmailJob</job-name>
        <job-group>Test Mail Job</job-group>
        <cron-expression>5/3 * * * * ?</cron-expression>
      </cron>
    </trigger>
  </schedule>
</job-scheduling-data>

2.读取配置文件，获取信息，生成对应的Job和Trigger

XMLSchedulingDataProcessor processor = new XMLSchedulingDataProcessor(new SimpleTypeLoadHelper());
//读取配置文件
await processor.ProcessFileAndScheduleJobs("~/config/quartz.xml", scheduler);
//启动调度任务
await scheduler.Start();

到此，相信大家对“Quartz在.NET中怎么使用”有了更深的了解，不妨来实际操作一番吧！这里是网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！