QuartzNet使用

quartz.config# You can configure your scheduler in either <quartz> configuration section# or in quartz properties file# Configuration section has precedencequartz.scheduler.instanceName = RemoteServer# configure thread pool infoquartz.threadPool.type = Quartz.Simpl.SimpleThreadPool, Quartzquartz.threadPool.threadCount = 10quartz.threadPool.threadPriority = Normal# job initialization plugin handles our xml reading, without it defaults are usedquartz.plugin.xml.type = Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Pluginsquartz.plugin.xml.fileNames = ~/quartz_jobs.xml# export this server to remoting contextquartz.scheduler.exporter.type = Quartz.Simpl.RemotingSchedulerExporter, Quartzquartz.scheduler.exporter.port = 555quartz.scheduler.exporter.bindName = QuartzSchedulerquartz.scheduler.exporter.channelType = tcpquartz.scheduler.exporter.channelName = httpQuartzquartz.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>2015-01-22T00:00:00+08:00</start-time> ???????<cron-expression>0/2 * * * * ? </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(3) ?????????????????.RepeatForever()) ?????????????.Build(); ???????????IJobDetail job1 = JobBuilder.Create<PaymentConfirmedJod>() ???????????????.WithIdentity("PaymentConfirmedJod", "group1") ???????????????.Build(); ???????????ITrigger trigger1 = TriggerBuilder.Create() ?????????????.WithIdentity("PaymentConfirmedTrigger", "group1") ?????????????.StartNow() ?????????????.WithSimpleSchedule(x => x ?????????????????.WithIntervalInSeconds(2) ?????????????????.RepeatForever()) ?????????????.Build(); ???????????sched.ScheduleJob(cancelOrderJob, cancelOrderTrigger); ???????????sched.ScheduleJob(job1, trigger1); ???????????System.Console.ReadKey(); ???????} ???}