百度360必应搜狗淘宝本站头条
vba高级教程svn连接scheduledtaskmybatis plus结构体数组
当前位置：网站首页 > 编程网 > 正文

通过实例详细讲解Quartz.NET的一些高级功能的应用，你用到了多少

yuyutoo 2024-11-01 15:55 2 浏览 0 评论

Quartz.NET 是一个强大的开源作业调度库，提供了许多高级功能。以下是 Quartz.NET 的常用高级功能：

  1. Cron 表达式触发器： 使用 Cron 表达式定义灵活的调度规则，实现复杂的时间调度策略。
  2. 作业依赖性： 允许定义作业之间的依赖关系，确保它们按照特定的顺序执行。
  3. 作业执行中的数据传递： 在调度作业时，可以传递参数和数据，使得作业能够根据需要获取执行时的上下文信息。
  4. 全局作业监听器： 添加全局监听器，监听作业的执行生命周期事件，例如作业执行前、执行后等。
  5. 全局触发器监听器： 添加全局监听器，监听触发器的生命周期事件，例如触发器触发、触发器完成等。
  6. 自定义日历： 可以实现自定义的日历逻辑，例如排除特定日期或时间段，以满足业务需求。
  7. 集群模式： 允许将 Quartz.NET 实例配置为集群，实现分布式作业调度，确保高可用性和负载均衡。
  8. 持久性作业： Quartz.NET 提供了作业的持久性支持，可以将作业和触发器存储在数据库中，保证作业不会丢失。
  9. 作业状态记录： Quartz.NET 能够记录作业的执行状态，包括成功、失败、被否决等，方便监控和故障排查。
  10. 并行执行： 允许多个作业同时执行，提高系统的并发性能。

这些功能使得 Quartz.NET 成为一个灵活且功能丰富的作业调度框架，适用于各种复杂的调度需求。

以下是 Quartz.NET 的高级功能示例，包含中文注释：

1.Cron 表达式触发器

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<NetworkStatusCheckJob>()
                .WithIdentity("networkStatusCheckJob", "group1")
                .Build();

            // 创建触发器，使用 Cron 表达式，每天10:30触发一次
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("networkStatusCheckTrigger", "group1")
                .StartNow()
                .WithCronSchedule("0 30 10 ? * *")
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

2.作业间的依赖性

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业1
            IJobDetail job1 = JobBuilder.Create<Job1>()
                .WithIdentity("job1", "group1")
                .Build();

            // 创建作业2
            IJobDetail job2 = JobBuilder.Create<Job2>()
                .WithIdentity("job2", "group1")
                .Build();

            // 创建触发器1
            ITrigger trigger1 = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartNow()
                .Build();

            // 创建触发器2，设置在触发器1后执行
            ITrigger trigger2 = TriggerBuilder.Create()
                .WithIdentity("trigger2", "group1")
                .StartNow()
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job1, trigger1).Wait();
            scheduler.ScheduleJob(job2, trigger2.ForJob(job1).Build()).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class Job1 : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("Job1 执行");
    }
}

public class Job2 : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("Job2 执行");
    }
}

3.作业执行中的数据传递

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建带数据的作业
            IJobDetail job = JobBuilder.Create<DataPassingJob>()
                .WithIdentity("dataPassingJob", "group1")
                .UsingJobData("key1", "value1")
                .UsingJobData("key2", 123)
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("dataPassingTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class DataPassingJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        // 从作业执行上下文中获取传递的数据
        JobDataMap dataMap = context.JobDetail.JobDataMap;
        string value1 = dataMap.GetString("key1");
        int value2 = dataMap.GetInt("key2");

        Console.WriteLine(#34;作业执行中的数据：key1={value1}, key2={value2}");
    }
}

4.全局作业监听器

using Quartz;
using Quartz.Impl;
using System;

public class GlobalJobListener : IJobListener
{
    public string Name => "GlobalJobListener";

    public Task JobExecutionVetoed(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;作业被否决：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }

    public Task JobToBeExecuted(IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;准备执行作业：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }

    public Task JobWasExecuted(IJobExecutionContext context, JobExecutionException jobException, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;作业执行完成：{context.JobDetail.Key}");
        return Task.CompletedTask;
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 添加全局作业监听器
            scheduler.ListenerManager.AddJobListener(new GlobalJobListener());

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()


                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

5.全局触发器监听器

using Quartz;
using Quartz.Impl;
using System;

public class GlobalTriggerListener : ITriggerListener
{
    public string Name => "GlobalTriggerListener";

    public Task TriggerComplete(ITrigger trigger, IJobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器完成：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task TriggerFired(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器触发：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task TriggerMisfired(ITrigger trigger, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;触发器错过触发：{trigger.Key}");
        return Task.CompletedTask;
    }

    public Task<bool> VetoJobExecution(ITrigger trigger, IJobExecutionContext context, CancellationToken cancellationToken = default)
    {
        Console.WriteLine(#34;否决作业执行：{trigger.Key}");
        return Task.FromResult(false);
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 添加全局触发器监听器
            scheduler.ListenerManager.AddTriggerListener(new GlobalTriggerListener());

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

6.自定义日历

using Quartz;
using Quartz.Impl;
using System;

public class CustomCalendar : BaseCalendar
{
    // 实现自定义的日历逻辑，这里简单演示一个排除周末的例子
    public override bool IsTimeIncluded(DateTimeOffset timeStampUtc)
    {
        return timeStampUtc.DayOfWeek != DayOfWeek.Saturday && timeStampUtc.DayOfWeek != DayOfWeek.Sunday;
    }

    public override DateTimeOffset GetNextIncludedTimeUtc(DateTimeOffset timeStampUtc)
    {
        // 确保下一个时间是在排除条件内的
        DateTimeOffset nextTime = timeStampUtc.AddSeconds(1);
        while (!IsTimeIncluded(nextTime))
        {
            nextTime = nextTime.AddSeconds(1);
        }
        return nextTime;
    }
}

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 使用自定义日历
            scheduler.AddCalendar("customCalendar", new CustomCalendar(), true, true);

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器，关联自定义日历
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .ModifiedByCalendar("customCalendar")
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

7.集群模式

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例，设置为集群模式
            IScheduler scheduler = schedulerFactory.GetScheduler(new NameValueCollection { { "quartz.jobStore.type", "Quartz.Simpl.RAMJobStore, Quartz" } }).Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

8.持久性作业

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例，设置为使用 AdoJobStore 持久性存储
            IScheduler scheduler = schedulerFactory.GetScheduler(new NameValueCollection
            {
                { "quartz.jobStore.type", "Quartz.Impl.AdoJobStore.JobStoreTX, Quartz" },
                { "quartz.jobStore.driverDelegateType", "Quartz.Impl.AdoJobStore.StdAdoDelegate, Quartz" },
                { "quartz.jobStore.dataSource", "myDS" },
                { "quartz.dataSource.myDS.connectionString", "YourConnectionString" },
                { "quartz.jobStore.tablePrefix", "QRTZ_" },
                { "quartz.jobStore.useProperties", "true" },
                { "quartz.jobStore.misfireThreshold", "60000" }
            }).Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<SimpleJob>()
                .WithIdentity("simpleJob", "group1")
                .StoreDurably() // 设置为持久性作业
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("simpleTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.AddJob(job, true).Wait();
            scheduler.ScheduleJob(trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class SimpleJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        Console.WriteLine("简单作业执行中...");
    }
}

9.作业状态记录

using Quartz;
using Quartz.Impl;
using System;

class Program
{
    static void Main(string[] args)
    {
        try
        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = schedulerFactory.GetScheduler().Result;

            // 创建作业
            IJobDetail job = JobBuilder.Create<StatusRecordingJob>()
                .WithIdentity("statusRecordingJob", "group1")
                .Build();

            // 创建触发器
            ITrigger trigger = TriggerBuilder.Create()
                .WithIdentity("statusRecordingTrigger", "group1")
                .StartNow()
                .WithSimpleSchedule(x => x
                    .WithIntervalInSeconds(20)
                    .RepeatForever())
                .Build();

            // 将作业和触发器添加到调度器
            scheduler.ScheduleJob(job, trigger).Wait();

            // 启动调度器
            scheduler.Start().Wait();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            scheduler.Shutdown().Wait();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class StatusRecordingJob : IJob
{
    public void Execute(IJobExecutionContext context)
    {
        // 记录作业状态
        Console.WriteLine(#34;作业执行中... 执行状态：{context.Result}");
    }
}

10.并行执行

using Quartz;
using Quartz.Impl;
using System;
using System.Threading.Tasks;

class Program
{
    static async Task Main(string[] args)
    {
        try


        {
            // 创建调度器工厂
            ISchedulerFactory schedulerFactory = new StdSchedulerFactory();

            // 获取调度器实例
            IScheduler scheduler = await schedulerFactory.GetScheduler();

            // 创建作业1
            IJobDetail job1 = JobBuilder.Create<ParallelJob>()
                .WithIdentity("parallelJob1", "group1")
                .Build();

            // 创建作业2
            IJobDetail job2 = JobBuilder.Create<ParallelJob>()
                .WithIdentity("parallelJob2", "group1")
                .Build();

            // 创建触发器1
            ITrigger trigger1 = TriggerBuilder.Create()
                .WithIdentity("trigger1", "group1")
                .StartNow()
                .Build();

            // 创建触发器2
            ITrigger trigger2 = TriggerBuilder.Create()
                .WithIdentity("trigger2", "group1")
                .StartNow()
                .Build();

            // 将作业和触发器添加到调度器
            await scheduler.ScheduleJob(job1, trigger1);
            await scheduler.ScheduleJob(job2, trigger2);

            // 启动调度器
            await scheduler.Start();

            Console.WriteLine("Quartz.NET 已启动，按任意键退出...");
            Console.ReadKey();

            // 关闭调度器
            await scheduler.Shutdown();
        }
        catch (SchedulerException se)
        {
            Console.WriteLine(se);
        }
    }
}

public class ParallelJob : IJob
{
    public async Task Execute(IJobExecutionContext context)
    {
        // 模拟作业执行时间
        await Task.Delay(TimeSpan.FromSeconds(10));

        Console.WriteLine(#34;并行作业执行中... 执行时间：{DateTime.Now}");
    }
}

这些示例涵盖了 Quartz.NET 的一些高级功能，包括 Cron 表达式触发器、作业间的依赖性、作业执行中的数据传递、全局作业监听器、全局触发器监听器、自定义日历、集群模式、持久性作业、作业状态记录和并行执行。希望对你理解 Quartz.NET 的高级功能有所帮助。

相关推荐

【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）是一种在计算机网络中进行进程间通信的方法，它允许不同主机上的程序通过网络相互通信。套接字是网络编程的基础，几乎所有的网络应用程序都使用某种形式的套接字来实现网络功能。套接字可以用...

取消回复欢迎 你 发表评论:

一周热门
最近发表
标签列表