QuartzNet使用

quartz.config

# You can configure your scheduler in either <quartz> configuration section

# or in quartz properties file

# Configuration section has precedence

quartz.scheduler.instanceName = RemoteServer

# configure thread pool info

quartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartz

quartz.threadPool.threadCount =

quartz.threadPool.threadPriority = Normal

# job initialization plugin handles our xml reading, without it defaults are used

quartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins

quartz.plugin.xml.fileNames = ~/quartz_jobs.xml

# export this server to remoting context

quartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartz

quartz.scheduler.exporter.port =

quartz.scheduler.exporter.bindName = QuartzScheduler

quartz.scheduler.exporter.channelType = tcp

quartz.scheduler.exporter.channelName = httpQuartz

quartz.scheduler.exporter.rejectRemoteRequests = true

quartz_jobs.xml

<?xml version="1.0" encoding="UTF-8"?>

<!-- This file contains job definitions in schema version 2.0 format -->

<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>

    <!--cancelOrderJob测试 任务配置-->

    <job>

      <name>cancelOrderJob</name>

      <group>ABC.OMS.Order</group>

      <description>取消订单计划任务</description>

      <job-type>QuartzTest.Jobs.CancelOrderJob,QuartzTest.Jobs</job-type>

      <durable>true</durable>

      <recover>false</recover>

    </job>

    <trigger>

      <cron>

        <name>cancelOrderTrigger</name>

        <group>ABC.OMS.Order</group>

        <job-name>cancelOrderJob</job-name>

        <job-group>ABC.OMS.Order</job-group>

        <start-time>--22T00::+:</start-time>

        <cron-expression>/ * * * * ? </cron-expression>

      </cron>

    </trigger>

  </schedule>

</job-scheduling-data>

class Program

    {

        static void Main(string[] args)

        {

            // var properties = new NameValueCollection();

            // properties["quartz.scheduler.instanceName"] = "RemoteServer";

            // 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"] = "555";

            // properties["quartz.scheduler.exporter.bindName"] = "QuartzScheduler";

            // properties["quartz.scheduler.exporter.channelType"] = "tcp";

            // properties["quartz.scheduler.exporter.channelName"] = "httpQuartz";

            // properties["quartz.scheduler.exporter.rejectRemoteRequests"] = "true";

            //ISchedulerFactory schedFact = new StdSchedulerFactory(properties);

            ISchedulerFactory schedFact = new StdSchedulerFactory();

            IScheduler sched = schedFact.GetScheduler().Result;

            sched.Start();

            IJobDetail cancelOrderJob = JobBuilder.Create<CancelOrderJob>()

                .WithIdentity("cancelOrderJob", "ABC.OMS.Order")

                .Build();

            ITrigger cancelOrderTrigger = TriggerBuilder.Create()

              .WithIdentity("cancelOrderTrigger", "ABC.OMS.Order")

              .StartNow()

              .WithSimpleSchedule(x => x

                  .WithIntervalInSeconds()

                  .RepeatForever())

              .Build();

            IJobDetail job1 = JobBuilder.Create<PaymentConfirmedJod>()

                .WithIdentity("PaymentConfirmedJod", "group1")

                .Build();

            ITrigger trigger1 = TriggerBuilder.Create()

              .WithIdentity("PaymentConfirmedTrigger", "group1")

              .StartNow()

              .WithSimpleSchedule(x => x

                  .WithIntervalInSeconds()

                  .RepeatForever())

              .Build();

            sched.ScheduleJob(cancelOrderJob, cancelOrderTrigger);

            sched.ScheduleJob(job1, trigger1);

            System.Console.ReadKey();

        }

    }

namespace QuartzTest.Jobs

{

    [DisallowConcurrentExecution]  //设置JOB不允许并行执行

    public class CancelOrderJob : IJob

    {

        System.Threading.Tasks.Task IJob.Execute(IJobExecutionContext context)

        {

            System.Console.WriteLine(string.Format("[{0}]订单已取消", DateTime.Now));

            Thread.Sleep();

            return System.Threading.Tasks.Task.CompletedTask;

        }

    }

}