百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

Quartz.NET一个优秀的作业调度框架

ccwgpt 2024-09-18 12:26 33 浏览 0 评论

1 什么是Quartz.NET?

Quartz是一个功能齐全的开源作业调度系统,可以与几乎任何其他软件系统集成或一起使用。

2 为什么需要Quartz.NET?

.NET Framework通过System.Timers.Timer类具有“内置”计时器功能-为什么有人使用Quartz而不是这些标准功能?

原因有很多!这里有一些:

  • 计时器没有持久性机制。
  • 计时器的时间安排不灵活(只能设置开始时间和重复间隔,没有基于日期,一天中的时间等信息)。
  • 计时器不使用线程池(每个计时器一个线程)
  • 计时器没有真正的管理方案-您必须编写自己的机制以能够按名称记住,组织和恢复任务等。
  • 3 如何使用Quartz.NET?

    首先,安装Quartz

    Quartz
    

    然后,定义一个任务类

    using System;
    using System.Threading.Tasks;
    
    namespace Quartz.ConsoleApp01
    {
        public class HelloJob : IJob
        {
            public Task Execute(IJobExecutionContext context)
            {
                Console.WriteLine("Hello "+DateTime.Now);
                return Task.CompletedTask;
            }
        }
    }
    

    最后,实例化并启动调度程序,并调度要执行的作业:

    using Quartz.Impl;
    using System;
    using System.Threading.Tasks;
    
    namespace Quartz.ConsoleApp01
    {
        class Program
        {
            static async Task Main(string[] args)
            {
                Console.WriteLine("开始调度!");
    
                //1、创建一个调度
                var factory = new StdSchedulerFactory();
                var scheduler = await factory.GetScheduler();
                await scheduler.Start();
    
                //2、创建一个任务
                var job = JobBuilder.Create<HelloJob>()
                    .WithIdentity("job1", "group1")
                    .Build();
    
                //3、创建一个触发器
                var trigger = TriggerBuilder.Create()
                    .WithIdentity("trigger1", "group1")
                    .WithCronSchedule("0/5 * * * * ?")     //5秒执行一次
                    .Build();
    
                await scheduler.ScheduleJob(job, trigger);
    
                Console.ReadKey();
            }
        }
    }
    

    我们来看一下输出结果:

    开始调度!
    Hello 2021/1/19 14:37:40
    Hello 2021/1/19 14:37:45
    Hello 2021/1/19 14:37:50
    Hello 2021/1/19 14:37:55
    

    3 使用配置文件方式使用Quartz.NET?

    首先,安装Quartz,Quartz.Plugins

    Quartz
    Quartz.Plugins
    

    然后,定义一个任务类

    using System;
    using System.Threading.Tasks;
    
    namespace Quartz.ConsoleApp02
    {
        public class HelloJob : IJob
        {
            public Task Execute(IJobExecutionContext context)
            {
                Console.WriteLine("Hello " + DateTime.Now);
                return Task.CompletedTask;
            }
        }
    }
    

    接着,配置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>
    		<!--TestJob测试 任务配置-->
    		<job>
    			<name>job1</name>
    			<group>group1</group>
    			<description>job1</description>
    			<job-type>Quartz.ConsoleApp02.HelloJob,Quartz.ConsoleApp02</job-type>
    			<durable>true</durable>
    			<recover>false</recover>
    		</job>
    		<trigger>
    			<cron>
    				<name>trigger1</name>
    				<group>group1</group>
    				<job-name>job1</job-name>
    				<job-group>group1</job-group>
    				<cron-expression>0/5 * * * * ?</cron-expression>
    			</cron>
    		</trigger>
    	</schedule>
    </job-scheduling-data>
    

    最后,实例化并启动调度程序:

    using Quartz.Impl;
    using System;
    using System.Collections.Specialized;
    using System.Threading.Tasks;
    
    namespace Quartz.ConsoleApp02
    {
        class Program
        {
            static async Task Main(string[] args)
            {
                Console.WriteLine("开始调度!");
    
                //1、首先,我们必须获得对调度程序的引用
                var properties = new NameValueCollection
                {
                    ["quartz.scheduler.instanceName"] = "XmlConfiguredInstance",
                    ["quartz.threadPool.type"] = "Quartz.Simpl.SimpleThreadPool, Quartz",
                    ["quartz.threadPool.threadCount"] = "5",
                    ["quartz.plugin.xml.type"] = "Quartz.Plugin.Xml.XMLSchedulingDataProcessorPlugin, Quartz.Plugins",
                    ["quartz.plugin.xml.fileNames"] = "~/quartz_jobs.xml",
                    // this is the default
                    ["quartz.plugin.xml.FailOnFileNotFound"] = "true",
                    // this is not the default
                    ["quartz.plugin.xml.failOnSchedulingError"] = "true"
                };
    
                //2、创建一个调度
                var factory = new StdSchedulerFactory(properties);
                var scheduler = await factory.GetScheduler();
                await scheduler.Start();
    
                Console.ReadKey();
            }
        }
    }
    

    4 Cron表达式

    4.1 介绍

    cron是已存在很长时间的UNIX工具,因此其调度功能强大且经过验证。
    cron表达式是由7段构成:秒 分 时 日 月 星期 年(可选)

  • "*" 用于选择字段中的所有值,例如,在分钟字段中表示“每分钟”。
  • "?" 在需要在允许使用字符的两个字段之一中指定某些内容而在另一个不允许使用的字段中指定内容时很有用。例如,如果我希望触发器在每月的某个特定日期(例如10号)触发,但不在乎是星期几,则将其10输入“月日”字段,以及?“星期几”字段中。
  • "-" 用于指定范围。例如,10-12在小时字段中表示“小时10、11和12”。
  • "," 用于指定其他值。例如,MON,WED,FRI在“星期几”字段中表示“星期一,星期三和星期五的日子”。
  • "/" 用于指定增量。例如,0/15在秒字段中表示“秒0、15、30和45”。和5/15在秒字段的意思是“秒5,20,35和50”。
  • "L" 在允许使用的两个字段中都有不同的含义。例如,“L月日”字段中的值表示“月的最后一天”
  • "W" 用于指定最接近给定日期的工作日(星期一至星期五)。例如,如果您要指定“15W月日”字段的值,则含义是:“离月15日最近的工作日”。
  • "#" 用于指定每月的“第n个” XXX天。例如,“6#3星期几”字段中的值表示“每月的第三个星期五”(第6天=星期五,“#3” =每月的第三个星期五)。

  • 4.2 例子


    相关推荐

    十分钟让你学会LNMP架构负载均衡(impala负载均衡)

    业务架构、应用架构、数据架构和技术架构一、几个基本概念1、pv值pv值(pageviews):页面的浏览量概念:一个网站的所有页面,在一天内,被浏览的总次数。(大型网站通常是上千万的级别)2、u...

    AGV仓储机器人调度系统架构(agv物流机器人)

    系统架构层次划分采用分层模块化设计,分为以下五层:1.1用户接口层功能:提供人机交互界面(Web/桌面端),支持任务下发、实时监控、数据可视化和报警管理。模块:任务管理面板:接收订单(如拣货、...

    远程热部署在美团的落地实践(远程热点是什么意思)

    Sonic是美团内部研发设计的一款用于热部署的IDEA插件,本文其实现原理及落地的一些技术细节。在阅读本文之前,建议大家先熟悉一下Spring源码、SpringMVC源码、SpringBoot...

    springboot搭建xxl-job(分布式任务调度系统)

    一、部署xxl-job服务端下载xxl-job源码:https://gitee.com/xuxueli0323/xxl-job二、导入项目、创建xxl_job数据库、修改配置文件为自己的数据库三、启动...

    大模型:使用vLLM和Ray分布式部署推理应用

    一、vLLM:面向大模型的高效推理框架1.核心特点专为推理优化:专注于大模型(如GPT-3、LLaMA)的高吞吐量、低延迟推理。关键技术:PagedAttention:类似操作系统内存分页管理,将K...

    国产开源之光【分布式工作流调度系统】:DolphinScheduler

    DolphinScheduler是一个开源的分布式工作流调度系统,旨在帮助用户以可靠、高效和可扩展的方式管理和调度大规模的数据处理工作流。它支持以图形化方式定义和管理工作流,提供了丰富的调度功能和监控...

    简单可靠高效的分布式任务队列系统

    #记录我的2024#大家好,又见面了,我是GitHub精选君!背景介绍在系统访问量逐渐增大,高并发、分布式系统成为了企业技术架构升级的必由之路。在这样的背景下,异步任务队列扮演着至关重要的角色,...

    虚拟服务器之间如何分布式运行?(虚拟服务器部署)

      在云计算和虚拟化技术快速发展的今天,传统“单机单任务”的服务器架构早已难以满足现代业务对高并发、高可用、弹性伸缩和容错容灾的严苛要求。分布式系统应运而生,并成为支撑各类互联网平台、企业信息系统和A...

    一文掌握 XXL-Job 的 6 大核心组件

    XXL-Job是一个分布式任务调度平台,其核心组件主要包括以下部分,各组件相互协作实现高效的任务调度与管理:1.调度注册中心(RegistryCenter)作用:负责管理调度器(Schedule...

    京东大佬问我,SpringBoot中如何做延迟队列?单机与分布式如何做?

    京东大佬问我,SpringBoot中如何做延迟队列?单机如何做?分布式如何做呢?并给出案例与代码分析。嗯,用户问的是在SpringBoot中如何实现延迟队列,单机和分布式环境下分别怎么做。这个问题其实...

    企业级项目组件选型(一)分布式任务调度平台

    官网地址:https://www.xuxueli.com/xxl-job/能力介绍架构图安全性为提升系统安全性,调度中心和执行器进行安全性校验,双方AccessToken匹配才允许通讯;调度中心和执...

    python多进程的分布式任务调度应用场景及示例

    多进程的分布式任务调度可以应用于以下场景:分布式爬虫:importmultiprocessingimportrequestsdefcrawl(url):response=re...

    SpringBoot整合ElasticJob实现分布式任务调度

    介绍ElasticJob是面向互联网生态和海量任务的分布式调度解决方案,由两个相互独立的子项目ElasticJob-Lite和ElasticJob-Cloud组成。它通过弹性调度、资源管控、...

    分布式可视化 DAG 任务调度系统 Taier 的整体流程分析

    Taier作为袋鼠云的开源项目之一,是一个分布式可视化的DAG任务调度系统。旨在降低ETL开发成本,提高大数据平台稳定性,让大数据开发人员可以在Taier直接进行业务逻辑的开发,而不用关...

    SpringBoot任务调度:@Scheduled与TaskExecutor全面解析

    一、任务调度基础概念1.1什么是任务调度任务调度是指按照预定的时间计划或特定条件自动执行任务的过程。在现代应用开发中,任务调度扮演着至关重要的角色,它使得开发者能够自动化处理周期性任务、定时任务和异...

    取消回复欢迎 发表评论: