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

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

yuyutoo 2024-11-01 15:55 4 浏览 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 例子


    相关推荐

    【Socket】解决UDP丢包问题

    一、介绍UDP是一种不可靠的、无连接的、基于数据报的传输层协议。相比于TCP就比较简单,像写信一样,直接打包丢过去,就不用管了,而不用TCP这样的反复确认。所以UDP的优势就是速度快,开销小。但是随之...

    深入学习IO多路复用select/poll/epoll实现原理

    Linux服务器处理网络请求有三种机制,select、poll、epoll,本文打算深入学习下其实现原理。0.结论...

    25-1-Python网络编程-基础概念

    1-网络编程基础概念1-1-基本概念1-2-OSI七层网络模型OSI(开放系统互联)七层网络模型是国际标准化组织(ISO)提出的网络通信分层架构,用于描述计算机网络中数据传输的过程。...

    Java NIO多路复用机制

    NIO多路复用机制JavaNIO(Non-blockingI/O或NewI/O)是Java提供的用于执行非阻塞I/O操作的API,它极大地增强了Java在处理网络通信和文件系统访问方面的能力。N...

    Python 网络编程完全指南:从零开始掌握 Socket 和网络工具

    Python网络编程完全指南:从零开始掌握Socket和网络工具在现代应用开发中,网络编程是不可或缺的技能。Python提供了一系列高效的工具和库来处理网络通信、数据传输和协议操作。本指南将从...

    Rust中的UDP编程:高效网络通信的实践指南

    在实时性要求高、允许少量数据丢失的场景中,UDP(用户数据报协议)凭借其无连接、低延迟的特性成为理想选择。Rust语言凭借内存安全和高性能的特点,为UDP网络编程提供了强大的工具支持。本文将深入探讨如...

    Python 网络编程的基础复习:理解Socket的作用

    计算机网络的组成部分在逻辑上可以划分为这样的结构五层网络体系应用层:应用层是网络协议的最高层,解决的是具体应用问题...

    25-2-Python网络编程-TCP 编程示例

    2-TCP编程示例应用程序通常通过“套接字”(socket)向网络发出请求或者应答网络请求,使主机间或者一台计算机上的进程间可以通信。Python语言提供了两种访问网络服务的功能。...

    linux下C++ socket网络编程——即时通信系统(含源码)

    一:项目内容本项目使用C++实现一个具备服务器端和客户端即时通信且具有私聊功能的聊天室。目的是学习C++网络开发的基本概念,同时也可以熟悉下Linux下的C++程序编译和简单MakeFile编写二:需...

    Python快速入门教程7:循环语句

    一、循环语句简介循环语句用于重复执行一段代码块,直到满足特定条件为止。Python支持两种主要的循环结构:for循环和while循环。...

    10分钟学会Socket通讯,学不会你打我

    Socket通讯是软硬件直接常用的一种通讯方式,分为TCP和UDP通讯。在我的职业生涯中,有且仅用过一次UDP通讯。而TCP通讯系统却经常写,正好今天写了一个TCP通讯的软件。总结一下内容软件使用C#...

    Python 高级编程之网络编程 Socket(六)

    一、概述Python网络编程是指使用Python语言编写的网络应用程序。这种编程涉及到网络通信、套接字编程、协议解析等多种方面的知识。...

    linux网络编程Socket之RST详解

    产生RST的三个条件:1.目的地为某端口的SYN到达,然而该端口上没有正在监听的服务器;2.TCP想取消一个已有的连接;3.TCP接收到一个根本不存在的连接上的分节;现在模拟上面的三种情况:cl...

    ABB机器人编程实用技巧,多项案例

    ...

    Python中实现Socket通讯(附详细代码)

    套接字(socket)是一种在计算机网络中进行进程间通信的方法,它允许不同主机上的程序通过网络相互通信。套接字是网络编程的基础,几乎所有的网络应用程序都使用某种形式的套接字来实现网络功能。套接字可以用...

    取消回复欢迎 发表评论: